mock_queue

Documentation

Overview

Package mock_queue is a generated GoMock package.

Index

• type MockKafkaWriter
  • func NewMockKafkaWriter(ctrl *gomock.Controller) *MockKafkaWriter
  • func (m *MockKafkaWriter) EXPECT() *MockKafkaWriterMockRecorder
  • func (m *MockKafkaWriter) WriteMessages(ctx context.Context, msgs ...kafka.Message) error
• type MockKafkaWriterMockRecorder
  • func (mr *MockKafkaWriterMockRecorder) WriteMessages(ctx interface{}, msgs ...interface{}) *gomock.Call

Types

type MockKafkaWriter

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

MockKafkaWriter is a mock of KafkaWriter interface.

func NewMockKafkaWriter

func NewMockKafkaWriter(ctrl *gomock.Controller) *MockKafkaWriter

NewMockKafkaWriter creates a new mock instance.

func (*MockKafkaWriter) EXPECT

func (m *MockKafkaWriter) EXPECT() *MockKafkaWriterMockRecorder

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

func (*MockKafkaWriter) WriteMessages

func (m *MockKafkaWriter) WriteMessages(ctx context.Context, msgs ...kafka.Message) error

WriteMessages mocks base method.

type MockKafkaWriterMockRecorder

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

MockKafkaWriterMockRecorder is the mock recorder for MockKafkaWriter.

func (*MockKafkaWriterMockRecorder) WriteMessages

func (mr *MockKafkaWriterMockRecorder) WriteMessages(ctx interface{}, msgs ...interface{}) *gomock.Call

WriteMessages indicates an expected call of WriteMessages.