mocks

package
v1.22.1 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2026 License: BSD-2-Clause Imports: 6 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaHighwaterMarkProvider 

type KafkaHighwaterMarkProvider struct {
	HighWaterMarkStub func(context.Context, kafka.Topic, kafka.Partition) (*kafka.Offset, error)
	// contains filtered or unexported fields
}

func (*KafkaHighwaterMarkProvider) HighWaterMark 

func (fake *KafkaHighwaterMarkProvider) HighWaterMark(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition) (*kafka.Offset, error)

func (*KafkaHighwaterMarkProvider) HighWaterMarkArgsForCall 

func (fake *KafkaHighwaterMarkProvider) HighWaterMarkArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition)

func (*KafkaHighwaterMarkProvider) HighWaterMarkCallCount 

func (fake *KafkaHighwaterMarkProvider) HighWaterMarkCallCount() int

func (*KafkaHighwaterMarkProvider) HighWaterMarkCalls 

func (fake *KafkaHighwaterMarkProvider) HighWaterMarkCalls(stub func(context.Context, kafka.Topic, kafka.Partition) (*kafka.Offset, error))

func (*KafkaHighwaterMarkProvider) HighWaterMarkReturns 

func (fake *KafkaHighwaterMarkProvider) HighWaterMarkReturns(result1 *kafka.Offset, result2 error)

func (*KafkaHighwaterMarkProvider) HighWaterMarkReturnsOnCall 

func (fake *KafkaHighwaterMarkProvider) HighWaterMarkReturnsOnCall(i int, result1 *kafka.Offset, result2 error)

func (*KafkaHighwaterMarkProvider) Invocations 

func (fake *KafkaHighwaterMarkProvider) Invocations() map[string][][]interface{}

type KafkaJSONSender 

type KafkaJSONSender struct {
	SendDeleteStub func(context.Context, kafka.Topic, kafka.Key, ...sarama.RecordHeader) error

	SendDeletesStub func(context.Context, kafka.Entries) error

	SendUpdateStub func(context.Context, kafka.Topic, kafka.Key, kafka.Value, ...sarama.RecordHeader) error

	SendUpdatesStub func(context.Context, kafka.Entries) error
	// contains filtered or unexported fields
}

func (*KafkaJSONSender) Invocations 

func (fake *KafkaJSONSender) Invocations() map[string][][]interface{}

func (*KafkaJSONSender) SendDelete 

func (fake *KafkaJSONSender) SendDelete(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Key, arg4 ...sarama.RecordHeader) error

func (*KafkaJSONSender) SendDeleteArgsForCall 

func (fake *KafkaJSONSender) SendDeleteArgsForCall(i int) (context.Context, kafka.Topic, kafka.Key, []sarama.RecordHeader)

func (*KafkaJSONSender) SendDeleteCallCount 

func (fake *KafkaJSONSender) SendDeleteCallCount() int

func (*KafkaJSONSender) SendDeleteCalls 

func (fake *KafkaJSONSender) SendDeleteCalls(stub func(context.Context, kafka.Topic, kafka.Key, ...sarama.RecordHeader) error)

func (*KafkaJSONSender) SendDeleteReturns 

func (fake *KafkaJSONSender) SendDeleteReturns(result1 error)

func (*KafkaJSONSender) SendDeleteReturnsOnCall 

func (fake *KafkaJSONSender) SendDeleteReturnsOnCall(i int, result1 error)

func (*KafkaJSONSender) SendDeletes 

func (fake *KafkaJSONSender) SendDeletes(arg1 context.Context, arg2 kafka.Entries) error

func (*KafkaJSONSender) SendDeletesArgsForCall 

func (fake *KafkaJSONSender) SendDeletesArgsForCall(i int) (context.Context, kafka.Entries)

func (*KafkaJSONSender) SendDeletesCallCount 

func (fake *KafkaJSONSender) SendDeletesCallCount() int

func (*KafkaJSONSender) SendDeletesCalls 

func (fake *KafkaJSONSender) SendDeletesCalls(stub func(context.Context, kafka.Entries) error)

func (*KafkaJSONSender) SendDeletesReturns 

func (fake *KafkaJSONSender) SendDeletesReturns(result1 error)

func (*KafkaJSONSender) SendDeletesReturnsOnCall 

func (fake *KafkaJSONSender) SendDeletesReturnsOnCall(i int, result1 error)

func (*KafkaJSONSender) SendUpdate 

func (fake *KafkaJSONSender) SendUpdate(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Key, arg4 kafka.Value, arg5 ...sarama.RecordHeader) error

func (*KafkaJSONSender) SendUpdateArgsForCall 

func (fake *KafkaJSONSender) SendUpdateArgsForCall(i int) (context.Context, kafka.Topic, kafka.Key, kafka.Value, []sarama.RecordHeader)

func (*KafkaJSONSender) SendUpdateCallCount 

func (fake *KafkaJSONSender) SendUpdateCallCount() int

func (*KafkaJSONSender) SendUpdateCalls 

func (fake *KafkaJSONSender) SendUpdateCalls(stub func(context.Context, kafka.Topic, kafka.Key, kafka.Value, ...sarama.RecordHeader) error)

func (*KafkaJSONSender) SendUpdateReturns 

func (fake *KafkaJSONSender) SendUpdateReturns(result1 error)

func (*KafkaJSONSender) SendUpdateReturnsOnCall 

func (fake *KafkaJSONSender) SendUpdateReturnsOnCall(i int, result1 error)

func (*KafkaJSONSender) SendUpdates 

func (fake *KafkaJSONSender) SendUpdates(arg1 context.Context, arg2 kafka.Entries) error

func (*KafkaJSONSender) SendUpdatesArgsForCall 

func (fake *KafkaJSONSender) SendUpdatesArgsForCall(i int) (context.Context, kafka.Entries)

func (*KafkaJSONSender) SendUpdatesCallCount 

func (fake *KafkaJSONSender) SendUpdatesCallCount() int

func (*KafkaJSONSender) SendUpdatesCalls 

func (fake *KafkaJSONSender) SendUpdatesCalls(stub func(context.Context, kafka.Entries) error)

func (*KafkaJSONSender) SendUpdatesReturns 

func (fake *KafkaJSONSender) SendUpdatesReturns(result1 error)

func (*KafkaJSONSender) SendUpdatesReturnsOnCall 

func (fake *KafkaJSONSender) SendUpdatesReturnsOnCall(i int, result1 error)

type KafkaMessageHandler 

type KafkaMessageHandler struct {
	ConsumeMessageStub func(context.Context, *sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*KafkaMessageHandler) ConsumeMessage 

func (fake *KafkaMessageHandler) ConsumeMessage(arg1 context.Context, arg2 *sarama.ConsumerMessage) error

func (*KafkaMessageHandler) ConsumeMessageArgsForCall 

func (fake *KafkaMessageHandler) ConsumeMessageArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)

func (*KafkaMessageHandler) ConsumeMessageCallCount 

func (fake *KafkaMessageHandler) ConsumeMessageCallCount() int

func (*KafkaMessageHandler) ConsumeMessageCalls 

func (fake *KafkaMessageHandler) ConsumeMessageCalls(stub func(context.Context, *sarama.ConsumerMessage) error)

func (*KafkaMessageHandler) ConsumeMessageReturns 

func (fake *KafkaMessageHandler) ConsumeMessageReturns(result1 error)

func (*KafkaMessageHandler) ConsumeMessageReturnsOnCall 

func (fake *KafkaMessageHandler) ConsumeMessageReturnsOnCall(i int, result1 error)

func (*KafkaMessageHandler) Invocations 

func (fake *KafkaMessageHandler) Invocations() map[string][][]interface{}

type KafkaMessageHandlerBatch 

type KafkaMessageHandlerBatch struct {
	ConsumeMessagesStub func(context.Context, []*sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*KafkaMessageHandlerBatch) ConsumeMessages 

func (fake *KafkaMessageHandlerBatch) ConsumeMessages(arg1 context.Context, arg2 []*sarama.ConsumerMessage) error

func (*KafkaMessageHandlerBatch) ConsumeMessagesArgsForCall 

func (fake *KafkaMessageHandlerBatch) ConsumeMessagesArgsForCall(i int) (context.Context, []*sarama.ConsumerMessage)

func (*KafkaMessageHandlerBatch) ConsumeMessagesCallCount 

func (fake *KafkaMessageHandlerBatch) ConsumeMessagesCallCount() int

func (*KafkaMessageHandlerBatch) ConsumeMessagesCalls 

func (fake *KafkaMessageHandlerBatch) ConsumeMessagesCalls(stub func(context.Context, []*sarama.ConsumerMessage) error)

func (*KafkaMessageHandlerBatch) ConsumeMessagesReturns 

func (fake *KafkaMessageHandlerBatch) ConsumeMessagesReturns(result1 error)

func (*KafkaMessageHandlerBatch) ConsumeMessagesReturnsOnCall 

func (fake *KafkaMessageHandlerBatch) ConsumeMessagesReturnsOnCall(i int, result1 error)

func (*KafkaMessageHandlerBatch) Invocations 

func (fake *KafkaMessageHandlerBatch) Invocations() map[string][][]interface{}

type KafkaMessageHandlerBatchTx 

type KafkaMessageHandlerBatchTx struct {
	ConsumeMessagesStub func(context.Context, kv.Tx, []*sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*KafkaMessageHandlerBatchTx) ConsumeMessages 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessages(arg1 context.Context, arg2 kv.Tx, arg3 []*sarama.ConsumerMessage) error

func (*KafkaMessageHandlerBatchTx) ConsumeMessagesArgsForCall 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessagesArgsForCall(i int) (context.Context, kv.Tx, []*sarama.ConsumerMessage)

func (*KafkaMessageHandlerBatchTx) ConsumeMessagesCallCount 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessagesCallCount() int

func (*KafkaMessageHandlerBatchTx) ConsumeMessagesCalls 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessagesCalls(stub func(context.Context, kv.Tx, []*sarama.ConsumerMessage) error)

func (*KafkaMessageHandlerBatchTx) ConsumeMessagesReturns 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessagesReturns(result1 error)

func (*KafkaMessageHandlerBatchTx) ConsumeMessagesReturnsOnCall 

func (fake *KafkaMessageHandlerBatchTx) ConsumeMessagesReturnsOnCall(i int, result1 error)

func (*KafkaMessageHandlerBatchTx) Invocations 

func (fake *KafkaMessageHandlerBatchTx) Invocations() map[string][][]interface{}

type KafkaMessageHandlerTx 

type KafkaMessageHandlerTx struct {
	ConsumeMessageStub func(context.Context, kv.Tx, *sarama.ConsumerMessage) error
	// contains filtered or unexported fields
}

func (*KafkaMessageHandlerTx) ConsumeMessage 

func (fake *KafkaMessageHandlerTx) ConsumeMessage(arg1 context.Context, arg2 kv.Tx, arg3 *sarama.ConsumerMessage) error

func (*KafkaMessageHandlerTx) ConsumeMessageArgsForCall 

func (fake *KafkaMessageHandlerTx) ConsumeMessageArgsForCall(i int) (context.Context, kv.Tx, *sarama.ConsumerMessage)

func (*KafkaMessageHandlerTx) ConsumeMessageCallCount 

func (fake *KafkaMessageHandlerTx) ConsumeMessageCallCount() int

func (*KafkaMessageHandlerTx) ConsumeMessageCalls 

func (fake *KafkaMessageHandlerTx) ConsumeMessageCalls(stub func(context.Context, kv.Tx, *sarama.ConsumerMessage) error)

func (*KafkaMessageHandlerTx) ConsumeMessageReturns 

func (fake *KafkaMessageHandlerTx) ConsumeMessageReturns(result1 error)

func (*KafkaMessageHandlerTx) ConsumeMessageReturnsOnCall 

func (fake *KafkaMessageHandlerTx) ConsumeMessageReturnsOnCall(i int, result1 error)

func (*KafkaMessageHandlerTx) Invocations 

func (fake *KafkaMessageHandlerTx) Invocations() map[string][][]interface{}

type KafkaMetrics 

type KafkaMetrics struct {
	ConsumePartitionCreateFailureIncStub func(kafka.Topic, kafka.Partition)

	ConsumePartitionCreateOutOfRangeErrorIncStub func(kafka.Topic, kafka.Partition)

	ConsumePartitionCreateOutOfRangeErrorInitializeStub func(kafka.Topic, kafka.Partition)

	ConsumePartitionCreateSuccessIncStub func(kafka.Topic, kafka.Partition)

	ConsumePartitionCreateTotalIncStub func(kafka.Topic, kafka.Partition)

	CurrentOffsetStub func(kafka.Topic, kafka.Partition, kafka.Offset)

	ErrorCounterIncStub func(kafka.Topic, kafka.Partition)

	HighWaterMarkOffsetStub func(kafka.Topic, kafka.Partition, kafka.Offset)

	MessageHandlerDurationMeasureStub func(kafka.Topic, kafka.Partition, time.Duration)

	MessageHandlerFailureCounterIncStub func(kafka.Topic, kafka.Partition)

	MessageHandlerSuccessCounterIncStub func(kafka.Topic, kafka.Partition)

	MessageHandlerTotalCounterIncStub func(kafka.Topic, kafka.Partition)

	SyncProducerDurationMeasureStub func(kafka.Topic, time.Duration)

	SyncProducerFailureCounterIncStub func(kafka.Topic)

	SyncProducerSuccessCounterIncStub func(kafka.Topic)

	SyncProducerTotalCounterIncStub func(kafka.Topic)
	// contains filtered or unexported fields
}

func (*KafkaMetrics) ConsumePartitionCreateFailureInc 

func (fake *KafkaMetrics) ConsumePartitionCreateFailureInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateFailureIncArgsForCall 

func (fake *KafkaMetrics) ConsumePartitionCreateFailureIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateFailureIncCallCount 

func (fake *KafkaMetrics) ConsumePartitionCreateFailureIncCallCount() int

func (*KafkaMetrics) ConsumePartitionCreateFailureIncCalls 

func (fake *KafkaMetrics) ConsumePartitionCreateFailureIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInc 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncArgsForCall 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncCallCount 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncCallCount() int

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncCalls 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitialize 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitialize(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeArgsForCall 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeCallCount 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeCallCount() int

func (*KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeCalls 

func (fake *KafkaMetrics) ConsumePartitionCreateOutOfRangeErrorInitializeCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) ConsumePartitionCreateSuccessInc 

func (fake *KafkaMetrics) ConsumePartitionCreateSuccessInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateSuccessIncArgsForCall 

func (fake *KafkaMetrics) ConsumePartitionCreateSuccessIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateSuccessIncCallCount 

func (fake *KafkaMetrics) ConsumePartitionCreateSuccessIncCallCount() int

func (*KafkaMetrics) ConsumePartitionCreateSuccessIncCalls 

func (fake *KafkaMetrics) ConsumePartitionCreateSuccessIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) ConsumePartitionCreateTotalInc 

func (fake *KafkaMetrics) ConsumePartitionCreateTotalInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateTotalIncArgsForCall 

func (fake *KafkaMetrics) ConsumePartitionCreateTotalIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ConsumePartitionCreateTotalIncCallCount 

func (fake *KafkaMetrics) ConsumePartitionCreateTotalIncCallCount() int

func (*KafkaMetrics) ConsumePartitionCreateTotalIncCalls 

func (fake *KafkaMetrics) ConsumePartitionCreateTotalIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) CurrentOffset 

func (fake *KafkaMetrics) CurrentOffset(arg1 kafka.Topic, arg2 kafka.Partition, arg3 kafka.Offset)

func (*KafkaMetrics) CurrentOffsetArgsForCall 

func (fake *KafkaMetrics) CurrentOffsetArgsForCall(i int) (kafka.Topic, kafka.Partition, kafka.Offset)

func (*KafkaMetrics) CurrentOffsetCallCount 

func (fake *KafkaMetrics) CurrentOffsetCallCount() int

func (*KafkaMetrics) CurrentOffsetCalls 

func (fake *KafkaMetrics) CurrentOffsetCalls(stub func(kafka.Topic, kafka.Partition, kafka.Offset))

func (*KafkaMetrics) ErrorCounterInc 

func (fake *KafkaMetrics) ErrorCounterInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) ErrorCounterIncArgsForCall 

func (fake *KafkaMetrics) ErrorCounterIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) ErrorCounterIncCallCount 

func (fake *KafkaMetrics) ErrorCounterIncCallCount() int

func (*KafkaMetrics) ErrorCounterIncCalls 

func (fake *KafkaMetrics) ErrorCounterIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) HighWaterMarkOffset 

func (fake *KafkaMetrics) HighWaterMarkOffset(arg1 kafka.Topic, arg2 kafka.Partition, arg3 kafka.Offset)

func (*KafkaMetrics) HighWaterMarkOffsetArgsForCall 

func (fake *KafkaMetrics) HighWaterMarkOffsetArgsForCall(i int) (kafka.Topic, kafka.Partition, kafka.Offset)

func (*KafkaMetrics) HighWaterMarkOffsetCallCount 

func (fake *KafkaMetrics) HighWaterMarkOffsetCallCount() int

func (*KafkaMetrics) HighWaterMarkOffsetCalls 

func (fake *KafkaMetrics) HighWaterMarkOffsetCalls(stub func(kafka.Topic, kafka.Partition, kafka.Offset))

func (*KafkaMetrics) Invocations 

func (fake *KafkaMetrics) Invocations() map[string][][]interface{}

func (*KafkaMetrics) MessageHandlerDurationMeasure 

func (fake *KafkaMetrics) MessageHandlerDurationMeasure(arg1 kafka.Topic, arg2 kafka.Partition, arg3 time.Duration)

func (*KafkaMetrics) MessageHandlerDurationMeasureArgsForCall 

func (fake *KafkaMetrics) MessageHandlerDurationMeasureArgsForCall(i int) (kafka.Topic, kafka.Partition, time.Duration)

func (*KafkaMetrics) MessageHandlerDurationMeasureCallCount 

func (fake *KafkaMetrics) MessageHandlerDurationMeasureCallCount() int

func (*KafkaMetrics) MessageHandlerDurationMeasureCalls 

func (fake *KafkaMetrics) MessageHandlerDurationMeasureCalls(stub func(kafka.Topic, kafka.Partition, time.Duration))

func (*KafkaMetrics) MessageHandlerFailureCounterInc 

func (fake *KafkaMetrics) MessageHandlerFailureCounterInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) MessageHandlerFailureCounterIncArgsForCall 

func (fake *KafkaMetrics) MessageHandlerFailureCounterIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) MessageHandlerFailureCounterIncCallCount 

func (fake *KafkaMetrics) MessageHandlerFailureCounterIncCallCount() int

func (*KafkaMetrics) MessageHandlerFailureCounterIncCalls 

func (fake *KafkaMetrics) MessageHandlerFailureCounterIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) MessageHandlerSuccessCounterInc 

func (fake *KafkaMetrics) MessageHandlerSuccessCounterInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) MessageHandlerSuccessCounterIncArgsForCall 

func (fake *KafkaMetrics) MessageHandlerSuccessCounterIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) MessageHandlerSuccessCounterIncCallCount 

func (fake *KafkaMetrics) MessageHandlerSuccessCounterIncCallCount() int

func (*KafkaMetrics) MessageHandlerSuccessCounterIncCalls 

func (fake *KafkaMetrics) MessageHandlerSuccessCounterIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) MessageHandlerTotalCounterInc 

func (fake *KafkaMetrics) MessageHandlerTotalCounterInc(arg1 kafka.Topic, arg2 kafka.Partition)

func (*KafkaMetrics) MessageHandlerTotalCounterIncArgsForCall 

func (fake *KafkaMetrics) MessageHandlerTotalCounterIncArgsForCall(i int) (kafka.Topic, kafka.Partition)

func (*KafkaMetrics) MessageHandlerTotalCounterIncCallCount 

func (fake *KafkaMetrics) MessageHandlerTotalCounterIncCallCount() int

func (*KafkaMetrics) MessageHandlerTotalCounterIncCalls 

func (fake *KafkaMetrics) MessageHandlerTotalCounterIncCalls(stub func(kafka.Topic, kafka.Partition))

func (*KafkaMetrics) SyncProducerDurationMeasure 

func (fake *KafkaMetrics) SyncProducerDurationMeasure(arg1 kafka.Topic, arg2 time.Duration)

func (*KafkaMetrics) SyncProducerDurationMeasureArgsForCall 

func (fake *KafkaMetrics) SyncProducerDurationMeasureArgsForCall(i int) (kafka.Topic, time.Duration)

func (*KafkaMetrics) SyncProducerDurationMeasureCallCount 

func (fake *KafkaMetrics) SyncProducerDurationMeasureCallCount() int

func (*KafkaMetrics) SyncProducerDurationMeasureCalls 

func (fake *KafkaMetrics) SyncProducerDurationMeasureCalls(stub func(kafka.Topic, time.Duration))

func (*KafkaMetrics) SyncProducerFailureCounterInc 

func (fake *KafkaMetrics) SyncProducerFailureCounterInc(arg1 kafka.Topic)

func (*KafkaMetrics) SyncProducerFailureCounterIncArgsForCall 

func (fake *KafkaMetrics) SyncProducerFailureCounterIncArgsForCall(i int) kafka.Topic

func (*KafkaMetrics) SyncProducerFailureCounterIncCallCount 

func (fake *KafkaMetrics) SyncProducerFailureCounterIncCallCount() int

func (*KafkaMetrics) SyncProducerFailureCounterIncCalls 

func (fake *KafkaMetrics) SyncProducerFailureCounterIncCalls(stub func(kafka.Topic))

func (*KafkaMetrics) SyncProducerSuccessCounterInc 

func (fake *KafkaMetrics) SyncProducerSuccessCounterInc(arg1 kafka.Topic)

func (*KafkaMetrics) SyncProducerSuccessCounterIncArgsForCall 

func (fake *KafkaMetrics) SyncProducerSuccessCounterIncArgsForCall(i int) kafka.Topic

func (*KafkaMetrics) SyncProducerSuccessCounterIncCallCount 

func (fake *KafkaMetrics) SyncProducerSuccessCounterIncCallCount() int

func (*KafkaMetrics) SyncProducerSuccessCounterIncCalls 

func (fake *KafkaMetrics) SyncProducerSuccessCounterIncCalls(stub func(kafka.Topic))

func (*KafkaMetrics) SyncProducerTotalCounterInc 

func (fake *KafkaMetrics) SyncProducerTotalCounterInc(arg1 kafka.Topic)

func (*KafkaMetrics) SyncProducerTotalCounterIncArgsForCall 

func (fake *KafkaMetrics) SyncProducerTotalCounterIncArgsForCall(i int) kafka.Topic

func (*KafkaMetrics) SyncProducerTotalCounterIncCallCount 

func (fake *KafkaMetrics) SyncProducerTotalCounterIncCallCount() int

func (*KafkaMetrics) SyncProducerTotalCounterIncCalls 

func (fake *KafkaMetrics) SyncProducerTotalCounterIncCalls(stub func(kafka.Topic))

type KafkaOffsetManager added in v1.21.0 

type KafkaOffsetManager struct {
	CloseStub func() error

	FallbackOffsetStub func() kafka.Offset

	InitialOffsetStub func() kafka.Offset

	MarkOffsetStub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error

	NextOffsetStub func(context.Context, kafka.Topic, kafka.Partition) (kafka.Offset, error)

	ResetOffsetStub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error
	// contains filtered or unexported fields
}

func (*KafkaOffsetManager) Close added in v1.21.0 

func (fake *KafkaOffsetManager) Close() error

func (*KafkaOffsetManager) CloseCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) CloseCallCount() int

func (*KafkaOffsetManager) CloseCalls added in v1.21.0 

func (fake *KafkaOffsetManager) CloseCalls(stub func() error)

func (*KafkaOffsetManager) CloseReturns added in v1.21.0 

func (fake *KafkaOffsetManager) CloseReturns(result1 error)

func (*KafkaOffsetManager) CloseReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) CloseReturnsOnCall(i int, result1 error)

func (*KafkaOffsetManager) FallbackOffset added in v1.21.0 

func (fake *KafkaOffsetManager) FallbackOffset() kafka.Offset

func (*KafkaOffsetManager) FallbackOffsetCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) FallbackOffsetCallCount() int

func (*KafkaOffsetManager) FallbackOffsetCalls added in v1.21.0 

func (fake *KafkaOffsetManager) FallbackOffsetCalls(stub func() kafka.Offset)

func (*KafkaOffsetManager) FallbackOffsetReturns added in v1.21.0 

func (fake *KafkaOffsetManager) FallbackOffsetReturns(result1 kafka.Offset)

func (*KafkaOffsetManager) FallbackOffsetReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) FallbackOffsetReturnsOnCall(i int, result1 kafka.Offset)

func (*KafkaOffsetManager) InitialOffset added in v1.21.0 

func (fake *KafkaOffsetManager) InitialOffset() kafka.Offset

func (*KafkaOffsetManager) InitialOffsetCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) InitialOffsetCallCount() int

func (*KafkaOffsetManager) InitialOffsetCalls added in v1.21.0 

func (fake *KafkaOffsetManager) InitialOffsetCalls(stub func() kafka.Offset)

func (*KafkaOffsetManager) InitialOffsetReturns added in v1.21.0 

func (fake *KafkaOffsetManager) InitialOffsetReturns(result1 kafka.Offset)

func (*KafkaOffsetManager) InitialOffsetReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) InitialOffsetReturnsOnCall(i int, result1 kafka.Offset)

func (*KafkaOffsetManager) Invocations added in v1.21.0 

func (fake *KafkaOffsetManager) Invocations() map[string][][]interface{}

func (*KafkaOffsetManager) MarkOffset added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffset(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition, arg4 kafka.Offset) error

func (*KafkaOffsetManager) MarkOffsetArgsForCall added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffsetArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition, kafka.Offset)

func (*KafkaOffsetManager) MarkOffsetCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffsetCallCount() int

func (*KafkaOffsetManager) MarkOffsetCalls added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffsetCalls(stub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error)

func (*KafkaOffsetManager) MarkOffsetReturns added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffsetReturns(result1 error)

func (*KafkaOffsetManager) MarkOffsetReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) MarkOffsetReturnsOnCall(i int, result1 error)

func (*KafkaOffsetManager) NextOffset added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffset(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition) (kafka.Offset, error)

func (*KafkaOffsetManager) NextOffsetArgsForCall added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffsetArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition)

func (*KafkaOffsetManager) NextOffsetCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffsetCallCount() int

func (*KafkaOffsetManager) NextOffsetCalls added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffsetCalls(stub func(context.Context, kafka.Topic, kafka.Partition) (kafka.Offset, error))

func (*KafkaOffsetManager) NextOffsetReturns added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffsetReturns(result1 kafka.Offset, result2 error)

func (*KafkaOffsetManager) NextOffsetReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) NextOffsetReturnsOnCall(i int, result1 kafka.Offset, result2 error)

func (*KafkaOffsetManager) ResetOffset added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffset(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition, arg4 kafka.Offset) error

func (*KafkaOffsetManager) ResetOffsetArgsForCall added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffsetArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition, kafka.Offset)

func (*KafkaOffsetManager) ResetOffsetCallCount added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffsetCallCount() int

func (*KafkaOffsetManager) ResetOffsetCalls added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffsetCalls(stub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error)

func (*KafkaOffsetManager) ResetOffsetReturns added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffsetReturns(result1 error)

func (*KafkaOffsetManager) ResetOffsetReturnsOnCall added in v1.21.0 

func (fake *KafkaOffsetManager) ResetOffsetReturnsOnCall(i int, result1 error)

type KafkaOffsetStore 

type KafkaOffsetStore struct {
	GetStub func(context.Context, kafka.Topic, kafka.Partition) (kafka.Offset, error)

	SetStub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error
	// contains filtered or unexported fields
}

func (*KafkaOffsetStore) Get 

func (fake *KafkaOffsetStore) Get(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition) (kafka.Offset, error)

func (*KafkaOffsetStore) GetArgsForCall 

func (fake *KafkaOffsetStore) GetArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition)

func (*KafkaOffsetStore) GetCallCount 

func (fake *KafkaOffsetStore) GetCallCount() int

func (*KafkaOffsetStore) GetCalls 

func (fake *KafkaOffsetStore) GetCalls(stub func(context.Context, kafka.Topic, kafka.Partition) (kafka.Offset, error))

func (*KafkaOffsetStore) GetReturns 

func (fake *KafkaOffsetStore) GetReturns(result1 kafka.Offset, result2 error)

func (*KafkaOffsetStore) GetReturnsOnCall 

func (fake *KafkaOffsetStore) GetReturnsOnCall(i int, result1 kafka.Offset, result2 error)

func (*KafkaOffsetStore) Invocations 

func (fake *KafkaOffsetStore) Invocations() map[string][][]interface{}

func (*KafkaOffsetStore) Set 

func (fake *KafkaOffsetStore) Set(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition, arg4 kafka.Offset) error

func (*KafkaOffsetStore) SetArgsForCall 

func (fake *KafkaOffsetStore) SetArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition, kafka.Offset)

func (*KafkaOffsetStore) SetCallCount 

func (fake *KafkaOffsetStore) SetCallCount() int

func (*KafkaOffsetStore) SetCalls 

func (fake *KafkaOffsetStore) SetCalls(stub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset) error)

func (*KafkaOffsetStore) SetReturns 

func (fake *KafkaOffsetStore) SetReturns(result1 error)

func (*KafkaOffsetStore) SetReturnsOnCall 

func (fake *KafkaOffsetStore) SetReturnsOnCall(i int, result1 error)

type KafkaSaramaClient 

type KafkaSaramaClient struct {
	BrokerStub func(int32) (*sarama.Broker, error)

	BrokersStub func() []*sarama.Broker

	CloseStub func() error

	ClosedStub func() bool

	ConfigStub func() *sarama.Config

	ControllerStub func() (*sarama.Broker, error)

	CoordinatorStub func(string) (*sarama.Broker, error)

	GetOffsetStub func(string, int32, int64) (int64, error)

	InSyncReplicasStub func(string, int32) ([]int32, error)

	InitProducerIDStub func() (*sarama.InitProducerIDResponse, error)

	LeaderStub func(string, int32) (*sarama.Broker, error)

	LeaderAndEpochStub func(string, int32) (*sarama.Broker, int32, error)

	LeastLoadedBrokerStub func() *sarama.Broker

	OfflineReplicasStub func(string, int32) ([]int32, error)

	PartitionNotReadableStub func(string, int32) bool

	PartitionsStub func(string) ([]int32, error)

	RefreshBrokersStub func([]string) error

	RefreshControllerStub func() (*sarama.Broker, error)

	RefreshCoordinatorStub func(string) error

	RefreshMetadataStub func(...string) error

	RefreshTransactionCoordinatorStub func(string) error

	ReplicasStub func(string, int32) ([]int32, error)

	TopicsStub func() ([]string, error)

	TransactionCoordinatorStub func(string) (*sarama.Broker, error)

	WritablePartitionsStub func(string) ([]int32, error)
	// contains filtered or unexported fields
}

func (*KafkaSaramaClient) Broker 

func (fake *KafkaSaramaClient) Broker(arg1 int32) (*sarama.Broker, error)

func (*KafkaSaramaClient) BrokerArgsForCall 

func (fake *KafkaSaramaClient) BrokerArgsForCall(i int) int32

func (*KafkaSaramaClient) BrokerCallCount 

func (fake *KafkaSaramaClient) BrokerCallCount() int

func (*KafkaSaramaClient) BrokerCalls 

func (fake *KafkaSaramaClient) BrokerCalls(stub func(int32) (*sarama.Broker, error))

func (*KafkaSaramaClient) BrokerReturns 

func (fake *KafkaSaramaClient) BrokerReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) BrokerReturnsOnCall 

func (fake *KafkaSaramaClient) BrokerReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) Brokers 

func (fake *KafkaSaramaClient) Brokers() []*sarama.Broker

func (*KafkaSaramaClient) BrokersCallCount 

func (fake *KafkaSaramaClient) BrokersCallCount() int

func (*KafkaSaramaClient) BrokersCalls 

func (fake *KafkaSaramaClient) BrokersCalls(stub func() []*sarama.Broker)

func (*KafkaSaramaClient) BrokersReturns 

func (fake *KafkaSaramaClient) BrokersReturns(result1 []*sarama.Broker)

func (*KafkaSaramaClient) BrokersReturnsOnCall 

func (fake *KafkaSaramaClient) BrokersReturnsOnCall(i int, result1 []*sarama.Broker)

func (*KafkaSaramaClient) Close 

func (fake *KafkaSaramaClient) Close() error

func (*KafkaSaramaClient) CloseCallCount 

func (fake *KafkaSaramaClient) CloseCallCount() int

func (*KafkaSaramaClient) CloseCalls 

func (fake *KafkaSaramaClient) CloseCalls(stub func() error)

func (*KafkaSaramaClient) CloseReturns 

func (fake *KafkaSaramaClient) CloseReturns(result1 error)

func (*KafkaSaramaClient) CloseReturnsOnCall 

func (fake *KafkaSaramaClient) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClient) Closed 

func (fake *KafkaSaramaClient) Closed() bool

func (*KafkaSaramaClient) ClosedCallCount 

func (fake *KafkaSaramaClient) ClosedCallCount() int

func (*KafkaSaramaClient) ClosedCalls 

func (fake *KafkaSaramaClient) ClosedCalls(stub func() bool)

func (*KafkaSaramaClient) ClosedReturns 

func (fake *KafkaSaramaClient) ClosedReturns(result1 bool)

func (*KafkaSaramaClient) ClosedReturnsOnCall 

func (fake *KafkaSaramaClient) ClosedReturnsOnCall(i int, result1 bool)

func (*KafkaSaramaClient) Config 

func (fake *KafkaSaramaClient) Config() *sarama.Config

func (*KafkaSaramaClient) ConfigCallCount 

func (fake *KafkaSaramaClient) ConfigCallCount() int

func (*KafkaSaramaClient) ConfigCalls 

func (fake *KafkaSaramaClient) ConfigCalls(stub func() *sarama.Config)

func (*KafkaSaramaClient) ConfigReturns 

func (fake *KafkaSaramaClient) ConfigReturns(result1 *sarama.Config)

func (*KafkaSaramaClient) ConfigReturnsOnCall 

func (fake *KafkaSaramaClient) ConfigReturnsOnCall(i int, result1 *sarama.Config)

func (*KafkaSaramaClient) Controller 

func (fake *KafkaSaramaClient) Controller() (*sarama.Broker, error)

func (*KafkaSaramaClient) ControllerCallCount 

func (fake *KafkaSaramaClient) ControllerCallCount() int

func (*KafkaSaramaClient) ControllerCalls 

func (fake *KafkaSaramaClient) ControllerCalls(stub func() (*sarama.Broker, error))

func (*KafkaSaramaClient) ControllerReturns 

func (fake *KafkaSaramaClient) ControllerReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) ControllerReturnsOnCall 

func (fake *KafkaSaramaClient) ControllerReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) Coordinator 

func (fake *KafkaSaramaClient) Coordinator(arg1 string) (*sarama.Broker, error)

func (*KafkaSaramaClient) CoordinatorArgsForCall 

func (fake *KafkaSaramaClient) CoordinatorArgsForCall(i int) string

func (*KafkaSaramaClient) CoordinatorCallCount 

func (fake *KafkaSaramaClient) CoordinatorCallCount() int

func (*KafkaSaramaClient) CoordinatorCalls 

func (fake *KafkaSaramaClient) CoordinatorCalls(stub func(string) (*sarama.Broker, error))

func (*KafkaSaramaClient) CoordinatorReturns 

func (fake *KafkaSaramaClient) CoordinatorReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) CoordinatorReturnsOnCall 

func (fake *KafkaSaramaClient) CoordinatorReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) GetOffset 

func (fake *KafkaSaramaClient) GetOffset(arg1 string, arg2 int32, arg3 int64) (int64, error)

func (*KafkaSaramaClient) GetOffsetArgsForCall 

func (fake *KafkaSaramaClient) GetOffsetArgsForCall(i int) (string, int32, int64)

func (*KafkaSaramaClient) GetOffsetCallCount 

func (fake *KafkaSaramaClient) GetOffsetCallCount() int

func (*KafkaSaramaClient) GetOffsetCalls 

func (fake *KafkaSaramaClient) GetOffsetCalls(stub func(string, int32, int64) (int64, error))

func (*KafkaSaramaClient) GetOffsetReturns 

func (fake *KafkaSaramaClient) GetOffsetReturns(result1 int64, result2 error)

func (*KafkaSaramaClient) GetOffsetReturnsOnCall 

func (fake *KafkaSaramaClient) GetOffsetReturnsOnCall(i int, result1 int64, result2 error)

func (*KafkaSaramaClient) InSyncReplicas 

func (fake *KafkaSaramaClient) InSyncReplicas(arg1 string, arg2 int32) ([]int32, error)

func (*KafkaSaramaClient) InSyncReplicasArgsForCall 

func (fake *KafkaSaramaClient) InSyncReplicasArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) InSyncReplicasCallCount 

func (fake *KafkaSaramaClient) InSyncReplicasCallCount() int

func (*KafkaSaramaClient) InSyncReplicasCalls 

func (fake *KafkaSaramaClient) InSyncReplicasCalls(stub func(string, int32) ([]int32, error))

func (*KafkaSaramaClient) InSyncReplicasReturns 

func (fake *KafkaSaramaClient) InSyncReplicasReturns(result1 []int32, result2 error)

func (*KafkaSaramaClient) InSyncReplicasReturnsOnCall 

func (fake *KafkaSaramaClient) InSyncReplicasReturnsOnCall(i int, result1 []int32, result2 error)

func (*KafkaSaramaClient) InitProducerID 

func (fake *KafkaSaramaClient) InitProducerID() (*sarama.InitProducerIDResponse, error)

func (*KafkaSaramaClient) InitProducerIDCallCount 

func (fake *KafkaSaramaClient) InitProducerIDCallCount() int

func (*KafkaSaramaClient) InitProducerIDCalls 

func (fake *KafkaSaramaClient) InitProducerIDCalls(stub func() (*sarama.InitProducerIDResponse, error))

func (*KafkaSaramaClient) InitProducerIDReturns 

func (fake *KafkaSaramaClient) InitProducerIDReturns(result1 *sarama.InitProducerIDResponse, result2 error)

func (*KafkaSaramaClient) InitProducerIDReturnsOnCall 

func (fake *KafkaSaramaClient) InitProducerIDReturnsOnCall(i int, result1 *sarama.InitProducerIDResponse, result2 error)

func (*KafkaSaramaClient) Invocations 

func (fake *KafkaSaramaClient) Invocations() map[string][][]interface{}

func (*KafkaSaramaClient) Leader 

func (fake *KafkaSaramaClient) Leader(arg1 string, arg2 int32) (*sarama.Broker, error)

func (*KafkaSaramaClient) LeaderAndEpoch 

func (fake *KafkaSaramaClient) LeaderAndEpoch(arg1 string, arg2 int32) (*sarama.Broker, int32, error)

func (*KafkaSaramaClient) LeaderAndEpochArgsForCall 

func (fake *KafkaSaramaClient) LeaderAndEpochArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) LeaderAndEpochCallCount 

func (fake *KafkaSaramaClient) LeaderAndEpochCallCount() int

func (*KafkaSaramaClient) LeaderAndEpochCalls 

func (fake *KafkaSaramaClient) LeaderAndEpochCalls(stub func(string, int32) (*sarama.Broker, int32, error))

func (*KafkaSaramaClient) LeaderAndEpochReturns 

func (fake *KafkaSaramaClient) LeaderAndEpochReturns(result1 *sarama.Broker, result2 int32, result3 error)

func (*KafkaSaramaClient) LeaderAndEpochReturnsOnCall 

func (fake *KafkaSaramaClient) LeaderAndEpochReturnsOnCall(i int, result1 *sarama.Broker, result2 int32, result3 error)

func (*KafkaSaramaClient) LeaderArgsForCall 

func (fake *KafkaSaramaClient) LeaderArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) LeaderCallCount 

func (fake *KafkaSaramaClient) LeaderCallCount() int

func (*KafkaSaramaClient) LeaderCalls 

func (fake *KafkaSaramaClient) LeaderCalls(stub func(string, int32) (*sarama.Broker, error))

func (*KafkaSaramaClient) LeaderReturns 

func (fake *KafkaSaramaClient) LeaderReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) LeaderReturnsOnCall 

func (fake *KafkaSaramaClient) LeaderReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) LeastLoadedBroker 

func (fake *KafkaSaramaClient) LeastLoadedBroker() *sarama.Broker

func (*KafkaSaramaClient) LeastLoadedBrokerCallCount 

func (fake *KafkaSaramaClient) LeastLoadedBrokerCallCount() int

func (*KafkaSaramaClient) LeastLoadedBrokerCalls 

func (fake *KafkaSaramaClient) LeastLoadedBrokerCalls(stub func() *sarama.Broker)

func (*KafkaSaramaClient) LeastLoadedBrokerReturns 

func (fake *KafkaSaramaClient) LeastLoadedBrokerReturns(result1 *sarama.Broker)

func (*KafkaSaramaClient) LeastLoadedBrokerReturnsOnCall 

func (fake *KafkaSaramaClient) LeastLoadedBrokerReturnsOnCall(i int, result1 *sarama.Broker)

func (*KafkaSaramaClient) OfflineReplicas 

func (fake *KafkaSaramaClient) OfflineReplicas(arg1 string, arg2 int32) ([]int32, error)

func (*KafkaSaramaClient) OfflineReplicasArgsForCall 

func (fake *KafkaSaramaClient) OfflineReplicasArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) OfflineReplicasCallCount 

func (fake *KafkaSaramaClient) OfflineReplicasCallCount() int

func (*KafkaSaramaClient) OfflineReplicasCalls 

func (fake *KafkaSaramaClient) OfflineReplicasCalls(stub func(string, int32) ([]int32, error))

func (*KafkaSaramaClient) OfflineReplicasReturns 

func (fake *KafkaSaramaClient) OfflineReplicasReturns(result1 []int32, result2 error)

func (*KafkaSaramaClient) OfflineReplicasReturnsOnCall 

func (fake *KafkaSaramaClient) OfflineReplicasReturnsOnCall(i int, result1 []int32, result2 error)

func (*KafkaSaramaClient) PartitionNotReadable 

func (fake *KafkaSaramaClient) PartitionNotReadable(arg1 string, arg2 int32) bool

func (*KafkaSaramaClient) PartitionNotReadableArgsForCall 

func (fake *KafkaSaramaClient) PartitionNotReadableArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) PartitionNotReadableCallCount 

func (fake *KafkaSaramaClient) PartitionNotReadableCallCount() int

func (*KafkaSaramaClient) PartitionNotReadableCalls 

func (fake *KafkaSaramaClient) PartitionNotReadableCalls(stub func(string, int32) bool)

func (*KafkaSaramaClient) PartitionNotReadableReturns 

func (fake *KafkaSaramaClient) PartitionNotReadableReturns(result1 bool)

func (*KafkaSaramaClient) PartitionNotReadableReturnsOnCall 

func (fake *KafkaSaramaClient) PartitionNotReadableReturnsOnCall(i int, result1 bool)

func (*KafkaSaramaClient) Partitions 

func (fake *KafkaSaramaClient) Partitions(arg1 string) ([]int32, error)

func (*KafkaSaramaClient) PartitionsArgsForCall 

func (fake *KafkaSaramaClient) PartitionsArgsForCall(i int) string

func (*KafkaSaramaClient) PartitionsCallCount 

func (fake *KafkaSaramaClient) PartitionsCallCount() int

func (*KafkaSaramaClient) PartitionsCalls 

func (fake *KafkaSaramaClient) PartitionsCalls(stub func(string) ([]int32, error))

func (*KafkaSaramaClient) PartitionsReturns 

func (fake *KafkaSaramaClient) PartitionsReturns(result1 []int32, result2 error)

func (*KafkaSaramaClient) PartitionsReturnsOnCall 

func (fake *KafkaSaramaClient) PartitionsReturnsOnCall(i int, result1 []int32, result2 error)

func (*KafkaSaramaClient) RefreshBrokers 

func (fake *KafkaSaramaClient) RefreshBrokers(arg1 []string) error

func (*KafkaSaramaClient) RefreshBrokersArgsForCall 

func (fake *KafkaSaramaClient) RefreshBrokersArgsForCall(i int) []string

func (*KafkaSaramaClient) RefreshBrokersCallCount 

func (fake *KafkaSaramaClient) RefreshBrokersCallCount() int

func (*KafkaSaramaClient) RefreshBrokersCalls 

func (fake *KafkaSaramaClient) RefreshBrokersCalls(stub func([]string) error)

func (*KafkaSaramaClient) RefreshBrokersReturns 

func (fake *KafkaSaramaClient) RefreshBrokersReturns(result1 error)

func (*KafkaSaramaClient) RefreshBrokersReturnsOnCall 

func (fake *KafkaSaramaClient) RefreshBrokersReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClient) RefreshController 

func (fake *KafkaSaramaClient) RefreshController() (*sarama.Broker, error)

func (*KafkaSaramaClient) RefreshControllerCallCount 

func (fake *KafkaSaramaClient) RefreshControllerCallCount() int

func (*KafkaSaramaClient) RefreshControllerCalls 

func (fake *KafkaSaramaClient) RefreshControllerCalls(stub func() (*sarama.Broker, error))

func (*KafkaSaramaClient) RefreshControllerReturns 

func (fake *KafkaSaramaClient) RefreshControllerReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) RefreshControllerReturnsOnCall 

func (fake *KafkaSaramaClient) RefreshControllerReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) RefreshCoordinator 

func (fake *KafkaSaramaClient) RefreshCoordinator(arg1 string) error

func (*KafkaSaramaClient) RefreshCoordinatorArgsForCall 

func (fake *KafkaSaramaClient) RefreshCoordinatorArgsForCall(i int) string

func (*KafkaSaramaClient) RefreshCoordinatorCallCount 

func (fake *KafkaSaramaClient) RefreshCoordinatorCallCount() int

func (*KafkaSaramaClient) RefreshCoordinatorCalls 

func (fake *KafkaSaramaClient) RefreshCoordinatorCalls(stub func(string) error)

func (*KafkaSaramaClient) RefreshCoordinatorReturns 

func (fake *KafkaSaramaClient) RefreshCoordinatorReturns(result1 error)

func (*KafkaSaramaClient) RefreshCoordinatorReturnsOnCall 

func (fake *KafkaSaramaClient) RefreshCoordinatorReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClient) RefreshMetadata 

func (fake *KafkaSaramaClient) RefreshMetadata(arg1 ...string) error

func (*KafkaSaramaClient) RefreshMetadataArgsForCall 

func (fake *KafkaSaramaClient) RefreshMetadataArgsForCall(i int) []string

func (*KafkaSaramaClient) RefreshMetadataCallCount 

func (fake *KafkaSaramaClient) RefreshMetadataCallCount() int

func (*KafkaSaramaClient) RefreshMetadataCalls 

func (fake *KafkaSaramaClient) RefreshMetadataCalls(stub func(...string) error)

func (*KafkaSaramaClient) RefreshMetadataReturns 

func (fake *KafkaSaramaClient) RefreshMetadataReturns(result1 error)

func (*KafkaSaramaClient) RefreshMetadataReturnsOnCall 

func (fake *KafkaSaramaClient) RefreshMetadataReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClient) RefreshTransactionCoordinator 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinator(arg1 string) error

func (*KafkaSaramaClient) RefreshTransactionCoordinatorArgsForCall 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinatorArgsForCall(i int) string

func (*KafkaSaramaClient) RefreshTransactionCoordinatorCallCount 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinatorCallCount() int

func (*KafkaSaramaClient) RefreshTransactionCoordinatorCalls 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinatorCalls(stub func(string) error)

func (*KafkaSaramaClient) RefreshTransactionCoordinatorReturns 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinatorReturns(result1 error)

func (*KafkaSaramaClient) RefreshTransactionCoordinatorReturnsOnCall 

func (fake *KafkaSaramaClient) RefreshTransactionCoordinatorReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClient) Replicas 

func (fake *KafkaSaramaClient) Replicas(arg1 string, arg2 int32) ([]int32, error)

func (*KafkaSaramaClient) ReplicasArgsForCall 

func (fake *KafkaSaramaClient) ReplicasArgsForCall(i int) (string, int32)

func (*KafkaSaramaClient) ReplicasCallCount 

func (fake *KafkaSaramaClient) ReplicasCallCount() int

func (*KafkaSaramaClient) ReplicasCalls 

func (fake *KafkaSaramaClient) ReplicasCalls(stub func(string, int32) ([]int32, error))

func (*KafkaSaramaClient) ReplicasReturns 

func (fake *KafkaSaramaClient) ReplicasReturns(result1 []int32, result2 error)

func (*KafkaSaramaClient) ReplicasReturnsOnCall 

func (fake *KafkaSaramaClient) ReplicasReturnsOnCall(i int, result1 []int32, result2 error)

func (*KafkaSaramaClient) Topics 

func (fake *KafkaSaramaClient) Topics() ([]string, error)

func (*KafkaSaramaClient) TopicsCallCount 

func (fake *KafkaSaramaClient) TopicsCallCount() int

func (*KafkaSaramaClient) TopicsCalls 

func (fake *KafkaSaramaClient) TopicsCalls(stub func() ([]string, error))

func (*KafkaSaramaClient) TopicsReturns 

func (fake *KafkaSaramaClient) TopicsReturns(result1 []string, result2 error)

func (*KafkaSaramaClient) TopicsReturnsOnCall 

func (fake *KafkaSaramaClient) TopicsReturnsOnCall(i int, result1 []string, result2 error)

func (*KafkaSaramaClient) TransactionCoordinator 

func (fake *KafkaSaramaClient) TransactionCoordinator(arg1 string) (*sarama.Broker, error)

func (*KafkaSaramaClient) TransactionCoordinatorArgsForCall 

func (fake *KafkaSaramaClient) TransactionCoordinatorArgsForCall(i int) string

func (*KafkaSaramaClient) TransactionCoordinatorCallCount 

func (fake *KafkaSaramaClient) TransactionCoordinatorCallCount() int

func (*KafkaSaramaClient) TransactionCoordinatorCalls 

func (fake *KafkaSaramaClient) TransactionCoordinatorCalls(stub func(string) (*sarama.Broker, error))

func (*KafkaSaramaClient) TransactionCoordinatorReturns 

func (fake *KafkaSaramaClient) TransactionCoordinatorReturns(result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) TransactionCoordinatorReturnsOnCall 

func (fake *KafkaSaramaClient) TransactionCoordinatorReturnsOnCall(i int, result1 *sarama.Broker, result2 error)

func (*KafkaSaramaClient) WritablePartitions 

func (fake *KafkaSaramaClient) WritablePartitions(arg1 string) ([]int32, error)

func (*KafkaSaramaClient) WritablePartitionsArgsForCall 

func (fake *KafkaSaramaClient) WritablePartitionsArgsForCall(i int) string

func (*KafkaSaramaClient) WritablePartitionsCallCount 

func (fake *KafkaSaramaClient) WritablePartitionsCallCount() int

func (*KafkaSaramaClient) WritablePartitionsCalls 

func (fake *KafkaSaramaClient) WritablePartitionsCalls(stub func(string) ([]int32, error))

func (*KafkaSaramaClient) WritablePartitionsReturns 

func (fake *KafkaSaramaClient) WritablePartitionsReturns(result1 []int32, result2 error)

func (*KafkaSaramaClient) WritablePartitionsReturnsOnCall 

func (fake *KafkaSaramaClient) WritablePartitionsReturnsOnCall(i int, result1 []int32, result2 error)

type KafkaSaramaClientPool added in v1.22.0 

type KafkaSaramaClientPool struct {
	AcquireStub func(context.Context) (kafka.SaramaClient, error)

	CloseStub func() error

	ReleaseStub func(kafka.SaramaClient, bool)
	// contains filtered or unexported fields
}

func (*KafkaSaramaClientPool) Acquire added in v1.22.0 

func (fake *KafkaSaramaClientPool) Acquire(arg1 context.Context) (kafka.SaramaClient, error)

func (*KafkaSaramaClientPool) AcquireArgsForCall added in v1.22.0 

func (fake *KafkaSaramaClientPool) AcquireArgsForCall(i int) context.Context

func (*KafkaSaramaClientPool) AcquireCallCount added in v1.22.0 

func (fake *KafkaSaramaClientPool) AcquireCallCount() int

func (*KafkaSaramaClientPool) AcquireCalls added in v1.22.0 

func (fake *KafkaSaramaClientPool) AcquireCalls(stub func(context.Context) (kafka.SaramaClient, error))

func (*KafkaSaramaClientPool) AcquireReturns added in v1.22.0 

func (fake *KafkaSaramaClientPool) AcquireReturns(result1 kafka.SaramaClient, result2 error)

func (*KafkaSaramaClientPool) AcquireReturnsOnCall added in v1.22.0 

func (fake *KafkaSaramaClientPool) AcquireReturnsOnCall(i int, result1 kafka.SaramaClient, result2 error)

func (*KafkaSaramaClientPool) Close added in v1.22.0 

func (fake *KafkaSaramaClientPool) Close() error

func (*KafkaSaramaClientPool) CloseCallCount added in v1.22.0 

func (fake *KafkaSaramaClientPool) CloseCallCount() int

func (*KafkaSaramaClientPool) CloseCalls added in v1.22.0 

func (fake *KafkaSaramaClientPool) CloseCalls(stub func() error)

func (*KafkaSaramaClientPool) CloseReturns added in v1.22.0 

func (fake *KafkaSaramaClientPool) CloseReturns(result1 error)

func (*KafkaSaramaClientPool) CloseReturnsOnCall added in v1.22.0 

func (fake *KafkaSaramaClientPool) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClientPool) Invocations added in v1.22.0 

func (fake *KafkaSaramaClientPool) Invocations() map[string][][]interface{}

func (*KafkaSaramaClientPool) Release added in v1.22.0 

func (fake *KafkaSaramaClientPool) Release(arg1 kafka.SaramaClient, arg2 bool)

func (*KafkaSaramaClientPool) ReleaseArgsForCall added in v1.22.0 

func (fake *KafkaSaramaClientPool) ReleaseArgsForCall(i int) (kafka.SaramaClient, bool)

func (*KafkaSaramaClientPool) ReleaseCallCount added in v1.22.0 

func (fake *KafkaSaramaClientPool) ReleaseCallCount() int

func (*KafkaSaramaClientPool) ReleaseCalls added in v1.22.0 

func (fake *KafkaSaramaClientPool) ReleaseCalls(stub func(kafka.SaramaClient, bool))

type KafkaSaramaClientProvider added in v1.18.0 

type KafkaSaramaClientProvider struct {
	ClientStub func(context.Context) (kafka.SaramaClient, error)

	CloseStub func() error
	// contains filtered or unexported fields
}

func (*KafkaSaramaClientProvider) Client added in v1.18.0 

func (fake *KafkaSaramaClientProvider) Client(arg1 context.Context) (kafka.SaramaClient, error)

func (*KafkaSaramaClientProvider) ClientArgsForCall added in v1.18.0 

func (fake *KafkaSaramaClientProvider) ClientArgsForCall(i int) context.Context

func (*KafkaSaramaClientProvider) ClientCallCount added in v1.18.0 

func (fake *KafkaSaramaClientProvider) ClientCallCount() int

func (*KafkaSaramaClientProvider) ClientCalls added in v1.18.0 

func (fake *KafkaSaramaClientProvider) ClientCalls(stub func(context.Context) (kafka.SaramaClient, error))

func (*KafkaSaramaClientProvider) ClientReturns added in v1.18.0 

func (fake *KafkaSaramaClientProvider) ClientReturns(result1 kafka.SaramaClient, result2 error)

func (*KafkaSaramaClientProvider) ClientReturnsOnCall added in v1.18.0 

func (fake *KafkaSaramaClientProvider) ClientReturnsOnCall(i int, result1 kafka.SaramaClient, result2 error)

func (*KafkaSaramaClientProvider) Close added in v1.18.0 

func (fake *KafkaSaramaClientProvider) Close() error

func (*KafkaSaramaClientProvider) CloseCallCount added in v1.18.0 

func (fake *KafkaSaramaClientProvider) CloseCallCount() int

func (*KafkaSaramaClientProvider) CloseCalls added in v1.18.0 

func (fake *KafkaSaramaClientProvider) CloseCalls(stub func() error)

func (*KafkaSaramaClientProvider) CloseReturns added in v1.18.0 

func (fake *KafkaSaramaClientProvider) CloseReturns(result1 error)

func (*KafkaSaramaClientProvider) CloseReturnsOnCall added in v1.18.0 

func (fake *KafkaSaramaClientProvider) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaClientProvider) Invocations added in v1.18.0 

func (fake *KafkaSaramaClientProvider) Invocations() map[string][][]interface{}

type KafkaSaramaConsumer 

type KafkaSaramaConsumer struct {
	CloseStub func() error

	ConsumePartitionStub func(string, int32, int64) (sarama.PartitionConsumer, error)

	HighWaterMarksStub func() map[string]map[int32]int64

	PartitionsStub func(string) ([]int32, error)

	PauseStub func(map[string][]int32)

	PauseAllStub func()

	ResumeStub func(map[string][]int32)

	ResumeAllStub func()

	TopicsStub func() ([]string, error)
	// contains filtered or unexported fields
}

func (*KafkaSaramaConsumer) Close 

func (fake *KafkaSaramaConsumer) Close() error

func (*KafkaSaramaConsumer) CloseCallCount 

func (fake *KafkaSaramaConsumer) CloseCallCount() int

func (*KafkaSaramaConsumer) CloseCalls 

func (fake *KafkaSaramaConsumer) CloseCalls(stub func() error)

func (*KafkaSaramaConsumer) CloseReturns 

func (fake *KafkaSaramaConsumer) CloseReturns(result1 error)

func (*KafkaSaramaConsumer) CloseReturnsOnCall 

func (fake *KafkaSaramaConsumer) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaConsumer) ConsumePartition 

func (fake *KafkaSaramaConsumer) ConsumePartition(arg1 string, arg2 int32, arg3 int64) (sarama.PartitionConsumer, error)

func (*KafkaSaramaConsumer) ConsumePartitionArgsForCall 

func (fake *KafkaSaramaConsumer) ConsumePartitionArgsForCall(i int) (string, int32, int64)

func (*KafkaSaramaConsumer) ConsumePartitionCallCount 

func (fake *KafkaSaramaConsumer) ConsumePartitionCallCount() int

func (*KafkaSaramaConsumer) ConsumePartitionCalls 

func (fake *KafkaSaramaConsumer) ConsumePartitionCalls(stub func(string, int32, int64) (sarama.PartitionConsumer, error))

func (*KafkaSaramaConsumer) ConsumePartitionReturns 

func (fake *KafkaSaramaConsumer) ConsumePartitionReturns(result1 sarama.PartitionConsumer, result2 error)

func (*KafkaSaramaConsumer) ConsumePartitionReturnsOnCall 

func (fake *KafkaSaramaConsumer) ConsumePartitionReturnsOnCall(i int, result1 sarama.PartitionConsumer, result2 error)

func (*KafkaSaramaConsumer) HighWaterMarks 

func (fake *KafkaSaramaConsumer) HighWaterMarks() map[string]map[int32]int64

func (*KafkaSaramaConsumer) HighWaterMarksCallCount 

func (fake *KafkaSaramaConsumer) HighWaterMarksCallCount() int

func (*KafkaSaramaConsumer) HighWaterMarksCalls 

func (fake *KafkaSaramaConsumer) HighWaterMarksCalls(stub func() map[string]map[int32]int64)

func (*KafkaSaramaConsumer) HighWaterMarksReturns 

func (fake *KafkaSaramaConsumer) HighWaterMarksReturns(result1 map[string]map[int32]int64)

func (*KafkaSaramaConsumer) HighWaterMarksReturnsOnCall 

func (fake *KafkaSaramaConsumer) HighWaterMarksReturnsOnCall(i int, result1 map[string]map[int32]int64)

func (*KafkaSaramaConsumer) Invocations 

func (fake *KafkaSaramaConsumer) Invocations() map[string][][]interface{}

func (*KafkaSaramaConsumer) Partitions 

func (fake *KafkaSaramaConsumer) Partitions(arg1 string) ([]int32, error)

func (*KafkaSaramaConsumer) PartitionsArgsForCall 

func (fake *KafkaSaramaConsumer) PartitionsArgsForCall(i int) string

func (*KafkaSaramaConsumer) PartitionsCallCount 

func (fake *KafkaSaramaConsumer) PartitionsCallCount() int

func (*KafkaSaramaConsumer) PartitionsCalls 

func (fake *KafkaSaramaConsumer) PartitionsCalls(stub func(string) ([]int32, error))

func (*KafkaSaramaConsumer) PartitionsReturns 

func (fake *KafkaSaramaConsumer) PartitionsReturns(result1 []int32, result2 error)

func (*KafkaSaramaConsumer) PartitionsReturnsOnCall 

func (fake *KafkaSaramaConsumer) PartitionsReturnsOnCall(i int, result1 []int32, result2 error)

func (*KafkaSaramaConsumer) Pause 

func (fake *KafkaSaramaConsumer) Pause(arg1 map[string][]int32)

func (*KafkaSaramaConsumer) PauseAll 

func (fake *KafkaSaramaConsumer) PauseAll()

func (*KafkaSaramaConsumer) PauseAllCallCount 

func (fake *KafkaSaramaConsumer) PauseAllCallCount() int

func (*KafkaSaramaConsumer) PauseAllCalls 

func (fake *KafkaSaramaConsumer) PauseAllCalls(stub func())

func (*KafkaSaramaConsumer) PauseArgsForCall 

func (fake *KafkaSaramaConsumer) PauseArgsForCall(i int) map[string][]int32

func (*KafkaSaramaConsumer) PauseCallCount 

func (fake *KafkaSaramaConsumer) PauseCallCount() int

func (*KafkaSaramaConsumer) PauseCalls 

func (fake *KafkaSaramaConsumer) PauseCalls(stub func(map[string][]int32))

func (*KafkaSaramaConsumer) Resume 

func (fake *KafkaSaramaConsumer) Resume(arg1 map[string][]int32)

func (*KafkaSaramaConsumer) ResumeAll 

func (fake *KafkaSaramaConsumer) ResumeAll()

func (*KafkaSaramaConsumer) ResumeAllCallCount 

func (fake *KafkaSaramaConsumer) ResumeAllCallCount() int

func (*KafkaSaramaConsumer) ResumeAllCalls 

func (fake *KafkaSaramaConsumer) ResumeAllCalls(stub func())

func (*KafkaSaramaConsumer) ResumeArgsForCall 

func (fake *KafkaSaramaConsumer) ResumeArgsForCall(i int) map[string][]int32

func (*KafkaSaramaConsumer) ResumeCallCount 

func (fake *KafkaSaramaConsumer) ResumeCallCount() int

func (*KafkaSaramaConsumer) ResumeCalls 

func (fake *KafkaSaramaConsumer) ResumeCalls(stub func(map[string][]int32))

func (*KafkaSaramaConsumer) Topics 

func (fake *KafkaSaramaConsumer) Topics() ([]string, error)

func (*KafkaSaramaConsumer) TopicsCallCount 

func (fake *KafkaSaramaConsumer) TopicsCallCount() int

func (*KafkaSaramaConsumer) TopicsCalls 

func (fake *KafkaSaramaConsumer) TopicsCalls(stub func() ([]string, error))

func (*KafkaSaramaConsumer) TopicsReturns 

func (fake *KafkaSaramaConsumer) TopicsReturns(result1 []string, result2 error)

func (*KafkaSaramaConsumer) TopicsReturnsOnCall 

func (fake *KafkaSaramaConsumer) TopicsReturnsOnCall(i int, result1 []string, result2 error)

type KafkaSaramaPartitionConsumer 

type KafkaSaramaPartitionConsumer struct {
	AsyncCloseStub func()

	CloseStub func() error

	ErrorsStub func() <-chan *sarama.ConsumerError

	HighWaterMarkOffsetStub func() int64

	IsPausedStub func() bool

	MessagesStub func() <-chan *sarama.ConsumerMessage

	PauseStub func()

	ResumeStub func()
	// contains filtered or unexported fields
}

func (*KafkaSaramaPartitionConsumer) AsyncClose 

func (fake *KafkaSaramaPartitionConsumer) AsyncClose()

func (*KafkaSaramaPartitionConsumer) AsyncCloseCallCount 

func (fake *KafkaSaramaPartitionConsumer) AsyncCloseCallCount() int

func (*KafkaSaramaPartitionConsumer) AsyncCloseCalls 

func (fake *KafkaSaramaPartitionConsumer) AsyncCloseCalls(stub func())

func (*KafkaSaramaPartitionConsumer) Close 

func (fake *KafkaSaramaPartitionConsumer) Close() error

func (*KafkaSaramaPartitionConsumer) CloseCallCount 

func (fake *KafkaSaramaPartitionConsumer) CloseCallCount() int

func (*KafkaSaramaPartitionConsumer) CloseCalls 

func (fake *KafkaSaramaPartitionConsumer) CloseCalls(stub func() error)

func (*KafkaSaramaPartitionConsumer) CloseReturns 

func (fake *KafkaSaramaPartitionConsumer) CloseReturns(result1 error)

func (*KafkaSaramaPartitionConsumer) CloseReturnsOnCall 

func (fake *KafkaSaramaPartitionConsumer) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaPartitionConsumer) Errors 

func (fake *KafkaSaramaPartitionConsumer) Errors() <-chan *sarama.ConsumerError

func (*KafkaSaramaPartitionConsumer) ErrorsCallCount 

func (fake *KafkaSaramaPartitionConsumer) ErrorsCallCount() int

func (*KafkaSaramaPartitionConsumer) ErrorsCalls 

func (fake *KafkaSaramaPartitionConsumer) ErrorsCalls(stub func() <-chan *sarama.ConsumerError)

func (*KafkaSaramaPartitionConsumer) ErrorsReturns 

func (fake *KafkaSaramaPartitionConsumer) ErrorsReturns(result1 <-chan *sarama.ConsumerError)

func (*KafkaSaramaPartitionConsumer) ErrorsReturnsOnCall 

func (fake *KafkaSaramaPartitionConsumer) ErrorsReturnsOnCall(i int, result1 <-chan *sarama.ConsumerError)

func (*KafkaSaramaPartitionConsumer) HighWaterMarkOffset 

func (fake *KafkaSaramaPartitionConsumer) HighWaterMarkOffset() int64

func (*KafkaSaramaPartitionConsumer) HighWaterMarkOffsetCallCount 

func (fake *KafkaSaramaPartitionConsumer) HighWaterMarkOffsetCallCount() int

func (*KafkaSaramaPartitionConsumer) HighWaterMarkOffsetCalls 

func (fake *KafkaSaramaPartitionConsumer) HighWaterMarkOffsetCalls(stub func() int64)

func (*KafkaSaramaPartitionConsumer) HighWaterMarkOffsetReturns 

func (fake *KafkaSaramaPartitionConsumer) HighWaterMarkOffsetReturns(result1 int64)

func (*KafkaSaramaPartitionConsumer) HighWaterMarkOffsetReturnsOnCall 

func (fake *KafkaSaramaPartitionConsumer) HighWaterMarkOffsetReturnsOnCall(i int, result1 int64)

func (*KafkaSaramaPartitionConsumer) Invocations 

func (fake *KafkaSaramaPartitionConsumer) Invocations() map[string][][]interface{}

func (*KafkaSaramaPartitionConsumer) IsPaused 

func (fake *KafkaSaramaPartitionConsumer) IsPaused() bool

func (*KafkaSaramaPartitionConsumer) IsPausedCallCount 

func (fake *KafkaSaramaPartitionConsumer) IsPausedCallCount() int

func (*KafkaSaramaPartitionConsumer) IsPausedCalls 

func (fake *KafkaSaramaPartitionConsumer) IsPausedCalls(stub func() bool)

func (*KafkaSaramaPartitionConsumer) IsPausedReturns 

func (fake *KafkaSaramaPartitionConsumer) IsPausedReturns(result1 bool)

func (*KafkaSaramaPartitionConsumer) IsPausedReturnsOnCall 

func (fake *KafkaSaramaPartitionConsumer) IsPausedReturnsOnCall(i int, result1 bool)

func (*KafkaSaramaPartitionConsumer) Messages 

func (fake *KafkaSaramaPartitionConsumer) Messages() <-chan *sarama.ConsumerMessage

func (*KafkaSaramaPartitionConsumer) MessagesCallCount 

func (fake *KafkaSaramaPartitionConsumer) MessagesCallCount() int

func (*KafkaSaramaPartitionConsumer) MessagesCalls 

func (fake *KafkaSaramaPartitionConsumer) MessagesCalls(stub func() <-chan *sarama.ConsumerMessage)

func (*KafkaSaramaPartitionConsumer) MessagesReturns 

func (fake *KafkaSaramaPartitionConsumer) MessagesReturns(result1 <-chan *sarama.ConsumerMessage)

func (*KafkaSaramaPartitionConsumer) MessagesReturnsOnCall 

func (fake *KafkaSaramaPartitionConsumer) MessagesReturnsOnCall(i int, result1 <-chan *sarama.ConsumerMessage)

func (*KafkaSaramaPartitionConsumer) Pause 

func (fake *KafkaSaramaPartitionConsumer) Pause()

func (*KafkaSaramaPartitionConsumer) PauseCallCount 

func (fake *KafkaSaramaPartitionConsumer) PauseCallCount() int

func (*KafkaSaramaPartitionConsumer) PauseCalls 

func (fake *KafkaSaramaPartitionConsumer) PauseCalls(stub func())

func (*KafkaSaramaPartitionConsumer) Resume 

func (fake *KafkaSaramaPartitionConsumer) Resume()

func (*KafkaSaramaPartitionConsumer) ResumeCallCount 

func (fake *KafkaSaramaPartitionConsumer) ResumeCallCount() int

func (*KafkaSaramaPartitionConsumer) ResumeCalls 

func (fake *KafkaSaramaPartitionConsumer) ResumeCalls(stub func())

type KafkaSaramaSyncProducer 

type KafkaSaramaSyncProducer struct {
	AbortTxnStub func() error

	AddMessageToTxnStub func(*sarama.ConsumerMessage, string, *string) error

	AddOffsetsToTxnStub func(map[string][]*sarama.PartitionOffsetMetadata, string) error

	BeginTxnStub func() error

	CloseStub func() error

	CommitTxnStub func() error

	IsTransactionalStub func() bool

	SendMessageStub func(*sarama.ProducerMessage) (int32, int64, error)

	SendMessagesStub func([]*sarama.ProducerMessage) error

	TxnStatusStub func() sarama.ProducerTxnStatusFlag
	// contains filtered or unexported fields
}

func (*KafkaSaramaSyncProducer) AbortTxn 

func (fake *KafkaSaramaSyncProducer) AbortTxn() error

func (*KafkaSaramaSyncProducer) AbortTxnCallCount 

func (fake *KafkaSaramaSyncProducer) AbortTxnCallCount() int

func (*KafkaSaramaSyncProducer) AbortTxnCalls 

func (fake *KafkaSaramaSyncProducer) AbortTxnCalls(stub func() error)

func (*KafkaSaramaSyncProducer) AbortTxnReturns 

func (fake *KafkaSaramaSyncProducer) AbortTxnReturns(result1 error)

func (*KafkaSaramaSyncProducer) AbortTxnReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) AbortTxnReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) AddMessageToTxn 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxn(arg1 *sarama.ConsumerMessage, arg2 string, arg3 *string) error

func (*KafkaSaramaSyncProducer) AddMessageToTxnArgsForCall 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxnArgsForCall(i int) (*sarama.ConsumerMessage, string, *string)

func (*KafkaSaramaSyncProducer) AddMessageToTxnCallCount 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxnCallCount() int

func (*KafkaSaramaSyncProducer) AddMessageToTxnCalls 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxnCalls(stub func(*sarama.ConsumerMessage, string, *string) error)

func (*KafkaSaramaSyncProducer) AddMessageToTxnReturns 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxnReturns(result1 error)

func (*KafkaSaramaSyncProducer) AddMessageToTxnReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) AddMessageToTxnReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) AddOffsetsToTxn 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxn(arg1 map[string][]*sarama.PartitionOffsetMetadata, arg2 string) error

func (*KafkaSaramaSyncProducer) AddOffsetsToTxnArgsForCall 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxnArgsForCall(i int) (map[string][]*sarama.PartitionOffsetMetadata, string)

func (*KafkaSaramaSyncProducer) AddOffsetsToTxnCallCount 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxnCallCount() int

func (*KafkaSaramaSyncProducer) AddOffsetsToTxnCalls 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxnCalls(stub func(map[string][]*sarama.PartitionOffsetMetadata, string) error)

func (*KafkaSaramaSyncProducer) AddOffsetsToTxnReturns 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxnReturns(result1 error)

func (*KafkaSaramaSyncProducer) AddOffsetsToTxnReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) AddOffsetsToTxnReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) BeginTxn 

func (fake *KafkaSaramaSyncProducer) BeginTxn() error

func (*KafkaSaramaSyncProducer) BeginTxnCallCount 

func (fake *KafkaSaramaSyncProducer) BeginTxnCallCount() int

func (*KafkaSaramaSyncProducer) BeginTxnCalls 

func (fake *KafkaSaramaSyncProducer) BeginTxnCalls(stub func() error)

func (*KafkaSaramaSyncProducer) BeginTxnReturns 

func (fake *KafkaSaramaSyncProducer) BeginTxnReturns(result1 error)

func (*KafkaSaramaSyncProducer) BeginTxnReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) BeginTxnReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) Close 

func (fake *KafkaSaramaSyncProducer) Close() error

func (*KafkaSaramaSyncProducer) CloseCallCount 

func (fake *KafkaSaramaSyncProducer) CloseCallCount() int

func (*KafkaSaramaSyncProducer) CloseCalls 

func (fake *KafkaSaramaSyncProducer) CloseCalls(stub func() error)

func (*KafkaSaramaSyncProducer) CloseReturns 

func (fake *KafkaSaramaSyncProducer) CloseReturns(result1 error)

func (*KafkaSaramaSyncProducer) CloseReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) CommitTxn 

func (fake *KafkaSaramaSyncProducer) CommitTxn() error

func (*KafkaSaramaSyncProducer) CommitTxnCallCount 

func (fake *KafkaSaramaSyncProducer) CommitTxnCallCount() int

func (*KafkaSaramaSyncProducer) CommitTxnCalls 

func (fake *KafkaSaramaSyncProducer) CommitTxnCalls(stub func() error)

func (*KafkaSaramaSyncProducer) CommitTxnReturns 

func (fake *KafkaSaramaSyncProducer) CommitTxnReturns(result1 error)

func (*KafkaSaramaSyncProducer) CommitTxnReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) CommitTxnReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) Invocations 

func (fake *KafkaSaramaSyncProducer) Invocations() map[string][][]interface{}

func (*KafkaSaramaSyncProducer) IsTransactional 

func (fake *KafkaSaramaSyncProducer) IsTransactional() bool

func (*KafkaSaramaSyncProducer) IsTransactionalCallCount 

func (fake *KafkaSaramaSyncProducer) IsTransactionalCallCount() int

func (*KafkaSaramaSyncProducer) IsTransactionalCalls 

func (fake *KafkaSaramaSyncProducer) IsTransactionalCalls(stub func() bool)

func (*KafkaSaramaSyncProducer) IsTransactionalReturns 

func (fake *KafkaSaramaSyncProducer) IsTransactionalReturns(result1 bool)

func (*KafkaSaramaSyncProducer) IsTransactionalReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) IsTransactionalReturnsOnCall(i int, result1 bool)

func (*KafkaSaramaSyncProducer) SendMessage 

func (fake *KafkaSaramaSyncProducer) SendMessage(arg1 *sarama.ProducerMessage) (int32, int64, error)

func (*KafkaSaramaSyncProducer) SendMessageArgsForCall 

func (fake *KafkaSaramaSyncProducer) SendMessageArgsForCall(i int) *sarama.ProducerMessage

func (*KafkaSaramaSyncProducer) SendMessageCallCount 

func (fake *KafkaSaramaSyncProducer) SendMessageCallCount() int

func (*KafkaSaramaSyncProducer) SendMessageCalls 

func (fake *KafkaSaramaSyncProducer) SendMessageCalls(stub func(*sarama.ProducerMessage) (int32, int64, error))

func (*KafkaSaramaSyncProducer) SendMessageReturns 

func (fake *KafkaSaramaSyncProducer) SendMessageReturns(result1 int32, result2 int64, result3 error)

func (*KafkaSaramaSyncProducer) SendMessageReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) SendMessageReturnsOnCall(i int, result1 int32, result2 int64, result3 error)

func (*KafkaSaramaSyncProducer) SendMessages 

func (fake *KafkaSaramaSyncProducer) SendMessages(arg1 []*sarama.ProducerMessage) error

func (*KafkaSaramaSyncProducer) SendMessagesArgsForCall 

func (fake *KafkaSaramaSyncProducer) SendMessagesArgsForCall(i int) []*sarama.ProducerMessage

func (*KafkaSaramaSyncProducer) SendMessagesCallCount 

func (fake *KafkaSaramaSyncProducer) SendMessagesCallCount() int

func (*KafkaSaramaSyncProducer) SendMessagesCalls 

func (fake *KafkaSaramaSyncProducer) SendMessagesCalls(stub func([]*sarama.ProducerMessage) error)

func (*KafkaSaramaSyncProducer) SendMessagesReturns 

func (fake *KafkaSaramaSyncProducer) SendMessagesReturns(result1 error)

func (*KafkaSaramaSyncProducer) SendMessagesReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) SendMessagesReturnsOnCall(i int, result1 error)

func (*KafkaSaramaSyncProducer) TxnStatus 

func (fake *KafkaSaramaSyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag

func (*KafkaSaramaSyncProducer) TxnStatusCallCount 

func (fake *KafkaSaramaSyncProducer) TxnStatusCallCount() int

func (*KafkaSaramaSyncProducer) TxnStatusCalls 

func (fake *KafkaSaramaSyncProducer) TxnStatusCalls(stub func() sarama.ProducerTxnStatusFlag)

func (*KafkaSaramaSyncProducer) TxnStatusReturns 

func (fake *KafkaSaramaSyncProducer) TxnStatusReturns(result1 sarama.ProducerTxnStatusFlag)

func (*KafkaSaramaSyncProducer) TxnStatusReturnsOnCall 

func (fake *KafkaSaramaSyncProducer) TxnStatusReturnsOnCall(i int, result1 sarama.ProducerTxnStatusFlag)

type KafkaSyncProducer 

type KafkaSyncProducer struct {
	CloseStub func() error

	SendMessageStub func(context.Context, *sarama.ProducerMessage) (int32, int64, error)

	SendMessagesStub func(context.Context, []*sarama.ProducerMessage) error
	// contains filtered or unexported fields
}

func (*KafkaSyncProducer) Close 

func (fake *KafkaSyncProducer) Close() error

func (*KafkaSyncProducer) CloseCallCount 

func (fake *KafkaSyncProducer) CloseCallCount() int

func (*KafkaSyncProducer) CloseCalls 

func (fake *KafkaSyncProducer) CloseCalls(stub func() error)

func (*KafkaSyncProducer) CloseReturns 

func (fake *KafkaSyncProducer) CloseReturns(result1 error)

func (*KafkaSyncProducer) CloseReturnsOnCall 

func (fake *KafkaSyncProducer) CloseReturnsOnCall(i int, result1 error)

func (*KafkaSyncProducer) Invocations 

func (fake *KafkaSyncProducer) Invocations() map[string][][]interface{}

func (*KafkaSyncProducer) SendMessage 

func (fake *KafkaSyncProducer) SendMessage(arg1 context.Context, arg2 *sarama.ProducerMessage) (int32, int64, error)

func (*KafkaSyncProducer) SendMessageArgsForCall 

func (fake *KafkaSyncProducer) SendMessageArgsForCall(i int) (context.Context, *sarama.ProducerMessage)

func (*KafkaSyncProducer) SendMessageCallCount 

func (fake *KafkaSyncProducer) SendMessageCallCount() int

func (*KafkaSyncProducer) SendMessageCalls 

func (fake *KafkaSyncProducer) SendMessageCalls(stub func(context.Context, *sarama.ProducerMessage) (int32, int64, error))

func (*KafkaSyncProducer) SendMessageReturns 

func (fake *KafkaSyncProducer) SendMessageReturns(result1 int32, result2 int64, result3 error)

func (*KafkaSyncProducer) SendMessageReturnsOnCall 

func (fake *KafkaSyncProducer) SendMessageReturnsOnCall(i int, result1 int32, result2 int64, result3 error)

func (*KafkaSyncProducer) SendMessages 

func (fake *KafkaSyncProducer) SendMessages(arg1 context.Context, arg2 []*sarama.ProducerMessage) error

func (*KafkaSyncProducer) SendMessagesArgsForCall 

func (fake *KafkaSyncProducer) SendMessagesArgsForCall(i int) (context.Context, []*sarama.ProducerMessage)

func (*KafkaSyncProducer) SendMessagesCallCount 

func (fake *KafkaSyncProducer) SendMessagesCallCount() int

func (*KafkaSyncProducer) SendMessagesCalls 

func (fake *KafkaSyncProducer) SendMessagesCalls(stub func(context.Context, []*sarama.ProducerMessage) error)

func (*KafkaSyncProducer) SendMessagesReturns 

func (fake *KafkaSyncProducer) SendMessagesReturns(result1 error)

func (*KafkaSyncProducer) SendMessagesReturnsOnCall 

func (fake *KafkaSyncProducer) SendMessagesReturnsOnCall(i int, result1 error)

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.