Documentation
¶
Overview ¶
Package mock_eaa is a generated GoMock package.
Package mock_eaa is a generated GoMock package.
Index ¶
- type MockKafkaInterface
- func (m *MockKafkaInterface) DefaultSaramaSubscriberConfig() *sarama.Config
- func (m *MockKafkaInterface) DefaultSaramaSyncPublisherConfig() *sarama.Config
- func (m *MockKafkaInterface) EXPECT() *MockKafkaInterfaceMockRecorder
- func (m *MockKafkaInterface) NewPublisher(config kafka.PublisherConfig, logger watermill.LoggerAdapter) (*kafka.Publisher, error)
- func (m *MockKafkaInterface) NewSubscriber(config kafka.SubscriberConfig, logger watermill.LoggerAdapter) (*kafka.Subscriber, error)
- func (m *MockKafkaInterface) NewWithPartitioningMarshaler(generatePartitionKey kafka.GeneratePartitionKey) kafka.MarshalerUnmarshaler
- type MockKafkaInterfaceMockRecorder
- func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig() *gomock.Call
- func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig() *gomock.Call
- func (mr *MockKafkaInterfaceMockRecorder) NewPublisher(config, logger interface{}) *gomock.Call
- func (mr *MockKafkaInterfaceMockRecorder) NewSubscriber(config, logger interface{}) *gomock.Call
- func (mr *MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler(generatePartitionKey interface{}) *gomock.Call
- type MockKafkaPublisher
- type MockKafkaPublisherMockRecorder
- type MockKafkaSubscriber
- type MockKafkaSubscriberMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockKafkaInterface ¶
type MockKafkaInterface struct {
// contains filtered or unexported fields
}
MockKafkaInterface is a mock of KafkaInterface interface
func NewMockKafkaInterface ¶
func NewMockKafkaInterface(ctrl *gomock.Controller) *MockKafkaInterface
NewMockKafkaInterface creates a new mock instance
func (*MockKafkaInterface) DefaultSaramaSubscriberConfig ¶
func (m *MockKafkaInterface) DefaultSaramaSubscriberConfig() *sarama.Config
DefaultSaramaSubscriberConfig mocks base method
func (*MockKafkaInterface) DefaultSaramaSyncPublisherConfig ¶
func (m *MockKafkaInterface) DefaultSaramaSyncPublisherConfig() *sarama.Config
DefaultSaramaSyncPublisherConfig mocks base method
func (*MockKafkaInterface) EXPECT ¶
func (m *MockKafkaInterface) EXPECT() *MockKafkaInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockKafkaInterface) NewPublisher ¶
func (m *MockKafkaInterface) NewPublisher(config kafka.PublisherConfig, logger watermill.LoggerAdapter) (*kafka.Publisher, error)
NewPublisher mocks base method
func (*MockKafkaInterface) NewSubscriber ¶
func (m *MockKafkaInterface) NewSubscriber(config kafka.SubscriberConfig, logger watermill.LoggerAdapter) (*kafka.Subscriber, error)
NewSubscriber mocks base method
func (*MockKafkaInterface) NewWithPartitioningMarshaler ¶
func (m *MockKafkaInterface) NewWithPartitioningMarshaler(generatePartitionKey kafka.GeneratePartitionKey) kafka.MarshalerUnmarshaler
NewWithPartitioningMarshaler mocks base method
type MockKafkaInterfaceMockRecorder ¶
type MockKafkaInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaInterfaceMockRecorder is the mock recorder for MockKafkaInterface
func (*MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig ¶
func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSubscriberConfig() *gomock.Call
DefaultSaramaSubscriberConfig indicates an expected call of DefaultSaramaSubscriberConfig
func (*MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig ¶
func (mr *MockKafkaInterfaceMockRecorder) DefaultSaramaSyncPublisherConfig() *gomock.Call
DefaultSaramaSyncPublisherConfig indicates an expected call of DefaultSaramaSyncPublisherConfig
func (*MockKafkaInterfaceMockRecorder) NewPublisher ¶
func (mr *MockKafkaInterfaceMockRecorder) NewPublisher(config, logger interface{}) *gomock.Call
NewPublisher indicates an expected call of NewPublisher
func (*MockKafkaInterfaceMockRecorder) NewSubscriber ¶
func (mr *MockKafkaInterfaceMockRecorder) NewSubscriber(config, logger interface{}) *gomock.Call
NewSubscriber indicates an expected call of NewSubscriber
func (*MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler ¶
func (mr *MockKafkaInterfaceMockRecorder) NewWithPartitioningMarshaler(generatePartitionKey interface{}) *gomock.Call
NewWithPartitioningMarshaler indicates an expected call of NewWithPartitioningMarshaler
type MockKafkaPublisher ¶
type MockKafkaPublisher struct {
// contains filtered or unexported fields
}
MockKafkaPublisher is a mock of KafkaPublisher interface
func NewMockKafkaPublisher ¶
func NewMockKafkaPublisher(ctrl *gomock.Controller) *MockKafkaPublisher
NewMockKafkaPublisher creates a new mock instance
func (*MockKafkaPublisher) Close ¶
func (m *MockKafkaPublisher) Close() error
Close mocks base method
func (*MockKafkaPublisher) EXPECT ¶
func (m *MockKafkaPublisher) EXPECT() *MockKafkaPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockKafkaPublisherMockRecorder ¶
type MockKafkaPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaPublisherMockRecorder is the mock recorder for MockKafkaPublisher
func (*MockKafkaPublisherMockRecorder) Close ¶
func (mr *MockKafkaPublisherMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockKafkaPublisherMockRecorder) Publish ¶
func (mr *MockKafkaPublisherMockRecorder) Publish(topic interface{}, msgs ...interface{}) *gomock.Call
Publish indicates an expected call of Publish
type MockKafkaSubscriber ¶
type MockKafkaSubscriber struct {
// contains filtered or unexported fields
}
MockKafkaSubscriber is a mock of KafkaSubscriber interface
func NewMockKafkaSubscriber ¶
func NewMockKafkaSubscriber(ctrl *gomock.Controller) *MockKafkaSubscriber
NewMockKafkaSubscriber creates a new mock instance
func (*MockKafkaSubscriber) Close ¶
func (m *MockKafkaSubscriber) Close() error
Close mocks base method
func (*MockKafkaSubscriber) EXPECT ¶
func (m *MockKafkaSubscriber) EXPECT() *MockKafkaSubscriberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockKafkaSubscriberMockRecorder ¶
type MockKafkaSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaSubscriberMockRecorder is the mock recorder for MockKafkaSubscriber
func (*MockKafkaSubscriberMockRecorder) Close ¶
func (mr *MockKafkaSubscriberMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockKafkaSubscriberMockRecorder) Subscribe ¶
func (mr *MockKafkaSubscriberMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe
Source Files