Documentation ¶
Overview ¶
Package collector implements expired piece deletion from storage node.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Interval time.Duration `help:"how frequently expired pieces are collected" default:"1h0m0s"` ExpirationGracePeriod time.Duration `` /* 191-byte string literal not displayed */ ExpirationBatchSize int `` /* 127-byte string literal not displayed */ }
Config defines parameters for storage node Collector.
type RunOnce ¶ added in v1.116.3
type RunOnce struct {
// contains filtered or unexported fields
}
RunOnce executes the collector only once.
func NewRunnerOnce ¶ added in v1.116.3
func NewRunnerOnce(log *zap.Logger, pieces *pieces.Store, usedSerials *usedserials.Table, config Config, stop *modular.StopTrigger) RunOnce
NewRunnerOnce creates a new RunOnce.
type Service ¶
Service implements collecting expired pieces on the storage node.
architecture: Chore
func NewService ¶
func NewService(log *zap.Logger, pieces *pieces.Store, usedSerials *usedserials.Table, config Config) *Service
NewService creates a new collector service.
Click to show internal directories.
Click to hide internal directories.