NewInput creates a new mock input that will return transactions containing a list of batches, then exit.

NewManager provides a new mock manager.

Cache provides a mock cache implementation.

CacheItem represents a cached key/ttl pair.

Input provides a mocked input implementation.

Manager provides a mock benthos manager that components can use to test interactions with fake resources.

OutputChanneled implements the output.Type interface around an exported transaction channel.

OutputWriter provides a mock implementation of types.OutputWriter.

Processor provides a mock processor implementation around a closure.

RateLimit provides a mock rate limit implementation around a closure.