mock

Documentation

Index

• Constants
• type KafkaAdminMockClient
  • func NewKafkaAdminMockClient(initTopics ...string) *KafkaAdminMockClient
  • func (m *KafkaAdminMockClient) ACLs() []string
  • func (m *KafkaAdminMockClient) CreateACLs(ctx context.Context, aclBindings kafka.ACLBindings, ...) (result []kafka.CreateACLResult, err error)
  • func (m *KafkaAdminMockClient) CreateTopics(ctx context.Context, topics []kafka.TopicSpecification, ...) (result []kafka.TopicResult, err error)
  • func (m *KafkaAdminMockClient) DescribeACLs(ctx context.Context, aclBindingFilter kafka.ACLBindingFilter, ...) (result *kafka.DescribeACLsResult, err error)
  • func (m *KafkaAdminMockClient) DescribeTopics(ctx context.Context, topics kafka.TopicCollection, ...) (result kafka.DescribeTopicsResult, err error)
  • func (m *KafkaAdminMockClient) Topics() []string
• type MaestroMockServer
  • func NewMaestroMockServer() *MaestroMockServer
  • func (m *MaestroMockServer) Start()
  • func (m *MaestroMockServer) Stop()
  • func (m *MaestroMockServer) URL() string
• type MockMessageQueueAuthzCreator
  • func NewMockMessageQueueAuthzCreator() *MockMessageQueueAuthzCreator
  • func (a *MockMessageQueueAuthzCreator) ClusterName() string
  • func (a *MockMessageQueueAuthzCreator) CreateAuthorizations(ctx context.Context, clusterName string) error
  • func (a *MockMessageQueueAuthzCreator) DeleteAuthorizations(ctx context.Context, clusterName string) error
• type MockSyncContext
  • func NewMockSyncContext(t *testing.T, key string) *MockSyncContext
  • func (m MockSyncContext) Queue() workqueue.RateLimitingInterface
  • func (m MockSyncContext) QueueKey() string
  • func (m MockSyncContext) Recorder() events.Recorder

Constants

const Consumer = "maestro-build-in-consumer"

Types

type KafkaAdminMockClient

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

func NewKafkaAdminMockClient

func NewKafkaAdminMockClient(initTopics ...string) *KafkaAdminMockClient

func (*KafkaAdminMockClient) ACLs

func (m *KafkaAdminMockClient) ACLs() []string

func (*KafkaAdminMockClient) CreateACLs

func (m *KafkaAdminMockClient) CreateACLs(ctx context.Context, aclBindings kafka.ACLBindings,
	options ...kafka.CreateACLsAdminOption) (result []kafka.CreateACLResult, err error)

func (*KafkaAdminMockClient) CreateTopics

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

func (*KafkaAdminMockClient) DescribeACLs

func (m *KafkaAdminMockClient) DescribeACLs(ctx context.Context, aclBindingFilter kafka.ACLBindingFilter,
	options ...kafka.DescribeACLsAdminOption) (result *kafka.DescribeACLsResult, err error)

func (*KafkaAdminMockClient) DescribeTopics

func (m *KafkaAdminMockClient) DescribeTopics(ctx context.Context, topics kafka.TopicCollection,
	options ...kafka.DescribeTopicsAdminOption) (result kafka.DescribeTopicsResult, err error)

func (*KafkaAdminMockClient) Topics

func (m *KafkaAdminMockClient) Topics() []string

type MaestroMockServer

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

func NewMaestroMockServer

func NewMaestroMockServer() *MaestroMockServer

func (*MaestroMockServer) Start

func (m *MaestroMockServer) Start()

func (*MaestroMockServer) Stop

func (m *MaestroMockServer) Stop()

func (*MaestroMockServer) URL

func (m *MaestroMockServer) URL() string

type MockMessageQueueAuthzCreator

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

func NewMockMessageQueueAuthzCreator

func NewMockMessageQueueAuthzCreator() *MockMessageQueueAuthzCreator

func (*MockMessageQueueAuthzCreator) ClusterName

func (a *MockMessageQueueAuthzCreator) ClusterName() string

func (*MockMessageQueueAuthzCreator) CreateAuthorizations

func (a *MockMessageQueueAuthzCreator) CreateAuthorizations(ctx context.Context, clusterName string) error

func (*MockMessageQueueAuthzCreator) DeleteAuthorizations

func (a *MockMessageQueueAuthzCreator) DeleteAuthorizations(ctx context.Context, clusterName string) error

type MockSyncContext

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

func NewMockSyncContext

func NewMockSyncContext(t *testing.T, key string) *MockSyncContext

func (MockSyncContext) Queue

func (m MockSyncContext) Queue() workqueue.RateLimitingInterface

func (MockSyncContext) QueueKey

func (m MockSyncContext) QueueKey() string

func (MockSyncContext) Recorder

func (m MockSyncContext) Recorder() events.Recorder