batchInserter

package

v0.6.0 Latest Latest Go to latest Published: Jun 10, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	InsertingQueueDepth            = "inserting_queue_depth"
	DroppedEventsFromDbFailCounter = "dropped_events_db_fail_count"
)

This section is empty.

func Metrics() []xmetrics.Metric

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

func NewBatchInserter(config Config, logger log.Logger, metricsRegistry provider.Provider, inserter db.Inserter) (*BatchInserter, error)

func (b *BatchInserter) Insert(record db.Record)

func (b *BatchInserter) Start()

func (b *BatchInserter) Stop()

type Config struct {
	MaxWorkers       int
	MaxBatchSize     int
	MaxBatchWaitTime time.Duration
	QueueSize        int
}

type Measures struct {
	InsertingQueue               metrics.Gauge
	DroppedEventsFromDbFailCount metrics.Counter
}

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider