stub

Documentation

Index

• type Client
  • func (s Client) Close()
  • func (s Client) CreateTopic(context.Context, kafkaadmin.CreateTopicConfig) error
  • func (s Client) DeleteTopic(context.Context, string) error
  • func (s Client) DescribeTopics(context.Context, []string) (kafkaadmin.TopicStates, error)
  • func (s Client) GetDynamicConfigs(context.Context, string, []string) (kafkaadmin.ResourceConfigs, error)
  • func (s Client) RemoveThrottle(context.Context, kafkaadmin.RemoveThrottleConfig) error
  • func (s Client) SetThrottle(context.Context, kafkaadmin.SetThrottleConfig) error

Types

type Client

type Client struct{}

StubClient is a stubbed implementation of KafkaAdminClient.

func (Client) Close

func (s Client) Close()

func (Client) CreateTopic

func (s Client) CreateTopic(context.Context, kafkaadmin.CreateTopicConfig) error

func (Client) DeleteTopic

func (s Client) DeleteTopic(context.Context, string) error

func (Client) DescribeTopics

func (s Client) DescribeTopics(context.Context, []string) (kafkaadmin.TopicStates, error)

func (Client) GetDynamicConfigs

func (s Client) GetDynamicConfigs(context.Context, string, []string) (kafkaadmin.ResourceConfigs, error)

func (Client) RemoveThrottle

func (s Client) RemoveThrottle(context.Context, kafkaadmin.RemoveThrottleConfig) error

func (Client) SetThrottle

func (s Client) SetThrottle(context.Context, kafkaadmin.SetThrottleConfig) error