mockkafka

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
  • func (m *MockKafka) Close() error
  • func (m *MockKafka) CommitMessages(arg0 context.Context, arg1 kafka.Message) error
  • func (m *MockKafka) DialContext(arg0 context.Context, arg1, arg2 string) (*kafka.Conn, error)
  • func (m *MockKafka) EXPECT() *MockKafkaMockRecorder
  • func (m *MockKafka) FetchMessage(arg0 context.Context) (kafka.Message, error)
  • func (m *MockKafka) NewReader(arg0 string) *kafka.Reader
  • func (m *MockKafka) ReadMessage(arg0 context.Context) (kafka.Message, error)
  • func (m *MockKafka) WriteMessages(arg0 context.Context, arg1 kafka.Message) error
• type MockKafkaMockRecorder
  • func (mr *MockKafkaMockRecorder) Close() *gomock.Call
  • func (mr *MockKafkaMockRecorder) CommitMessages(arg0, arg1 any) *gomock.Call
  • func (mr *MockKafkaMockRecorder) DialContext(arg0, arg1, arg2 any) *gomock.Call
  • func (mr *MockKafkaMockRecorder) FetchMessage(arg0 any) *gomock.Call
  • func (mr *MockKafkaMockRecorder) NewReader(arg0 any) *gomock.Call
  • func (mr *MockKafkaMockRecorder) ReadMessage(arg0 any) *gomock.Call
  • func (mr *MockKafkaMockRecorder) WriteMessages(arg0, arg1 any) *gomock.Call

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.