pullstorage

Documentation

Index

• Variables
• type PullStorer
  • func New(storer storage.Storer, logger log.Logger) *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) ([]swarm.Address, uint64, error)
  • func (s *PullStorer) Metrics() []prometheus.Collector
  • func (s *PullStorer) Put(ctx context.Context, mode storage.ModePut, chs ...swarm.Chunk) error
• type Storer

Variables

var (

	// ErrDbClosed is used to signal the underlying database was closed
	ErrDbClosed = errors.New("db closed")
)

Types

type PullStorer

type PullStorer struct {
	storage.Storer
	// contains filtered or unexported fields
}

PullStorer wraps storage.Storer.

func New

func New(storer storage.Storer, logger log.Logger) *PullStorer

New returns a new pullstorage Storer instance.

func (*PullStorer) Cursors

func (s *PullStorer) Cursors(ctx context.Context) (curs []uint64, err error)

Cursors gets the last BinID for every bin in the local storage

func (*PullStorer) Get

func (s *PullStorer) Get(ctx context.Context, mode storage.ModeGet, addrs ...swarm.Address) ([]swarm.Chunk, error)

Get chunks.

func (*PullStorer) IntervalChunks

func (s *PullStorer) IntervalChunks(ctx context.Context, bin uint8, from, to uint64, limit int) ([]swarm.Address, uint64, error)

IntervalChunks collects chunk for a requested interval.

func (*PullStorer) Metrics

func (s *PullStorer) Metrics() []prometheus.Collector

func (*PullStorer) Put

func (s *PullStorer) Put(ctx context.Context, mode storage.ModePut, chs ...swarm.Chunk) error

Put chunks.

type Storer

type Storer interface {
	// IntervalChunks collects chunk for a requested interval.
	IntervalChunks(ctx context.Context, bin uint8, from, to uint64, limit int) (chunks []swarm.Address, topmost uint64, err error)
	// Cursors gets the last BinID for every bin in the local storage
	Cursors(ctx context.Context) ([]uint64, error)
	// Get chunks.
	Get(ctx context.Context, mode storage.ModeGet, addrs ...swarm.Address) ([]swarm.Chunk, error)
	// Put chunks.
	Put(ctx context.Context, mode storage.ModePut, chs ...swarm.Chunk) error
	// Set chunks.
	Set(ctx context.Context, mode storage.ModeSet, addrs ...swarm.Address) error
	// Has chunks.
	Has(ctx context.Context, addr swarm.Address) (bool, error)
}

Storer is a thin wrapper around storage.Storer. It is used in order to collect and provide information about chunks currently present in the local store.