Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Error is the default error class for retain errors. Error = errs.Class("retain") )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { RetainTimeBuffer time.Duration `help:"allows for small differences in the satellite and storagenode clocks" default:"1h0m0s"` RetainStatus Status `` /* 144-byte string literal not displayed */ MaxConcurrentRetain int `help:"how many concurrent retain requests can be processed at the same time." default:"5"` }
Config defines parameters for the retain service.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service queues and processes retain requests from satellites.
func NewService ¶
NewService creates a new retain service.
func (*Service) Queue ¶
Queue adds a retain request to the queue. It discards a request for a satellite that already has a queued request. true is returned if the request is queued and false is returned if it is discarded
type Status ¶
type Status uint32
Status is a type defining the enabled/disabled status of retain requests.
const ( // Disabled means we do not do anything with retain requests. Disabled Status = iota + 1 // Enabled means we fully enable retain requests and delete data not defined by bloom filter. Enabled // Debug means we partially enable retain requests, and print out pieces we should delete, without actually deleting them. Debug )
Click to show internal directories.
Click to hide internal directories.