batchDeleter

Jul 2, 2019

Changes in this version

type Config

+ SetSize int

Jun 10, 2019

Changes in this version

+ const DeletingQueueDepth

+ func Metrics() []xmetrics.Metric

+ type BatchDeleter struct

+ func NewBatchDeleter(config Config, logger log.Logger, metricsRegistry provider.Provider, ...) (*BatchDeleter, error)

+ func (d *BatchDeleter) Start()

+ func (d *BatchDeleter) Stop()

+ type Config struct

+ DeleteWaitTime time.Duration

+ GetLimit int

+ GetWaitTime time.Duration

+ MaxBatchSize int

+ MaxWorkers int

+ QueueSize int

+ Shard int

+ type Measures struct

+ DeletingQueue metrics.Gauge

+ func NewMeasures(p provider.Provider) *Measures