admin

Documentation

Index

• Variables
• type Admin
  • func NewAdmin(config *config.Configuration) *Admin
  • func (a *Admin) AddConfig(ctx context.Context, topic, key, value string) error
  • func (a *Admin) ConfigureTopic(ctx context.Context, topic string, config map[string]string) error
  • func (a *Admin) CreateTopic(ctx context.Context, topicName string, partitionsCount int32, ...) error
  • func (a *Admin) DeleteGroup(group string) error
  • func (a *Admin) DeleteTopic(ctx context.Context, topic string) error
  • func (a *Admin) DescribeGroup(ctx context.Context, group string) models.Group
  • func (a *Admin) DescribeTopic(ctx context.Context, topic string) (models.TopicInfo, error)
  • func (a *Admin) GetClusterInfo(ctx context.Context) (models.ClusterInfo, error)
  • func (a *Admin) GetGroupsList(ctx context.Context) ([]string, error)
  • func (a *Admin) GetOffsetByTime(ctx context.Context, partition int32, topic string, ts time.Time) (int64, error)
  • func (a *Admin) GetOffsetsByTime(ctx context.Context, topic string, ts time.Time) ([]int64, error)
  • func (a *Admin) GetTopicConsumers(ctx context.Context, topic string) ([]models.TopicConsumerInfo, error)
  • func (a *Admin) ListTopics(ctx context.Context) ([]models.Topic, error)
  • func (a *Admin) UpdateTopic(ctx context.Context, topic string, partitionsCount int32, ...) error
• type TopicConfig

Variables

var ErrNoBrokers = errors.New("Empty brokers list")

Types

type Admin

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

func NewAdmin

func NewAdmin(config *config.Configuration) *Admin

func (*Admin) AddConfig

func (a *Admin) AddConfig(ctx context.Context, topic, key, value string) error

func (*Admin) ConfigureTopic

func (a *Admin) ConfigureTopic(ctx context.Context, topic string, config map[string]string) error

func (*Admin) CreateTopic

func (a *Admin) CreateTopic(ctx context.Context,
	topicName string,
	partitionsCount int32,
	replicationFactor int16,
	cleanupPolicy string,
) error

func (*Admin) DeleteGroup

func (a *Admin) DeleteGroup(group string) error

func (*Admin) DeleteTopic

func (a *Admin) DeleteTopic(ctx context.Context, topic string) error

func (*Admin) DescribeGroup

func (a *Admin) DescribeGroup(ctx context.Context, group string) models.Group

func (*Admin) DescribeTopic

func (a *Admin) DescribeTopic(ctx context.Context, topic string) (models.TopicInfo, error)

func (*Admin) GetClusterInfo

func (a *Admin) GetClusterInfo(ctx context.Context) (models.ClusterInfo, error)

func (*Admin) GetGroupsList

func (a *Admin) GetGroupsList(ctx context.Context) ([]string, error)

func (*Admin) GetOffsetByTime

func (a *Admin) GetOffsetByTime(ctx context.Context, partition int32, topic string, ts time.Time) (int64, error)

func (*Admin) GetOffsetsByTime

func (a *Admin) GetOffsetsByTime(ctx context.Context, topic string, ts time.Time) ([]int64, error)

func (*Admin) GetTopicConsumers

func (a *Admin) GetTopicConsumers(ctx context.Context, topic string) ([]models.TopicConsumerInfo, error)

func (*Admin) ListTopics

func (a *Admin) ListTopics(ctx context.Context) ([]models.Topic, error)

func (*Admin) UpdateTopic

func (a *Admin) UpdateTopic(ctx context.Context, topic string, partitionsCount int32, assignments [][]int32) error

type TopicConfig

type TopicConfig map[string]sarama.IncrementalAlterConfigsEntry