bloomfilter

May 9, 2024

Changes in this version

type SyncObserver

+ func (obs *SyncObserver) TestingForceTableSize(size int)

+ func (obs *SyncObserver) TestingRetainInfos() map[storj.NodeID]*RetainInfo

+ type TestingObserver interface

+ TestingForceTableSize func(size int)

+ TestingRetainInfos func() map[storj.NodeID]*RetainInfo

Mar 15, 2024

Changes in this version

type Observer

+ func (obs *Observer) TestingForceTableSize(size int)

Jan 19, 2024

Changes in this version

type Config

+ MaxBloomFilterSize memory.Size

May 31, 2023

Changes in this version

type Observer

+ func (obs *Observer) TestingRetainInfos() map[storj.NodeID]*RetainInfo

May 15, 2023

Changes in this version

type Config

+ UseSyncObserver bool

+ type SyncObserver struct

+ func NewSyncObserver(log *zap.Logger, config Config, overlay overlay.DB) *SyncObserver

+ func (obs *SyncObserver) Finish(ctx context.Context) (err error)

+ func (obs *SyncObserver) Fork(ctx context.Context) (_ rangedloop.Partial, err error)

+ func (obs *SyncObserver) Join(ctx context.Context, partial rangedloop.Partial) (err error)

+ func (obs *SyncObserver) Process(ctx context.Context, segments []segmentloop.Segment) error

+ func (obs *SyncObserver) Start(ctx context.Context, startTime time.Time) (err error)

+ type Upload struct

+ func NewUpload(log *zap.Logger, config Config) *Upload

+ func (bfu *Upload) CheckConfig() error

+ func (bfu *Upload) UploadBloomFilters(ctx context.Context, latestCreationDate time.Time, ...) (err error)

Jan 10, 2023

Changes in this version

type Config

+ UseRangedLoop bool

+ type Observer struct

+ func NewObserver(log *zap.Logger, config Config, overlay overlay.DB) *Observer

+ func (obs *Observer) Finish(ctx context.Context) (err error)

+ func (obs *Observer) Fork(ctx context.Context) (_ rangedloop.Partial, err error)

+ func (obs *Observer) Join(ctx context.Context, partial rangedloop.Partial) (err error)

+ func (obs *Observer) Start(ctx context.Context, startTime time.Time) (err error)

type PieceTracker

+ func NewPieceTrackerWithSeed(log *zap.Logger, config Config, pieceCounts map[storj.NodeID]int64, seed byte) *PieceTracker

+ func (pieceTracker *PieceTracker) Process(ctx context.Context, segments []segmentloop.Segment) error

Nov 2, 2022

Changes in this version

+ const LATEST

type Config

+ RunOnce bool

Sep 30, 2022

Changes in this version

type PieceTracker

+ LatestCreationTime time.Time

Sep 19, 2022

Changes in this version

+ type Config struct

+ AccessGrant string

+ Bucket string

+ Enabled bool

+ ExpireIn time.Duration

+ FalsePositiveRate float64

+ InitialPieces int

+ Interval time.Duration

+ ZipBatchSize int

+ type PieceTracker struct

+ RetainInfos map[storj.NodeID]*RetainInfo

+ func NewPieceTracker(log *zap.Logger, config Config, pieceCounts map[storj.NodeID]int) *PieceTracker

+ func (pieceTracker *PieceTracker) InlineSegment(ctx context.Context, segment *segmentloop.Segment) (err error)

+ func (pieceTracker *PieceTracker) LoopStarted(ctx context.Context, info segmentloop.LoopInfo) (err error)

+ func (pieceTracker *PieceTracker) RemoteSegment(ctx context.Context, segment *segmentloop.Segment) error

+ type RetainInfo struct

+ Count int

+ CreationDate time.Time

+ Filter *bloomfilter.Filter

+ type Service struct

+ Loop *sync2.Cycle

+ func NewService(log *zap.Logger, config Config, overlay overlay.DB, loop *segmentloop.Service) *Service

+ func (service *Service) Run(ctx context.Context) (err error)

+ func (service *Service) RunOnce(ctx context.Context) (err error)