mocks

package
v4.0.7+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2020 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) Brokers 

func (_m *Client) Brokers() []*sarama.Broker

Brokers provides a mock function with given fields:

func (*Client) Close 

func (_m *Client) Close() error

Close provides a mock function with given fields:

func (*Client) Closed 

func (_m *Client) Closed() bool

Closed provides a mock function with given fields:

func (*Client) Config 

func (_m *Client) Config() *sarama.Config

Config provides a mock function with given fields:

func (*Client) Controller 

func (_m *Client) Controller() (*sarama.Broker, error)

Controller provides a mock function with given fields:

func (*Client) Coordinator 

func (_m *Client) Coordinator(consumerGroup string) (*sarama.Broker, error)

Coordinator provides a mock function with given fields: consumerGroup

func (*Client) GetOffset 

func (_m *Client) GetOffset(topic string, partitionID int32, time int64) (int64, error)

GetOffset provides a mock function with given fields: topic, partitionID, time

func (*Client) InSyncReplicas 

func (_m *Client) InSyncReplicas(topic string, partitionID int32) ([]int32, error)

InSyncReplicas provides a mock function with given fields: topic, partitionID

func (*Client) InitProducerID 

func (_m *Client) InitProducerID() (*sarama.InitProducerIDResponse, error)

InitProducerID provides a mock function with given fields:

func (*Client) Leader 

func (_m *Client) Leader(topic string, partitionID int32) (*sarama.Broker, error)

Leader provides a mock function with given fields: topic, partitionID

func (*Client) OfflineReplicas 

func (_m *Client) OfflineReplicas(topic string, partitionID int32) ([]int32, error)

OfflineReplicas provides a mock function with given fields: topic, partitionID

func (*Client) Partitions 

func (_m *Client) Partitions(topic string) ([]int32, error)

Partitions provides a mock function with given fields: topic

func (*Client) RefreshController 

func (_m *Client) RefreshController() (*sarama.Broker, error)

RefreshController provides a mock function with given fields

func (*Client) RefreshCoordinator 

func (_m *Client) RefreshCoordinator(consumerGroup string) error

RefreshCoordinator provides a mock function with given fields: consumerGroup

func (*Client) RefreshMetadata 

func (_m *Client) RefreshMetadata(topics ...string) error

RefreshMetadata provides a mock function with given fields: topics

func (*Client) Replicas 

func (_m *Client) Replicas(topic string, partitionID int32) ([]int32, error)

Replicas provides a mock function with given fields: topic, partitionID

func (*Client) Topics 

func (_m *Client) Topics() ([]string, error)

Topics provides a mock function with given fields:

func (*Client) WritablePartitions 

func (_m *Client) WritablePartitions(topic string) ([]int32, error)

WritablePartitions provides a mock function with given fields: topic

type SaramaBroker 

type SaramaBroker struct {
	mock.Mock
}

SaramaBroker is an autogenerated mock type for the SaramaBroker type

func (*SaramaBroker) AddOffsetsToTxn 

func (_m *SaramaBroker) AddOffsetsToTxn(request *sarama.AddOffsetsToTxnRequest) (*sarama.AddOffsetsToTxnResponse, error)

AddOffsetsToTxn provides a mock function with given fields: request

func (*SaramaBroker) AddPartitionsToTxn 

func (_m *SaramaBroker) AddPartitionsToTxn(request *sarama.AddPartitionsToTxnRequest) (*sarama.AddPartitionsToTxnResponse, error)

AddPartitionsToTxn provides a mock function with given fields: request

func (*SaramaBroker) Addr 

func (_m *SaramaBroker) Addr() string

Addr provides a mock function with given fields:

func (*SaramaBroker) AlterConfigs 

func (_m *SaramaBroker) AlterConfigs(request *sarama.AlterConfigsRequest) (*sarama.AlterConfigsResponse, error)

AlterConfigs provides a mock function with given fields: request

func (*SaramaBroker) ApiVersions 

func (_m *SaramaBroker) ApiVersions(request *sarama.ApiVersionsRequest) (*sarama.ApiVersionsResponse, error)

ApiVersions provides a mock function with given fields: request

func (*SaramaBroker) Close 

func (_m *SaramaBroker) Close() error

Close provides a mock function with given fields:

func (*SaramaBroker) CommitOffset 

func (_m *SaramaBroker) CommitOffset(request *sarama.OffsetCommitRequest) (*sarama.OffsetCommitResponse, error)

CommitOffset provides a mock function with given fields: request

func (*SaramaBroker) Connected 

func (_m *SaramaBroker) Connected() (bool, error)

Connected provides a mock function with given fields:

func (*SaramaBroker) CreateAcls 

func (_m *SaramaBroker) CreateAcls(request *sarama.CreateAclsRequest) (*sarama.CreateAclsResponse, error)

CreateAcls provides a mock function with given fields: request

func (*SaramaBroker) CreatePartitions 

func (_m *SaramaBroker) CreatePartitions(request *sarama.CreatePartitionsRequest) (*sarama.CreatePartitionsResponse, error)

CreatePartitions provides a mock function with given fields: request

func (*SaramaBroker) CreateTopics 

func (_m *SaramaBroker) CreateTopics(request *sarama.CreateTopicsRequest) (*sarama.CreateTopicsResponse, error)

CreateTopics provides a mock function with given fields: request

func (*SaramaBroker) DeleteAcls 

func (_m *SaramaBroker) DeleteAcls(request *sarama.DeleteAclsRequest) (*sarama.DeleteAclsResponse, error)

DeleteAcls provides a mock function with given fields: request

func (*SaramaBroker) DeleteGroups 

func (_m *SaramaBroker) DeleteGroups(request *sarama.DeleteGroupsRequest) (*sarama.DeleteGroupsResponse, error)

DeleteGroups provides a mock function with given fields: request

func (*SaramaBroker) DeleteRecords 

func (_m *SaramaBroker) DeleteRecords(request *sarama.DeleteRecordsRequest) (*sarama.DeleteRecordsResponse, error)

DeleteRecords provides a mock function with given fields: request

func (*SaramaBroker) DeleteTopics 

func (_m *SaramaBroker) DeleteTopics(request *sarama.DeleteTopicsRequest) (*sarama.DeleteTopicsResponse, error)

DeleteTopics provides a mock function with given fields: request

func (*SaramaBroker) DescribeAcls 

func (_m *SaramaBroker) DescribeAcls(request *sarama.DescribeAclsRequest) (*sarama.DescribeAclsResponse, error)

DescribeAcls provides a mock function with given fields: request

func (*SaramaBroker) DescribeConfigs 

func (_m *SaramaBroker) DescribeConfigs(request *sarama.DescribeConfigsRequest) (*sarama.DescribeConfigsResponse, error)

DescribeConfigs provides a mock function with given fields: request

func (*SaramaBroker) DescribeGroups 

func (_m *SaramaBroker) DescribeGroups(request *sarama.DescribeGroupsRequest) (*sarama.DescribeGroupsResponse, error)

DescribeGroups provides a mock function with given fields: request

func (*SaramaBroker) EndTxn 

func (_m *SaramaBroker) EndTxn(request *sarama.EndTxnRequest) (*sarama.EndTxnResponse, error)

EndTxn provides a mock function with given fields: request

func (*SaramaBroker) Fetch 

func (_m *SaramaBroker) Fetch(request *sarama.FetchRequest) (*sarama.FetchResponse, error)

Fetch provides a mock function with given fields: request

func (*SaramaBroker) FetchOffset 

func (_m *SaramaBroker) FetchOffset(request *sarama.OffsetFetchRequest) (*sarama.OffsetFetchResponse, error)

FetchOffset provides a mock function with given fields: request

func (*SaramaBroker) FindCoordinator 

func (_m *SaramaBroker) FindCoordinator(request *sarama.FindCoordinatorRequest) (*sarama.FindCoordinatorResponse, error)

FindCoordinator provides a mock function with given fields: request

func (*SaramaBroker) GetAvailableOffsets 

func (_m *SaramaBroker) GetAvailableOffsets(request *sarama.OffsetRequest) (*sarama.OffsetResponse, error)

GetAvailableOffsets provides a mock function with given fields: request

func (*SaramaBroker) GetConsumerMetadata 

func (_m *SaramaBroker) GetConsumerMetadata(request *sarama.ConsumerMetadataRequest) (*sarama.ConsumerMetadataResponse, error)

GetConsumerMetadata provides a mock function with given fields: request

func (*SaramaBroker) GetMetadata 

func (_m *SaramaBroker) GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)

GetMetadata provides a mock function with given fields: request

func (*SaramaBroker) Heartbeat 

func (_m *SaramaBroker) Heartbeat(request *sarama.HeartbeatRequest) (*sarama.HeartbeatResponse, error)

Heartbeat provides a mock function with given fields: request

func (*SaramaBroker) ID 

func (_m *SaramaBroker) ID() int32

ID provides a mock function with given fields:

func (*SaramaBroker) InitProducerID 

func (_m *SaramaBroker) InitProducerID(request *sarama.InitProducerIDRequest) (*sarama.InitProducerIDResponse, error)

InitProducerID provides a mock function with given fields: request

func (*SaramaBroker) JoinGroup 

func (_m *SaramaBroker) JoinGroup(request *sarama.JoinGroupRequest) (*sarama.JoinGroupResponse, error)

JoinGroup provides a mock function with given fields: request

func (*SaramaBroker) LeaveGroup 

func (_m *SaramaBroker) LeaveGroup(request *sarama.LeaveGroupRequest) (*sarama.LeaveGroupResponse, error)

LeaveGroup provides a mock function with given fields: request

func (*SaramaBroker) ListGroups 

func (_m *SaramaBroker) ListGroups(request *sarama.ListGroupsRequest) (*sarama.ListGroupsResponse, error)

ListGroups provides a mock function with given fields: request

func (*SaramaBroker) Open 

func (_m *SaramaBroker) Open(conf *sarama.Config) error

Open provides a mock function with given fields: conf

func (*SaramaBroker) Produce 

func (_m *SaramaBroker) Produce(request *sarama.ProduceRequest) (*sarama.ProduceResponse, error)

Produce provides a mock function with given fields: request

func (*SaramaBroker) Rack 

func (_m *SaramaBroker) Rack() string

Rack provides a mock function with given fields:

func (*SaramaBroker) SyncGroup 

func (_m *SaramaBroker) SyncGroup(request *sarama.SyncGroupRequest) (*sarama.SyncGroupResponse, error)

SyncGroup provides a mock function with given fields: request

func (*SaramaBroker) TxnOffsetCommit 

func (_m *SaramaBroker) TxnOffsetCommit(request *sarama.TxnOffsetCommitRequest) (*sarama.TxnOffsetCommitResponse, error)

TxnOffsetCommit provides a mock function with given fields: request

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.