testing

Documentation

Index

• func ErrorNewAdminClientFn(err error) wrapper.NewAdminClientFnType
• func NewMockAdminClient() types.AdminClientInterface
• func NonValidatingNewAdminClientFn(mockAdminClient types.AdminClientInterface) wrapper.NewAdminClientFnType
• func RestoreNewAdminClientFn()
• func StubNewAdminClientFn(stubNewAdminClientFn wrapper.NewAdminClientFnType)
• func ValidatingNewAdminClientFn(t *testing.T, expectedCtx context.Context, expectedBrokers []string, ...) wrapper.NewAdminClientFnType
• type MockAdminClient
  • func (c MockAdminClient) Close() error
  • func (c MockAdminClient) CreateTopic(context.Context, string, *sarama.TopicDetail) *sarama.TopicError
  • func (c MockAdminClient) DeleteTopic(context.Context, string) *sarama.TopicError

Functions

func ErrorNewAdminClientFn

func ErrorNewAdminClientFn(err error) wrapper.NewAdminClientFnType

Error NewAdminClient Function

func NewMockAdminClient

func NewMockAdminClient() types.AdminClientInterface

func NonValidatingNewAdminClientFn

func NonValidatingNewAdminClientFn(mockAdminClient types.AdminClientInterface) wrapper.NewAdminClientFnType

Non-Validating NewAdminClient Function

func RestoreNewAdminClientFn

func RestoreNewAdminClientFn()

Restore The NewAdminClientFn To Official Production Value

func StubNewAdminClientFn

func StubNewAdminClientFn(stubNewAdminClientFn wrapper.NewAdminClientFnType)

Replace The NewAdminClientFn With Specified Mock / Test Value

func ValidatingNewAdminClientFn

func ValidatingNewAdminClientFn(t *testing.T,
	expectedCtx context.Context,
	expectedBrokers []string,
	expectedConfig *sarama.Config,
	expectedAdminClientType types.AdminClientType,
	mockAdminClient types.AdminClientInterface) wrapper.NewAdminClientFnType

Validating NewAdminClient Function

Types

type MockAdminClient

type MockAdminClient struct {
}

func (MockAdminClient) Close

func (c MockAdminClient) Close() error

func (MockAdminClient) CreateTopic

func (c MockAdminClient) CreateTopic(context.Context, string, *sarama.TopicDetail) *sarama.TopicError

func (MockAdminClient) DeleteTopic

func (c MockAdminClient) DeleteTopic(context.Context, string) *sarama.TopicError