engine

Documentation

Index

• func BatchLogs(ctx context.Context, config BatchConfig)
• func WorkerCreator(transforms []types.Transformer, sink types.Sink) func(string, <-chan *types.LogBatch) *worker
• type BatchConfig
• type WorkerCreatorFunc

Functions

func BatchLogs

func BatchLogs(ctx context.Context, config BatchConfig)

func WorkerCreator

func WorkerCreator(transforms []types.Transformer, sink types.Sink) func(string, <-chan *types.LogBatch) *worker

Types

type BatchConfig

type BatchConfig struct {
	MaxBatchSize int
	MaxBatchWait time.Duration
	InputQueue   <-chan *types.Log
	OutputQueue  chan<- *types.LogBatch
	AckGenerator func(log *types.Log) func()
}

type WorkerCreatorFunc

type WorkerCreatorFunc func(string, <-chan *types.LogBatch) *worker