NewCollectionAdapter returns a mongo-driver/mongo collection wrapper.

NewMockAggregateCursor creates a new mock instance.

NewMockCollectionAdapter creates a new mock instance.

NewMockDriverDatabase creates a new mock instance.

NewMockStreamCursor creates a new mock instance.

WithBatchSize allows to specify a batch size when using changestream event.

WithFullDocument allows to returns the full document in oplogs when using changestream event.

WithMaxAwaitTime allows to specify the maximum await for new oplogs when using changestream event.

WithMaxRetries allows to specify the max retry attempts when watching collection fail return changes that occurred at or after the given maxRetries.

WithResumeAfter allows to specify the resume token for the change stream to resume notifications after the operation specified in the resume token.

WithRetryDelay allows to specify the delay between each retry attempt when watching collection fail return changes that occurred at or after the given duration.

WithStartAtOperationTime allows to specify the timestamp for the change stream to only return changes that occurred at or after the given timestamp.

ChangeEvent document according https://docs.mongodb.com/manual/reference/change-events/#change-stream-output.

ChangeEventKafkaMessageTransformer transforms mongodb change events into a format that will be used by the kafka client.

MockAggregateCursor is a mock of AggregateCursor interface.

MockAggregateCursorMockRecorder is the mock recorder for MockAggregateCursor.

MockCollectionAdapter is a mock of CollectionAdapter interface.

MockCollectionAdapterMockRecorder is the mock recorder for MockCollectionAdapter.

MockDriverDatabase is a mock of DriverDatabase interface.

MockDriverDatabaseMockRecorder is the mock recorder for MockDriverDatabase.

MockStreamCursor is a mock of StreamCursor interface.

MockStreamCursorMockRecorder is the mock recorder for MockStreamCursor.

AggregateCursor represents a mongo-driver/mongo Cursor object.

CollectionAdapter is a wrapper over the mongo-driver/mongo collection object mainly allowing us to use interfaces.

DriverDatabase represents the mongo-driver/mongo database object.

StreamCursor represents a mongo-driver/mongo ChangeStream object.