NewMockConsumer creates a new mock instance.

NewMockConsumerFactory creates a new mock instance.

NewMockItem creates a new mock instance.

NewMockItemPartitions creates a new mock instance.

NewMockItemToPersist creates a new mock instance.

NewMockPersister creates a new mock instance.

MockConsumer is a mock of Consumer interface.

MockConsumerFactory is a mock of ConsumerFactory interface.

MockConsumerFactoryMockRecorder is the mock recorder for MockConsumerFactory.

MockConsumerMockRecorder is the mock recorder for MockConsumer.

MockItem is a mock of Item interface.

MockItemMockRecorder is the mock recorder for MockItem.

MockItemPartitions is a mock of ItemPartitions interface.

MockItemPartitionsMockRecorder is the mock recorder for MockItemPartitions.

MockItemToPersist is a mock of ItemToPersist interface.

MockItemToPersistMockRecorder is the mock recorder for MockItemToPersist.

MockPersister is a mock of Persister interface.

MockPersisterMockRecorder is the mock recorder for MockPersister.

Offsets encapsulates the whole queue tree state including the offsets of each leaf node.