mocks

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminClient 

type AdminClient struct {
	mock.Mock
}

AdminClient is an autogenerated mock type for the AdminClient type

func (*AdminClient) AlterConfigs 

func (_m *AdminClient) AlterConfigs(ctx context.Context, resources []kafka.ConfigResource, options ...kafka.AlterConfigsAdminOption) ([]kafka.ConfigResourceResult, error)

AlterConfigs provides a mock function with given fields: ctx, resources, options

func (*AdminClient) Close 

func (_m *AdminClient) Close()

Close provides a mock function with given fields:

func (*AdminClient) ClusterID 

func (_m *AdminClient) ClusterID(ctx context.Context) (string, error)

ClusterID provides a mock function with given fields: ctx

func (*AdminClient) ControllerID 

func (_m *AdminClient) ControllerID(ctx context.Context) (int32, error)

ControllerID provides a mock function with given fields: ctx

func (*AdminClient) CreatePartitions 

func (_m *AdminClient) CreatePartitions(ctx context.Context, partitions []kafka.PartitionsSpecification, options ...kafka.CreatePartitionsAdminOption) ([]kafka.TopicResult, error)

CreatePartitions provides a mock function with given fields: ctx, partitions, options

func (*AdminClient) CreateTopics 

func (_m *AdminClient) CreateTopics(ctx context.Context, topics []kafka.TopicSpecification, options ...kafka.CreateTopicsAdminOption) ([]kafka.TopicResult, error)

CreateTopics provides a mock function with given fields: ctx, topics, options

func (*AdminClient) DeleteTopics 

func (_m *AdminClient) DeleteTopics(ctx context.Context, topics []string, options ...kafka.DeleteTopicsAdminOption) ([]kafka.TopicResult, error)

DeleteTopics provides a mock function with given fields: ctx, topics, options

func (*AdminClient) DescribeConfigs 

func (_m *AdminClient) DescribeConfigs(ctx context.Context, resources []kafka.ConfigResource, options ...kafka.DescribeConfigsAdminOption) ([]kafka.ConfigResourceResult, error)

DescribeConfigs provides a mock function with given fields: ctx, resources, options

func (*AdminClient) GetMetadata 

func (_m *AdminClient) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)

GetMetadata provides a mock function with given fields: topic, allTopics, timeoutMs

func (*AdminClient) SetOAuthBearerToken 

func (_m *AdminClient) SetOAuthBearerToken(oauthBearerToken kafka.OAuthBearerToken) error

SetOAuthBearerToken provides a mock function with given fields: oauthBearerToken

func (*AdminClient) SetOAuthBearerTokenFailure 

func (_m *AdminClient) SetOAuthBearerTokenFailure(errstr string) error

SetOAuthBearerTokenFailure provides a mock function with given fields: errstr

func (*AdminClient) String 

func (_m *AdminClient) String() string

String provides a mock function with given fields:

type Consumer 

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func (*Consumer) Assign 

func (_m *Consumer) Assign(partitions []kafka.TopicPartition) error

Assign provides a mock function with given fields: partitions

func (*Consumer) Assignment 

func (_m *Consumer) Assignment() ([]kafka.TopicPartition, error)

Assignment provides a mock function with given fields:

func (*Consumer) Close 

func (_m *Consumer) Close() error

Close provides a mock function with given fields:

func (*Consumer) Commit 

func (_m *Consumer) Commit() ([]kafka.TopicPartition, error)

Commit provides a mock function with given fields:

func (*Consumer) CommitMessage 

func (_m *Consumer) CommitMessage(m *kafka.Message) ([]kafka.TopicPartition, error)

CommitMessage provides a mock function with given fields: m

func (*Consumer) CommitOffsets 

func (_m *Consumer) CommitOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error)

CommitOffsets provides a mock function with given fields: offsets

func (*Consumer) Committed 

func (_m *Consumer) Committed(partitions []kafka.TopicPartition, timeoutMs int) ([]kafka.TopicPartition, error)

Committed provides a mock function with given fields: partitions, timeoutMs

func (*Consumer) Events 

func (_m *Consumer) Events() chan kafka.Event

Events provides a mock function with given fields:

func (*Consumer) GetConsumerGroupMetadata 

func (_m *Consumer) GetConsumerGroupMetadata() (*kafka.ConsumerGroupMetadata, error)

GetConsumerGroupMetadata provides a mock function with given fields:

func (*Consumer) GetMetadata 

func (_m *Consumer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)

GetMetadata provides a mock function with given fields: topic, allTopics, timeoutMs

func (*Consumer) GetWatermarkOffsets 

func (_m *Consumer) GetWatermarkOffsets(topic string, partition int32) (int64, int64, error)

GetWatermarkOffsets provides a mock function with given fields: topic, partition

func (*Consumer) Logs 

func (_m *Consumer) Logs() chan kafka.LogEvent

Logs provides a mock function with given fields:

func (*Consumer) OffsetsForTimes 

func (_m *Consumer) OffsetsForTimes(times []kafka.TopicPartition, timeoutMs int) ([]kafka.TopicPartition, error)

OffsetsForTimes provides a mock function with given fields: times, timeoutMs

func (*Consumer) Pause 

func (_m *Consumer) Pause(partitions []kafka.TopicPartition) error

Pause provides a mock function with given fields: partitions

func (*Consumer) Poll 

func (_m *Consumer) Poll(timeoutMs int) kafka.Event

Poll provides a mock function with given fields: timeoutMs

func (*Consumer) Position 

func (_m *Consumer) Position(partitions []kafka.TopicPartition) ([]kafka.TopicPartition, error)

Position provides a mock function with given fields: partitions

func (*Consumer) QueryWatermarkOffsets 

func (_m *Consumer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (int64, int64, error)

QueryWatermarkOffsets provides a mock function with given fields: topic, partition, timeoutMs

func (*Consumer) ReadMessage 

func (_m *Consumer) ReadMessage(timeout time.Duration) (*kafka.Message, error)

ReadMessage provides a mock function with given fields: timeout

func (*Consumer) Resume 

func (_m *Consumer) Resume(partitions []kafka.TopicPartition) error

Resume provides a mock function with given fields: partitions

func (*Consumer) Seek 

func (_m *Consumer) Seek(partition kafka.TopicPartition, timeoutMs int) error

Seek provides a mock function with given fields: partition, timeoutMs

func (*Consumer) SetOAuthBearerToken 

func (_m *Consumer) SetOAuthBearerToken(oauthBearerToken kafka.OAuthBearerToken) error

SetOAuthBearerToken provides a mock function with given fields: oauthBearerToken

func (*Consumer) SetOAuthBearerTokenFailure 

func (_m *Consumer) SetOAuthBearerTokenFailure(errstr string) error

SetOAuthBearerTokenFailure provides a mock function with given fields: errstr

func (*Consumer) StoreOffsets 

func (_m *Consumer) StoreOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error)

StoreOffsets provides a mock function with given fields: offsets

func (*Consumer) String 

func (_m *Consumer) String() string

String provides a mock function with given fields:

func (*Consumer) Subscribe 

func (_m *Consumer) Subscribe(topic string, rebalanceCb kafka.RebalanceCb) error

Subscribe provides a mock function with given fields: topic, rebalanceCb

func (*Consumer) SubscribeTopics 

func (_m *Consumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) error

SubscribeTopics provides a mock function with given fields: topics, rebalanceCb

func (*Consumer) Subscription 

func (_m *Consumer) Subscription() ([]string, error)

Subscription provides a mock function with given fields:

func (*Consumer) Unassign 

func (_m *Consumer) Unassign() error

Unassign provides a mock function with given fields:

func (*Consumer) Unsubscribe 

func (_m *Consumer) Unsubscribe() error

Unsubscribe provides a mock function with given fields:

type Producer 

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func (*Producer) AbortTransaction 

func (_m *Producer) AbortTransaction(ctx context.Context) error

AbortTransaction provides a mock function with given fields: ctx

func (*Producer) BeginTransaction 

func (_m *Producer) BeginTransaction() error

BeginTransaction provides a mock function with given fields:

func (*Producer) Close 

func (_m *Producer) Close()

Close provides a mock function with given fields:

func (*Producer) CommitTransaction 

func (_m *Producer) CommitTransaction(ctx context.Context) error

CommitTransaction provides a mock function with given fields: ctx

func (*Producer) Events 

func (_m *Producer) Events() chan confluent_kafka_gokafka.Event

Events provides a mock function with given fields:

func (*Producer) Flush 

func (_m *Producer) Flush(timeoutMs int) int

Flush provides a mock function with given fields: timeoutMs

func (*Producer) GetFatalError 

func (_m *Producer) GetFatalError() error

GetFatalError provides a mock function with given fields:

func (*Producer) GetMetadata 

func (_m *Producer) GetMetadata(topic *string, allTopics bool, timeoutMs int) (*confluent_kafka_gokafka.Metadata, error)

GetMetadata provides a mock function with given fields: topic, allTopics, timeoutMs

func (*Producer) GetTarget 

func (_m *Producer) GetTarget() *confluent_kafka_gokafka.Producer

GetTarget provides a mock function with given fields:

func (*Producer) InitTransactions 

func (_m *Producer) InitTransactions(ctx context.Context) error

InitTransactions provides a mock function with given fields: ctx

func (*Producer) Len 

func (_m *Producer) Len() int

Len provides a mock function with given fields:

func (*Producer) Logs 

func (_m *Producer) Logs() chan confluent_kafka_gokafka.LogEvent

Logs provides a mock function with given fields:

func (*Producer) OffsetsForTimes 

func (_m *Producer) OffsetsForTimes(times []confluent_kafka_gokafka.TopicPartition, timeoutMs int) ([]confluent_kafka_gokafka.TopicPartition, error)

OffsetsForTimes provides a mock function with given fields: times, timeoutMs

func (*Producer) Produce 

func (_m *Producer) Produce(msg *confluent_kafka_gokafka.Message, deliveryChan chan confluent_kafka_gokafka.Event) error

Produce provides a mock function with given fields: msg, deliveryChan

func (*Producer) ProduceChannel 

func (_m *Producer) ProduceChannel() chan *confluent_kafka_gokafka.Message

ProduceChannel provides a mock function with given fields:

func (*Producer) Purge 

func (_m *Producer) Purge(flags int) error

Purge provides a mock function with given fields: flags

func (*Producer) QueryWatermarkOffsets 

func (_m *Producer) QueryWatermarkOffsets(topic string, partition int32, timeoutMs int) (int64, int64, error)

QueryWatermarkOffsets provides a mock function with given fields: topic, partition, timeoutMs

func (*Producer) SendOffsetsToTransaction 

func (_m *Producer) SendOffsetsToTransaction(ctx context.Context, offsets []confluent_kafka_gokafka.TopicPartition, consumerMetadata *confluent_kafka_gokafka.ConsumerGroupMetadata) error

SendOffsetsToTransaction provides a mock function with given fields: ctx, offsets, consumerMetadata

func (*Producer) SetOAuthBearerToken 

func (_m *Producer) SetOAuthBearerToken(oauthBearerToken confluent_kafka_gokafka.OAuthBearerToken) error

SetOAuthBearerToken provides a mock function with given fields: oauthBearerToken

func (*Producer) SetOAuthBearerTokenFailure 

func (_m *Producer) SetOAuthBearerTokenFailure(errstr string) error

SetOAuthBearerTokenFailure provides a mock function with given fields: errstr

func (*Producer) String 

func (_m *Producer) String() string

String provides a mock function with given fields:

func (*Producer) TestFatalError 

func (_m *Producer) TestFatalError(code confluent_kafka_gokafka.ErrorCode, str string) confluent_kafka_gokafka.ErrorCode

TestFatalError provides a mock function with given fields: code, str

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.