batching

Documentation

Index

• func Emitted(ctx context.Context, sourceType data.SourceType, batchItemCount int, ...)
• func Error(ctx context.Context)
• func Init(meter api.Meter) error
• func Success(ctx context.Context)

Functions

func Emitted

func Emitted(ctx context.Context, sourceType data.SourceType, batchItemCount int, elapsed time.Duration)

Emitted should be called when emitting a batch to record the batch emitted count, batch item emitted count, and time elapsed from when the batch was created.

func Error

func Error(ctx context.Context)

Error records an error when handling batch input.

func Init

func Init(meter api.Meter) error

Init initializes the batching metrics. This should only be called by the tattler constructor or tests.

func Success

func Success(ctx context.Context)

Success records successful handling of batch input so we can calculate error rate.