Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mocks

package

Go to main page

Versions in this module

v0

v0.1.75

Oct 3, 2019

v0.1.74

Oct 3, 2019

Changes in this version

+ type MockClusterAdmin struct

+ func NewMockClusterAdmin(ctrl *gomock.Controller) *MockClusterAdmin

+ func (m *MockClusterAdmin) AlterConfig(arg0 sarama.ConfigResourceType, arg1 string, arg2 map[string]*string, ...) error

+ func (m *MockClusterAdmin) Close() error

+ func (m *MockClusterAdmin) CreateACL(arg0 sarama.Resource, arg1 sarama.Acl) error

+ func (m *MockClusterAdmin) CreatePartitions(arg0 string, arg1 int32, arg2 [][]int32, arg3 bool) error

+ func (m *MockClusterAdmin) CreateTopic(arg0 string, arg1 *sarama.TopicDetail, arg2 bool) error

+ func (m *MockClusterAdmin) DeleteACL(arg0 sarama.AclFilter, arg1 bool) ([]sarama.MatchingAcl, error)

+ func (m *MockClusterAdmin) DeleteConsumerGroup(arg0 string) error

+ func (m *MockClusterAdmin) DeleteRecords(arg0 string, arg1 map[int32]int64) error

+ func (m *MockClusterAdmin) DeleteTopic(arg0 string) error

+ func (m *MockClusterAdmin) DescribeCluster() ([]*sarama.Broker, int32, error)

+ func (m *MockClusterAdmin) DescribeConfig(arg0 sarama.ConfigResource) ([]sarama.ConfigEntry, error)

+ func (m *MockClusterAdmin) DescribeConsumerGroups(arg0 []string) ([]*sarama.GroupDescription, error)

+ func (m *MockClusterAdmin) DescribeTopics(arg0 []string) ([]*sarama.TopicMetadata, error)

+ func (m *MockClusterAdmin) EXPECT() *MockClusterAdminMockRecorder

+ func (m *MockClusterAdmin) ListAcls(arg0 sarama.AclFilter) ([]sarama.ResourceAcls, error)

+ func (m *MockClusterAdmin) ListConsumerGroupOffsets(arg0 string, arg1 map[string][]int32) (*sarama.OffsetFetchResponse, error)

+ func (m *MockClusterAdmin) ListConsumerGroups() (map[string]string, error)

+ func (m *MockClusterAdmin) ListTopics() (map[string]sarama.TopicDetail, error)

+ type MockClusterAdminMockRecorder struct

+ func (mr *MockClusterAdminMockRecorder) AlterConfig(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) Close() *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) CreateACL(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) CreatePartitions(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) CreateTopic(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DeleteACL(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DeleteConsumerGroup(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DeleteRecords(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DeleteTopic(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DescribeCluster() *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DescribeConfig(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DescribeConsumerGroups(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) DescribeTopics(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) ListAcls(arg0 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) ListConsumerGroupOffsets(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) ListConsumerGroups() *gomock.Call

+ func (mr *MockClusterAdminMockRecorder) ListTopics() *gomock.Call

v0.1.73

Sep 14, 2019

Changes in this version

+ type MockFlowMSK struct

+ func NewMockFlowMSK(ctrl *gomock.Controller) *MockFlowMSK

+ func (m *MockFlowMSK) EXPECT() *MockFlowMSKMockRecorder

+ func (m *MockFlowMSK) GetBootstrapBrokers(clusterName string) (*string, error)

+ func (m *MockFlowMSK) GetClusterArn(clusterName string) (*string, error)

+ type MockFlowMSKMockRecorder struct

+ func (mr *MockFlowMSKMockRecorder) GetBootstrapBrokers(clusterName interface{}) *gomock.Call

+ func (mr *MockFlowMSKMockRecorder) GetClusterArn(clusterName interface{}) *gomock.Call

v0.1.72

Sep 14, 2019

Changes in this version

+ type MockBroker struct

+ func NewMockBroker(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockFlowKafka(ctrl *gomock.Controller) *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 struct

+ 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