Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockBroker
- func (m *MockBroker) Close() error
- func (m *MockBroker) CreateTopics(request *sarama.CreateTopicsRequest) (*sarama.CreateTopicsResponse, error)
- func (m *MockBroker) DeleteTopics(request *sarama.DeleteTopicsRequest) (*sarama.DeleteTopicsResponse, error)
- func (m *MockBroker) DescribeConfigs(request *sarama.DescribeConfigsRequest) (*sarama.DescribeConfigsResponse, error)
- func (m *MockBroker) EXPECT() *MockBrokerMockRecorder
- func (m *MockBroker) GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)
- func (m *MockBroker) Open(conf *sarama.Config) error
- type MockBrokerMockRecorder
- func (mr *MockBrokerMockRecorder) Close() *gomock.Call
- func (mr *MockBrokerMockRecorder) CreateTopics(request interface{}) *gomock.Call
- func (mr *MockBrokerMockRecorder) DeleteTopics(request interface{}) *gomock.Call
- func (mr *MockBrokerMockRecorder) DescribeConfigs(request interface{}) *gomock.Call
- func (mr *MockBrokerMockRecorder) GetMetadata(request interface{}) *gomock.Call
- func (mr *MockBrokerMockRecorder) Open(conf interface{}) *gomock.Call
- type MockFlowKafka
- func (m *MockFlowKafka) CreateTopic(topic string, numPartitions, replicationFactor int, retentionMs string) error
- func (m *MockFlowKafka) DeleteTopic(topic string) error
- func (m *MockFlowKafka) DescribeTopic(topic ...string) ([]*pkg.Topic, error)
- func (m *MockFlowKafka) EXPECT() *MockFlowKafkaMockRecorder
- func (m *MockFlowKafka) GetMetadata() (*pkg.Metadata, error)
- func (m *MockFlowKafka) Produce(topic string, msg []byte) error
- type MockFlowKafkaMockRecorder
- func (mr *MockFlowKafkaMockRecorder) CreateTopic(topic, numPartitions, replicationFactor, retentionMs interface{}) *gomock.Call
- func (mr *MockFlowKafkaMockRecorder) DeleteTopic(topic interface{}) *gomock.Call
- func (mr *MockFlowKafkaMockRecorder) DescribeTopic(topic ...interface{}) *gomock.Call
- func (mr *MockFlowKafkaMockRecorder) GetMetadata() *gomock.Call
- func (mr *MockFlowKafkaMockRecorder) Produce(topic, msg interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBroker ¶
type MockBroker struct {
// contains filtered or unexported fields
}
MockBroker is a mock of Broker interface
func NewMockBroker ¶
func NewMockBroker(ctrl *gomock.Controller) *MockBroker
NewMockBroker creates a new mock instance
func (*MockBroker) CreateTopics ¶
func (m *MockBroker) CreateTopics(request *sarama.CreateTopicsRequest) (*sarama.CreateTopicsResponse, error)
CreateTopics mocks base method
func (*MockBroker) DeleteTopics ¶
func (m *MockBroker) DeleteTopics(request *sarama.DeleteTopicsRequest) (*sarama.DeleteTopicsResponse, error)
DeleteTopics mocks base method
func (*MockBroker) DescribeConfigs ¶
func (m *MockBroker) DescribeConfigs(request *sarama.DescribeConfigsRequest) (*sarama.DescribeConfigsResponse, error)
DescribeConfigs mocks base method
func (*MockBroker) EXPECT ¶
func (m *MockBroker) EXPECT() *MockBrokerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBroker) GetMetadata ¶
func (m *MockBroker) GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)
GetMetadata mocks base method
type MockBrokerMockRecorder ¶
type MockBrokerMockRecorder struct {
// contains filtered or unexported fields
}
MockBrokerMockRecorder is the mock recorder for MockBroker
func (*MockBrokerMockRecorder) Close ¶
func (mr *MockBrokerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockBrokerMockRecorder) CreateTopics ¶
func (mr *MockBrokerMockRecorder) CreateTopics(request interface{}) *gomock.Call
CreateTopics indicates an expected call of CreateTopics
func (*MockBrokerMockRecorder) DeleteTopics ¶
func (mr *MockBrokerMockRecorder) DeleteTopics(request interface{}) *gomock.Call
DeleteTopics indicates an expected call of DeleteTopics
func (*MockBrokerMockRecorder) DescribeConfigs ¶
func (mr *MockBrokerMockRecorder) DescribeConfigs(request interface{}) *gomock.Call
DescribeConfigs indicates an expected call of DescribeConfigs
func (*MockBrokerMockRecorder) GetMetadata ¶
func (mr *MockBrokerMockRecorder) GetMetadata(request interface{}) *gomock.Call
GetMetadata indicates an expected call of GetMetadata
func (*MockBrokerMockRecorder) Open ¶
func (mr *MockBrokerMockRecorder) Open(conf interface{}) *gomock.Call
Open indicates an expected call of Open
type MockFlowKafka ¶
type MockFlowKafka struct {
// contains filtered or unexported fields
}
MockFlowKafka is a mock of FlowKafka interface
func NewMockFlowKafka ¶
func NewMockFlowKafka(ctrl *gomock.Controller) *MockFlowKafka
NewMockFlowKafka creates a new mock instance
func (*MockFlowKafka) CreateTopic ¶
func (m *MockFlowKafka) CreateTopic(topic string, numPartitions, replicationFactor int, retentionMs string) error
CreateTopic mocks base method
func (*MockFlowKafka) DeleteTopic ¶
func (m *MockFlowKafka) DeleteTopic(topic string) error
DeleteTopic mocks base method
func (*MockFlowKafka) DescribeTopic ¶
func (m *MockFlowKafka) DescribeTopic(topic ...string) ([]*pkg.Topic, error)
DescribeTopic mocks base method
func (*MockFlowKafka) EXPECT ¶
func (m *MockFlowKafka) EXPECT() *MockFlowKafkaMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockFlowKafka) GetMetadata ¶
func (m *MockFlowKafka) GetMetadata() (*pkg.Metadata, error)
GetMetadata mocks base method
type MockFlowKafkaMockRecorder ¶
type MockFlowKafkaMockRecorder struct {
// contains filtered or unexported fields
}
MockFlowKafkaMockRecorder is the mock recorder for MockFlowKafka
func (*MockFlowKafkaMockRecorder) CreateTopic ¶
func (mr *MockFlowKafkaMockRecorder) CreateTopic(topic, numPartitions, replicationFactor, retentionMs interface{}) *gomock.Call
CreateTopic indicates an expected call of CreateTopic
func (*MockFlowKafkaMockRecorder) DeleteTopic ¶
func (mr *MockFlowKafkaMockRecorder) DeleteTopic(topic interface{}) *gomock.Call
DeleteTopic indicates an expected call of DeleteTopic
func (*MockFlowKafkaMockRecorder) DescribeTopic ¶
func (mr *MockFlowKafkaMockRecorder) DescribeTopic(topic ...interface{}) *gomock.Call
DescribeTopic indicates an expected call of DescribeTopic
func (*MockFlowKafkaMockRecorder) GetMetadata ¶
func (mr *MockFlowKafkaMockRecorder) GetMetadata() *gomock.Call
GetMetadata indicates an expected call of GetMetadata
func (*MockFlowKafkaMockRecorder) Produce ¶
func (mr *MockFlowKafkaMockRecorder) Produce(topic, msg interface{}) *gomock.Call
Produce indicates an expected call of Produce
Source Files