mockkafka

package

v0.1.10 Latest Latest Go to latest Published: Nov 28, 2023 License: Unlicense Imports: 4 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/0xanonymeow/kafka-go

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated by MockGen. DO NOT EDIT. Source: kafka.go

Generated by this command:

mockgen -source=kafka.go -package=mockkafka -destination=testings/mock_kafka/mockkafka.go

Package mockkafka is a generated GoMock package.

Index ¶

type MockKafka
- func NewMockKafka(ctrl *gomock.Controller) *MockKafka
type MockKafkaMockRecorder

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MockKafka ¶

type MockKafka struct {
	// contains filtered or unexported fields
}

MockKafka is a mock of Kafka interface.

func NewMockKafka ¶

func NewMockKafka(ctrl *gomock.Controller) *MockKafka

NewMockKafka creates a new mock instance.

func (*MockKafka) Close ¶

func (m *MockKafka) Close() error

Close mocks base method.

func (*MockKafka) CommitMessages ¶

func (m *MockKafka) CommitMessages(arg0 context.Context, arg1 kafka.Message) error

CommitMessages mocks base method.

func (*MockKafka) DialContext ¶

func (m *MockKafka) DialContext(arg0 context.Context, arg1, arg2 string) (*kafka.Conn, error)

DialContext mocks base method.

func (*MockKafka) EXPECT ¶

func (m *MockKafka) EXPECT() *MockKafkaMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKafka) FetchMessage ¶

func (m *MockKafka) FetchMessage(arg0 context.Context) (kafka.Message, error)

FetchMessage mocks base method.

func (*MockKafka) NewReader ¶

func (m *MockKafka) NewReader(arg0 []string) *kafka.Reader

NewReader mocks base method.

func (*MockKafka) ReadMessage ¶

func (m *MockKafka) ReadMessage(arg0 context.Context) (kafka.Message, error)

ReadMessage mocks base method.

func (*MockKafka) WriteMessages ¶

func (m *MockKafka) WriteMessages(arg0 context.Context, arg1 kafka.Message) error

WriteMessages mocks base method.

type MockKafkaMockRecorder ¶

type MockKafkaMockRecorder struct {
	// contains filtered or unexported fields
}

MockKafkaMockRecorder is the mock recorder for MockKafka.

func (*MockKafkaMockRecorder) Close ¶

func (mr *MockKafkaMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockKafkaMockRecorder) CommitMessages ¶

func (mr *MockKafkaMockRecorder) CommitMessages(arg0, arg1 any) *gomock.Call

CommitMessages indicates an expected call of CommitMessages.

func (*MockKafkaMockRecorder) DialContext ¶

func (mr *MockKafkaMockRecorder) DialContext(arg0, arg1, arg2 any) *gomock.Call

DialContext indicates an expected call of DialContext.

func (*MockKafkaMockRecorder) FetchMessage ¶

func (mr *MockKafkaMockRecorder) FetchMessage(arg0 any) *gomock.Call

FetchMessage indicates an expected call of FetchMessage.

func (*MockKafkaMockRecorder) NewReader ¶

func (mr *MockKafkaMockRecorder) NewReader(arg0 any) *gomock.Call

NewReader indicates an expected call of NewReader.

func (*MockKafkaMockRecorder) ReadMessage ¶

func (mr *MockKafkaMockRecorder) ReadMessage(arg0 any) *gomock.Call

ReadMessage indicates an expected call of ReadMessage.

func (*MockKafkaMockRecorder) WriteMessages ¶

func (mr *MockKafkaMockRecorder) WriteMessages(arg0, arg1 any) *gomock.Call

WriteMessages indicates an expected call of WriteMessages.

Source Files ¶

View all Source files

mockkafka.go

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