mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockKafkaClient
  • func NewMockKafkaClient(ctrl *gomock.Controller) *MockKafkaClient
  • func (m *MockKafkaClient) CreateTopics(ctx context.Context, topics []kafka.TopicSpecification, ...) ([]kafka.TopicResult, error)
  • func (m *MockKafkaClient) DeleteTopics(ctx context.Context, topics []string, options ...kafka.DeleteTopicsAdminOption) ([]kafka.TopicResult, error)
  • func (m *MockKafkaClient) EXPECT() *MockKafkaClientMockRecorder
• type MockKafkaClientMockRecorder
  • func (mr *MockKafkaClientMockRecorder) CreateTopics(ctx, topics interface{}, options ...interface{}) *gomock.Call
  • func (mr *MockKafkaClientMockRecorder) DeleteTopics(ctx, topics interface{}, options ...interface{}) *gomock.Call

Types

type MockKafkaClient

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

MockKafkaClient is a mock of KafkaClient interface.

func NewMockKafkaClient

func NewMockKafkaClient(ctrl *gomock.Controller) *MockKafkaClient

NewMockKafkaClient creates a new mock instance.

func (*MockKafkaClient) CreateTopics

func (m *MockKafkaClient) CreateTopics(ctx context.Context, topics []kafka.TopicSpecification, options ...kafka.CreateTopicsAdminOption) ([]kafka.TopicResult, error)

CreateTopics mocks base method.

func (*MockKafkaClient) DeleteTopics

func (m *MockKafkaClient) DeleteTopics(ctx context.Context, topics []string, options ...kafka.DeleteTopicsAdminOption) ([]kafka.TopicResult, error)

DeleteTopics mocks base method.

func (*MockKafkaClient) EXPECT

func (m *MockKafkaClient) EXPECT() *MockKafkaClientMockRecorder

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

type MockKafkaClientMockRecorder

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

MockKafkaClientMockRecorder is the mock recorder for MockKafkaClient.

func (*MockKafkaClientMockRecorder) CreateTopics

func (mr *MockKafkaClientMockRecorder) CreateTopics(ctx, topics interface{}, options ...interface{}) *gomock.Call

CreateTopics indicates an expected call of CreateTopics.

func (*MockKafkaClientMockRecorder) DeleteTopics

func (mr *MockKafkaClientMockRecorder) DeleteTopics(ctx, topics interface{}, options ...interface{}) *gomock.Call

DeleteTopics indicates an expected call of DeleteTopics.