stub

Documentation

Index

• type Client
  • func NewClient() Client
  • func (c Client) AddBrokers(bs kafkaadmin.BrokerStates)
  • func (s Client) Close()
  • func (s Client) CreateTopic(context.Context, kafkaadmin.CreateTopicConfig) error
  • func (s Client) DeleteTopic(context.Context, string) error
  • func (s Client) DescribeBrokers(context.Context, bool) (kafkaadmin.BrokerStates, error)
  • func (s Client) DescribeTopics(_ context.Context, names []string) (kafkaadmin.TopicStates, error)
  • func (c Client) DumpBrokerstates() kafkaadmin.BrokerStates
  • func (c Client) DumpMetadata() kafka.Metadata
  • func (s Client) GetConfigs(context.Context, string, []string) (kafkaadmin.ResourceConfigs, error)
  • func (s Client) GetDynamicConfigs(_ context.Context, _ string, names []string) (kafkaadmin.ResourceConfigs, error)
  • func (s Client) ListBrokers(context.Context) ([]int, error)
  • func (c Client) LoadBrokerstates(bs kafkaadmin.BrokerStates)
  • func (c Client) LoadMetadata(md kafka.Metadata)
  • func (s Client) RemoveThrottle(context.Context, kafkaadmin.RemoveThrottleConfig) error
  • func (s Client) SetThrottle(context.Context, kafkaadmin.SetThrottleConfig) error
  • func (s Client) UnderReplicatedTopics(ctx context.Context) (kafkaadmin.TopicStates, error)

Types

type Client

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

StubClient is a stubbed implementation of KafkaAdminClient.

func NewClient

func NewClient() Client

func (Client) AddBrokers

func (c Client) AddBrokers(bs kafkaadmin.BrokerStates)

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) DescribeBrokers

func (s Client) DescribeBrokers(context.Context, bool) (kafkaadmin.BrokerStates, error)

func (Client) DescribeTopics

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

func (Client) DumpBrokerstates

func (c Client) DumpBrokerstates() kafkaadmin.BrokerStates

func (Client) DumpMetadata

func (c Client) DumpMetadata() kafka.Metadata

func (Client) GetConfigs

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

func (Client) GetDynamicConfigs

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

func (Client) ListBrokers

func (s Client) ListBrokers(context.Context) ([]int, error)

func (Client) LoadBrokerstates

func (c Client) LoadBrokerstates(bs kafkaadmin.BrokerStates)

func (Client) LoadMetadata

func (c Client) LoadMetadata(md kafka.Metadata)

func (Client) RemoveThrottle

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

func (Client) SetThrottle

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

func (Client) UnderReplicatedTopics

func (s Client) UnderReplicatedTopics(ctx context.Context) (kafkaadmin.TopicStates, error)