NewAllowAllRouter creates a new router that routes all data to the backend queue.

NewBroadcastRouter creates a broadcast router.

NewMockRouter creates a new mock instance.

NewShardedRouter creates a sharded router.

NewWithAckRouter creates a new router that routes buffer and waits for acknowledgements.

MockRouter is a mock of Router interface.

MockRouterMockRecorder is the mock recorder for MockRouter.

ShardedQueue is a backend queue responsible for a set of shards.

Router routes data to the corresponding backends.