storer

Dec 6, 2023

Changes in this version

type Sample

+ func MakeSampleUsingChunks(chunks []swarm.Chunk, anchor []byte) (Sample, error)

type SampleStats

+ TaddrDuration time.Duration

Nov 6, 2023

Changes in this version

+ func Validate(ctx context.Context, basePath string, opts *Options) error

type DB

+ func (db *DB) CacheShallowCopy(ctx context.Context, store internal.Storage, addrs ...swarm.Address) error

Oct 16, 2023

Changes in this version

+ func Compact(ctx context.Context, basePath string, opts *Options, validate bool) error

Sep 20, 2023

Changes in this version

type ReserveStat

+ Epoch uint64

+ SizeWithinRadius int

+ TotalSize int

Aug 10, 2023

Changes in this version

type ReserveStat

+ LastBinIDs []uint64

Aug 4, 2023

Changes in this version

+ const SampleSize

+ var ErrDBQuit = errors.New("db quit")

+ type BinC struct

+ Address swarm.Address

+ BatchID []byte

+ BinID uint64

+ type CacheStat struct

+ Capacity int

+ Size int

+ type CacheStore interface

+ Cache func() storage.Putter

+ Lookup func() storage.Getter

+ type ChunkStoreStat struct

+ SharedSlots int

+ TotalChunks int

+ type DB struct

+ func New(ctx context.Context, dirPath string, opts *Options) (*DB, error)

+ func (db *DB) BatchHint(address swarm.Address) ([]byte, error)

+ func (db *DB) Cache() storage.Putter

+ func (db *DB) ChunkStore() storage.ReadOnlyChunkStore

+ func (db *DB) Close() error

+ func (db *DB) DebugInfo(ctx context.Context) (Info, error)

+ func (db *DB) DeletePin(ctx context.Context, root swarm.Address) (err error)

+ func (db *DB) DeleteSession(tagID uint64) error

+ func (db *DB) DirectUpload() PutterSession

+ func (db *DB) Download(cache bool) storage.Getter

+ func (db *DB) EvictBatch(ctx context.Context, batchID []byte) error

+ func (db *DB) Execute(ctx context.Context, do func(internal.Storage) error) error

+ func (db *DB) HasPin(root swarm.Address) (has bool, err error)

+ func (db *DB) IsWithinStorageRadius(addr swarm.Address) bool

+ func (db *DB) IteratePinCollection(root swarm.Address, iterateFn func(swarm.Address) (bool, error)) error

+ func (db *DB) ListSessions(offset, limit int) ([]SessionInfo, error)

+ func (db *DB) Lookup() storage.Getter

+ func (db *DB) Metrics() []prometheus.Collector

+ func (db *DB) NewCollection(ctx context.Context) (PutterSession, error)

+ func (db *DB) NewSession() (SessionInfo, error)

+ func (db *DB) Pins() (address []swarm.Address, err error)

+ func (db *DB) PusherFeed() <-chan *pusher.Op

+ func (db *DB) Report(ctx context.Context, chunk swarm.Chunk, state storage.ChunkState) error

+ func (db *DB) ReserveGet(ctx context.Context, addr swarm.Address, batchID []byte) (chunk swarm.Chunk, err error)

+ func (db *DB) ReserveHas(addr swarm.Address, batchID []byte) (has bool, err error)

+ func (db *DB) ReserveIterateChunks(cb func(swarm.Chunk) (bool, error)) error

+ func (db *DB) ReserveLastBinIDs() ([]uint64, error)

+ func (db *DB) ReservePutter() storage.Putter

+ func (db *DB) ReserveSample(ctx context.Context, anchor []byte, storageRadius uint8, consensusTime uint64, ...) (Sample, error)

+ func (db *DB) ReserveSize() int

+ func (db *DB) Session(tagID uint64) (SessionInfo, error)

+ func (db *DB) SetRetrievalService(r retrieval.Interface)

+ func (db *DB) StartReserveWorker(ctx context.Context, s Syncer, radius func() (uint8, error))

+ func (db *DB) StorageRadius() uint8

+ func (db *DB) SubscribeBin(ctx context.Context, bin uint8, start uint64) (<-chan *BinC, func(), <-chan error)

+ func (db *DB) SubscribePush(ctx context.Context) (<-chan swarm.Chunk, func())

+ func (db *DB) Upload(ctx context.Context, pin bool, tagID uint64) (PutterSession, error)

+ type Debugger interface

+ DebugInfo func(context.Context) (Info, error)

+ type Info struct

+ Cache CacheStat

+ ChunkStore ChunkStoreStat

+ Pinning PinningStat

+ Reserve ReserveStat

+ Upload UploadStat

+ type LocalStore interface

+ ChunkStore func() storage.ReadOnlyChunkStore

+ type NetStore interface

+ DirectUpload func() PutterSession

+ Download func(pin bool) storage.Getter

+ PusherFeed func() <-chan *pusher.Op

+ type Options struct

+ Address swarm.Address

+ Batchstore postage.Storer

+ CacheCapacity uint64

+ LdbBlockCacheCapacity uint64

+ LdbDisableSeeksCompaction bool

+ LdbOpenFilesLimit uint64

+ LdbStats atomic.Pointer[prometheus.HistogramVec]

+ LdbWriteBufferSize uint64

+ Logger log.Logger

+ RadiusSetter topology.SetStorageRadiuser

+ ReserveCapacity int

+ ReserveWakeUpDuration time.Duration

+ StateStore storage.StateStorer

+ ValidStamp postage.ValidStampFn

+ WarmupDuration time.Duration

+ type PinIterator interface

+ IteratePinCollection func(root swarm.Address, iterateFn func(swarm.Address) (bool, error)) error

+ type PinStore interface

+ DeletePin func(context.Context, swarm.Address) error

+ HasPin func(swarm.Address) (bool, error)

+ NewCollection func(context.Context) (PutterSession, error)

+ Pins func() ([]swarm.Address, error)

+ type PinningStat struct

+ TotalChunks int

+ TotalCollections int

+ type PutterSession interface

+ Cleanup func() error

+ Done func(swarm.Address) error

+ type RadiusChecker interface

+ IsWithinStorageRadius func(addr swarm.Address) bool

+ StorageRadius func() uint8

+ type Reserve interface

+ EvictBatch func(ctx context.Context, batchID []byte) error

+ ReserveSample func(context.Context, []byte, uint8, uint64, *big.Int) (Sample, error)

+ ReserveSize func() int

+ type ReserveIterator interface

+ ReserveIterateChunks func(cb func(swarm.Chunk) (bool, error)) error

+ type ReserveStat struct

+ Capacity int

+ Size int

+ type ReserveStore interface

+ ReserveGet func(ctx context.Context, addr swarm.Address, batchID []byte) (swarm.Chunk, error)

+ ReserveHas func(addr swarm.Address, batchID []byte) (bool, error)

+ ReserveLastBinIDs func() ([]uint64, error)

+ ReservePutter func() storage.Putter

+ SubscribeBin func(ctx context.Context, bin uint8, start uint64) (<-chan *BinC, func(), <-chan error)

+ type Sample struct

+ Items []SampleItem

+ Stats SampleStats

+ func RandSample(t *testing.T, anchor []byte) Sample

+ type SampleItem struct

+ ChunkAddress swarm.Address

+ ChunkData []byte

+ Stamp swarm.Stamp

+ TransformedAddress swarm.Address

+ type SampleStats struct

+ BatchesBelowValueDuration time.Duration

+ BelowBalanceIgnored int64

+ ChunkLoadDuration time.Duration

+ ChunkLoadFailed int64

+ HmacrDuration time.Duration

+ InvalidStamp int64

+ IterationDuration time.Duration

+ NewIgnored int64

+ RogueChunk int64

+ SampleInserts int64

+ StampLoadFailed int64

+ TotalDuration time.Duration

+ TotalIterated int64

+ ValidStampDuration time.Duration

+ type SessionInfo = upload.TagItem

+ type Syncer interface

+ Start func(context.Context)

+ SyncRate func() float64

+ type UploadStat struct

+ TotalSynced int

+ TotalUploaded int

+ type UploadStore interface

+ BatchHint func(swarm.Address) ([]byte, error)

+ DeleteSession func(tagID uint64) error

+ ListSessions func(offset, limit int) ([]SessionInfo, error)

+ NewSession func() (SessionInfo, error)

+ Session func(tagID uint64) (SessionInfo, error)

+ Upload func(ctx context.Context, pin bool, tagID uint64) (PutterSession, error)