template

Dec 9, 2019

Changes in this version

+ const DefaultInstanceMaxBatchSize

+ const DefaultInstanceMaxBuffered

+ const DefaultInstanceMaxRequests

+ type Instance generic.Type

+ type InstancePreprocessor func(*Instance) bool

+ type InstanceRingBuffer struct

+ func NewInstanceRingBuffer(size int) *InstanceRingBuffer

+ func (b *InstanceRingBuffer) Add(inst *Instance) (isOverwrite bool)

+ func (b *InstanceRingBuffer) NextBatch(maxSize int) []*Instance

+ func (b *InstanceRingBuffer) Size() int

+ func (b *InstanceRingBuffer) UnprocessedCount() int

+ type InstanceSender func(context.Context, []*Instance) error

+ type InstanceWriter struct

+ InputChan chan []*Instance

+ MaxBatchSize int

+ MaxBuffered int

+ MaxRequests int

+ OverwriteFunc func()

+ PreprocessFunc InstancePreprocessor

+ SendFunc InstanceSender

+ TotalFailedToSend int64

+ TotalFilteredOut int64

+ TotalInFlight int64

+ TotalOverwritten int64

+ TotalReceived int64

+ TotalSent int64

+ func (w *InstanceWriter) InternalMetrics(prefix string) []*datapoint.Datapoint

+ func (w *InstanceWriter) Start(ctx context.Context)

+ func (w *InstanceWriter) WaitForShutdown()