mock_v2

Documentation

Overview

Package mock_v2 is a generated GoMock package.

Package mock_v2 is a generated GoMock package.

Package mock_v2 is a generated GoMock package.

Index

• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (m *MockClient) CreateTopics(ctx context.Context, req *kafka.CreateTopicsRequest) (*kafka.CreateTopicsResponse, error)
  • func (m *MockClient) DescribeConfigs(ctx context.Context, req *kafka.DescribeConfigsRequest) (*kafka.DescribeConfigsResponse, error)
  • func (m *MockClient) EXPECT() *MockClientMockRecorder
  • func (m *MockClient) Metadata(ctx context.Context, req *kafka.MetadataRequest) (*kafka.MetadataResponse, error)
• type MockClientMockRecorder
  • func (mr *MockClientMockRecorder) CreateTopics(ctx, req interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) DescribeConfigs(ctx, req interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Metadata(ctx, req interface{}) *gomock.Call
• type MockGokrb5v8Client
  • func NewMockGokrb5v8Client(ctrl *gomock.Controller) *MockGokrb5v8Client
  • func (m *MockGokrb5v8Client) Credentials() *credentials.Credentials
  • func (m *MockGokrb5v8Client) Destroy()
  • func (m *MockGokrb5v8Client) EXPECT() *MockGokrb5v8ClientMockRecorder
  • func (m *MockGokrb5v8Client) GetServiceTicket(spn string) (messages.Ticket, types.EncryptionKey, error)
• type MockGokrb5v8ClientMockRecorder
  • func (mr *MockGokrb5v8ClientMockRecorder) Credentials() *gomock.Call
  • func (mr *MockGokrb5v8ClientMockRecorder) Destroy() *gomock.Call
  • func (mr *MockGokrb5v8ClientMockRecorder) GetServiceTicket(spn interface{}) *gomock.Call
• type MockWriter
  • func NewMockWriter(ctrl *gomock.Controller) *MockWriter
  • func (m *MockWriter) Close() error
  • func (m *MockWriter) EXPECT() *MockWriterMockRecorder
  • func (m *MockWriter) Stats() kafka.WriterStats
  • func (m *MockWriter) WriteMessages(ctx context.Context, msgs ...kafka.Message) error
• type MockWriterMockRecorder
  • func (mr *MockWriterMockRecorder) Close() *gomock.Call
  • func (mr *MockWriterMockRecorder) Stats() *gomock.Call
  • func (mr *MockWriterMockRecorder) WriteMessages(ctx interface{}, msgs ...interface{}) *gomock.Call

Types

type MockClient

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

MockClient is a mock of Client interface.

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) CreateTopics

func (m *MockClient) CreateTopics(ctx context.Context, req *kafka.CreateTopicsRequest) (*kafka.CreateTopicsResponse, error)

CreateTopics mocks base method.

func (*MockClient) DescribeConfigs

func (m *MockClient) DescribeConfigs(ctx context.Context, req *kafka.DescribeConfigsRequest) (*kafka.DescribeConfigsResponse, error)

DescribeConfigs mocks base method.

func (*MockClient) EXPECT

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) Metadata

func (m *MockClient) Metadata(ctx context.Context, req *kafka.MetadataRequest) (*kafka.MetadataResponse, error)

Metadata mocks base method.

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) CreateTopics

func (mr *MockClientMockRecorder) CreateTopics(ctx, req interface{}) *gomock.Call

CreateTopics indicates an expected call of CreateTopics.

func (*MockClientMockRecorder) DescribeConfigs

func (mr *MockClientMockRecorder) DescribeConfigs(ctx, req interface{}) *gomock.Call

DescribeConfigs indicates an expected call of DescribeConfigs.

func (*MockClientMockRecorder) Metadata

func (mr *MockClientMockRecorder) Metadata(ctx, req interface{}) *gomock.Call

Metadata indicates an expected call of Metadata.

type MockGokrb5v8Client

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

MockGokrb5v8Client is a mock of Gokrb5v8Client interface.

func NewMockGokrb5v8Client

func NewMockGokrb5v8Client(ctrl *gomock.Controller) *MockGokrb5v8Client

NewMockGokrb5v8Client creates a new mock instance.

func (*MockGokrb5v8Client) Credentials

func (m *MockGokrb5v8Client) Credentials() *credentials.Credentials

Credentials mocks base method.

func (*MockGokrb5v8Client) Destroy

func (m *MockGokrb5v8Client) Destroy()

Destroy mocks base method.

func (*MockGokrb5v8Client) EXPECT

func (m *MockGokrb5v8Client) EXPECT() *MockGokrb5v8ClientMockRecorder

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

func (*MockGokrb5v8Client) GetServiceTicket

func (m *MockGokrb5v8Client) GetServiceTicket(spn string) (messages.Ticket, types.EncryptionKey, error)

GetServiceTicket mocks base method.

type MockGokrb5v8ClientMockRecorder

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

MockGokrb5v8ClientMockRecorder is the mock recorder for MockGokrb5v8Client.

func (*MockGokrb5v8ClientMockRecorder) Credentials

func (mr *MockGokrb5v8ClientMockRecorder) Credentials() *gomock.Call

Credentials indicates an expected call of Credentials.

func (*MockGokrb5v8ClientMockRecorder) Destroy

func (mr *MockGokrb5v8ClientMockRecorder) Destroy() *gomock.Call

Destroy indicates an expected call of Destroy.

func (*MockGokrb5v8ClientMockRecorder) GetServiceTicket

func (mr *MockGokrb5v8ClientMockRecorder) GetServiceTicket(spn interface{}) *gomock.Call

GetServiceTicket indicates an expected call of GetServiceTicket.

type MockWriter

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

MockWriter is a mock of Writer interface.

func NewMockWriter

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance.

func (*MockWriter) Close

func (m *MockWriter) Close() error

Close mocks base method.

func (*MockWriter) EXPECT

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Stats

func (m *MockWriter) Stats() kafka.WriterStats

Stats mocks base method.

func (*MockWriter) WriteMessages

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

WriteMessages mocks base method.

type MockWriterMockRecorder

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

MockWriterMockRecorder is the mock recorder for MockWriter.

func (*MockWriterMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockWriterMockRecorder) Stats

func (mr *MockWriterMockRecorder) Stats() *gomock.Call

Stats indicates an expected call of Stats.

func (*MockWriterMockRecorder) WriteMessages

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

WriteMessages indicates an expected call of WriteMessages.