batchDeleter

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DeletingQueueDepth = "deleting_queue_depth"
)

Variables

This section is empty.

Functions

func Metrics 

func Metrics() []xmetrics.Metric

Types

type BatchDeleter 

type BatchDeleter struct {
	// contains filtered or unexported fields
}

func NewBatchDeleter 

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

func (*BatchDeleter) Start 

func (d *BatchDeleter) Start()

func (*BatchDeleter) Stop 

func (d *BatchDeleter) Stop()

type Config 

type Config struct {
	Shard          int
	MaxWorkers     int
	MaxBatchSize   int
	QueueSize      int
	DeleteWaitTime time.Duration
	GetLimit       int
	GetWaitTime    time.Duration
}

type Measures 

type Measures struct {
	DeletingQueue metrics.Gauge
}

func NewMeasures 

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.