mocks

package

v1.6.9 Latest Latest Go to latest Published: Feb 15, 2026 License: BSD-2-Clause Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bborbe/kafka-topic-reader

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated by counterfeiter. DO NOT EDIT.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BuildInfoMetrics ¶ added in v1.6.3

type BuildInfoMetrics struct {
	SetBuildInfoStub func(*time.DateTime)
	// contains filtered or unexported fields
}

func (*BuildInfoMetrics) Invocations ¶ added in v1.6.3

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

func (*BuildInfoMetrics) SetBuildInfo ¶ added in v1.6.3

func (fake *BuildInfoMetrics) SetBuildInfo(arg1 *time.DateTime)

func (*BuildInfoMetrics) SetBuildInfoArgsForCall ¶ added in v1.6.3

func (fake *BuildInfoMetrics) SetBuildInfoArgsForCall(i int) *time.DateTime

func (*BuildInfoMetrics) SetBuildInfoCallCount ¶ added in v1.6.3

func (fake *BuildInfoMetrics) SetBuildInfoCallCount() int

func (*BuildInfoMetrics) SetBuildInfoCalls ¶ added in v1.6.3

func (fake *BuildInfoMetrics) SetBuildInfoCalls(stub func(*time.DateTime))

type ChangesProvider ¶

type ChangesProvider struct {
	ChangesStub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset, uint64, []byte) (pkg.Records, error)
	// contains filtered or unexported fields
}

func (*ChangesProvider) Changes ¶

func (fake *ChangesProvider) Changes(arg1 context.Context, arg2 kafka.Topic, arg3 kafka.Partition, arg4 kafka.Offset, arg5 uint64, arg6 []byte) (pkg.Records, error)

func (*ChangesProvider) ChangesArgsForCall ¶

func (fake *ChangesProvider) ChangesArgsForCall(i int) (context.Context, kafka.Topic, kafka.Partition, kafka.Offset, uint64, []byte)

func (*ChangesProvider) ChangesCallCount ¶

func (fake *ChangesProvider) ChangesCallCount() int

func (*ChangesProvider) ChangesCalls ¶

func (fake *ChangesProvider) ChangesCalls(stub func(context.Context, kafka.Topic, kafka.Partition, kafka.Offset, uint64, []byte) (pkg.Records, error))

func (*ChangesProvider) ChangesReturns ¶

func (fake *ChangesProvider) ChangesReturns(result1 pkg.Records, result2 error)

func (*ChangesProvider) ChangesReturnsOnCall ¶

func (fake *ChangesProvider) ChangesReturnsOnCall(i int, result1 pkg.Records, result2 error)

func (*ChangesProvider) Invocations ¶

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

type Converter ¶

type Converter struct {
	ConvertStub func(context.Context, *sarama.ConsumerMessage) (*pkg.Record, error)
	// contains filtered or unexported fields
}

func (*Converter) Convert ¶

func (fake *Converter) Convert(arg1 context.Context, arg2 *sarama.ConsumerMessage) (*pkg.Record, error)

func (*Converter) ConvertArgsForCall ¶

func (fake *Converter) ConvertArgsForCall(i int) (context.Context, *sarama.ConsumerMessage)

func (*Converter) ConvertCallCount ¶

func (fake *Converter) ConvertCallCount() int

func (*Converter) ConvertCalls ¶

func (fake *Converter) ConvertCalls(stub func(context.Context, *sarama.ConsumerMessage) (*pkg.Record, error))

func (*Converter) ConvertReturns ¶

func (fake *Converter) ConvertReturns(result1 *pkg.Record, result2 error)

func (*Converter) ConvertReturnsOnCall ¶

func (fake *Converter) ConvertReturnsOnCall(i int, result1 *pkg.Record, result2 error)

func (*Converter) Invocations ¶

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

Source Files ¶

View all Source files

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