Versions in this module Expand all Collapse all v0 v0.1.0 Aug 3, 2021 Changes in this version + var ErrDbClosed = errors.New("db closed") + type PullStorer struct + func New(storer storage.Storer) *PullStorer + func (s *PullStorer) Cursors(ctx context.Context) (curs []uint64, err error) + func (s *PullStorer) Get(ctx context.Context, mode storage.ModeGet, addrs ...swarm.Address) ([]swarm.Chunk, error) + func (s *PullStorer) IntervalChunks(ctx context.Context, bin uint8, from, to uint64, limit int) (chs []swarm.Address, topmost uint64, err error) + func (s *PullStorer) Metrics() []prometheus.Collector + func (s *PullStorer) Put(ctx context.Context, mode storage.ModePut, chs ...swarm.Chunk) error + type Storer interface + Cursors func(ctx context.Context) ([]uint64, error) + Get func(ctx context.Context, mode storage.ModeGet, addrs ...swarm.Address) ([]swarm.Chunk, error) + Has func(ctx context.Context, addr swarm.Address) (bool, error) + IntervalChunks func(ctx context.Context, bin uint8, from, to uint64, limit int) (chunks []swarm.Address, topmost uint64, err error) + Put func(ctx context.Context, mode storage.ModePut, chs ...swarm.Chunk) error + Set func(ctx context.Context, mode storage.ModeSet, addrs ...swarm.Address) error
Go to main page