batch

Documentation

Index

• func Batch(values <-chan *model.InstructionSet, maxItems int, maxTimeout time.Duration, ...) chan *model.InstructionSet

Functions

func Batch

func Batch(values <-chan *model.InstructionSet, maxItems int, maxTimeout time.Duration, bufferSize int, clock clock.Clock) chan *model.InstructionSet

Batch batches up Instruction sets from a channel. Batches are created whenever maxItems InstructionSets have been received or maxTimeout has elapsed since the last batch was created (whichever occurs first).