Versions in this module Expand all Collapse all v0 v0.1.0 Aug 3, 2021 Changes in this version + var ErrInvalidChunk = errors.New("storage: invalid chunk") + var ErrNotFound = errors.New("storage: not found") + var ErrReferenceLength = errors.New("invalid reference length") + type Descriptor struct + Address swarm.Address + BinID uint64 + func (d *Descriptor) String() string + type Getter interface + Get func(ctx context.Context, mode ModeGet, addr swarm.Address) (ch swarm.Chunk, err error) + type Hasser interface + Has func(ctx context.Context, addr swarm.Address) (yes bool, err error) + HasMulti func(ctx context.Context, addrs ...swarm.Address) (yes []bool, err error) + type ModeGet int + const ModeGetLookup + const ModeGetPin + const ModeGetRequest + const ModeGetRequestPin + const ModeGetSync + func (m ModeGet) String() string + type ModePut int + const ModePutRequest + const ModePutRequestCache + const ModePutRequestPin + const ModePutSync + const ModePutUpload + const ModePutUploadPin + func (m ModePut) String() string + type ModeSet int + const ModeSetPin + const ModeSetRemove + const ModeSetSync + const ModeSetUnpin + func (m ModeSet) String() string + type PullSubscriber interface + SubscribePull func(ctx context.Context, bin uint8, since, until uint64) (c <-chan Descriptor, closed <-chan struct{}, stop func()) + type Putter interface + Put func(ctx context.Context, mode ModePut, chs ...swarm.Chunk) (exist []bool, err error) + type Setter interface + Set func(ctx context.Context, mode ModeSet, addrs ...swarm.Address) (err error) + type StateIterFunc func(key, value []byte) (stop bool, err error) + type StateStorer interface + DB func() *leveldb.DB + Delete func(key string) (err error) + Get func(key string, i interface{}) (err error) + Iterate func(prefix string, iterFunc StateIterFunc) (err error) + Put func(key string, i interface{}) (err error) + type Storer interface + GetMulti func(ctx context.Context, mode ModeGet, addrs ...swarm.Address) (ch []swarm.Chunk, err error) + LastPullSubscriptionBinID func(bin uint8) (id uint64, err error) + SubscribePush func(ctx context.Context) (c <-chan swarm.Chunk, stop func())