NewMockFilterFunc creates a new instance of MockFilterFunc.

NewMockKafkaClient creates a new instance of MockKafkaClient.

NewMockPublisher creates a new instance of MockPublisher.

NewMockSenderStream creates a new instance of MockSenderStream.

MockFilterFunc is an autogenerated mock type for the FilterFunc type.

MockFilterFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'.

MockKafkaClient is an autogenerated mock type for the KafkaClient type.

MockKafkaClient_PollFetches_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PollFetches'.

MockPublisher is an autogenerated mock type for the Publisher type.

MockPublisher_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'.

MockSenderStream is an autogenerated mock type for the SenderStream type.

MockSenderStream_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'.

MockSenderStream_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'.

MockSenderStream_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'.

MockSenderStream_SendHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendHeader'.

MockSenderStream_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'.

MockSenderStream_SetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHeader'.

MockSenderStream_SetTrailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetTrailer'.