kafcat

Documentation

Index

• type LeaderInfo
• type OffsetInfo
• type PartitionInfo
• type TopicInfo
  • func GetTopicInfos(client sarama.Client, ...) ([]TopicInfo, error)

Types

type LeaderInfo

type LeaderInfo struct {
	ID      int32
	Address string
}

type OffsetInfo

type OffsetInfo struct {
	Oldest int64
	Newest int64
}

type PartitionInfo

type PartitionInfo struct {
	Leader         *LeaderInfo `yaml:",omitempty"`
	Offsets        *OffsetInfo `yaml:",omitempty"`
	Writable       *bool       `yaml:",omitempty"`
	Replicas       []int32     `yaml:",omitempty,flow"`
	InSyncReplicas []int32     `yaml:",omitempty,flow"`
}

type TopicInfo

type TopicInfo struct {
	Name         string
	Partitions   map[int32]PartitionInfo `yaml:",omitempty"`
	PartitionIds []int32                 `yaml:",omitempty,flow"`
}

func GetTopicInfos

func GetTopicInfos(client sarama.Client, partitions, leader, offsets, writable, isr, replicas bool) ([]TopicInfo, error)