wrapper

Documentation

Index

• Variables
• func ProductionNewAdminClientWrapper(ctx context.Context, brokers []string, config *sarama.Config, ...) (types.AdminClientInterface, error)
• type NewAdminClientFnType

Variables

var NewAdminClientFn = ProductionNewAdminClientWrapper

Function Variables To Facilitate Mocking Of Sarama Functionality In Unit Tests

Functions

func ProductionNewAdminClientWrapper

func ProductionNewAdminClientWrapper(ctx context.Context, brokers []string, config *sarama.Config, adminClientType types.AdminClientType) (types.AdminClientInterface, error)

Create A New Kafka AdminClient Of Specified Type - Based On Specified Sarama Config

Types

type NewAdminClientFnType

type NewAdminClientFnType = func(ctx context.Context, brokers []string, config *sarama.Config, adminClientType types.AdminClientType) (types.AdminClientInterface, error)

Define Function Types For Wrapper Variables (Typesafe Stubbing For Tests)