describes

Documentation

Index

• func DescribeAllTopics(network, address string) (table.Writer, error)
• func DescribeBrokers(network, address string) (table.Writer, error)
• type Partition
• type Topic
• type TopicsOverview
  • func NewTopics(network, address string) (*TopicsOverview, error)
  • func (t *TopicsOverview) All() (table.Writer, error)
  • func (t *TopicsOverview) GetAllTopics() ([]Topic, error)

Functions

func DescribeAllTopics

func DescribeAllTopics(network, address string) (table.Writer, error)

func DescribeBrokers

func DescribeBrokers(network, address string) (table.Writer, error)

Types

type Partition

type Partition struct {
	Id       int
	Leader   kafka.Broker
	Replicas []kafka.Broker
	Isr      []kafka.Broker
}

type Topic

type Topic struct {
	Topic      string
	Partitions []Partition
}

type TopicsOverview

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

func NewTopics

func NewTopics(network, address string) (*TopicsOverview, error)

func (*TopicsOverview) All

func (t *TopicsOverview) All() (table.Writer, error)

func (*TopicsOverview) GetAllTopics

func (t *TopicsOverview) GetAllTopics() ([]Topic, error)