reaper

Jan 8, 2024

Changes in this version

type GCStats

+ EmptyAds int

type Option

+ func WithSegmentSize(size int) Option

+ func WithSyncSegmentSize(size int) Option

Dec 15, 2023

Changes in this version

+ func ArchiveName(providerID peer.ID) string

Dec 13, 2023

Changes in this version

+ var ErrNoCarReader = errors.New("car reader not available")

+ var ErrProviderNotFound = errors.New("provider not found")

+ type GCAd struct

+ ContextID string

+ Entries cid.Cid

+ Previous cid.Cid

+ type GCState struct

+ LastProcessedAdCid cid.Cid

+ type GCStats struct

+ AdsProcessed int

+ CarsDataSize int64

+ CarsRemoved int

+ CtxIDsKept int

+ CtxIDsRemoved int

+ IndexAdsKept int

+ IndexAdsRemoved int

+ IndexesRemoved int

+ RemovalAds int

+ ReusedCtxIDs int

+ TimeElapsed time.Duration

+ func (s GCStats) String() string

+ type Option func(*config) error

+ func WithCarCompress(alg string) Option

+ func WithCarDelete(del bool) Option

+ func WithCarRead(rd bool) Option

+ func WithCommit(commit bool) Option

+ func WithDatastoreDir(dir string) Option

+ func WithDatastoreTempDir(dir string) Option

+ func WithDeleteNotFound(dnf bool) Option

+ func WithEntriesDepthLimit(depthLimit int64) Option

+ func WithEntriesFromPublisher(entsFromPub bool) Option

+ func WithHttpTimeout(to time.Duration) Option

+ func WithLibp2pHost(h host.Host) Option

+ func WithPCache(pc *pcache.ProviderCache) Option

+ func WithTopicName(topic string) Option

+ type Reaper struct

+ func New(idxr indexer.Interface, fileStore filestore.Interface, options ...Option) (*Reaper, error)

+ func (r *Reaper) AddStats(a GCStats)

+ func (r *Reaper) ClearStats()

+ func (r *Reaper) Close()

+ func (r *Reaper) DataArchiveName(ctx context.Context, providerID peer.ID) (string, error)

+ func (r *Reaper) Reap(ctx context.Context, providerID peer.ID) error

+ func (r *Reaper) Stats() GCStats