mocks

package

v2.13.2+incompatible Latest Latest Go to latest Published: May 12, 2020 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nandatf/newrelic

Links

Open Source Insights

Documentation ¶

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL