types

Documentation

Index

• type Broker
• type ConsumerGroup
• type LowHighOffset
• type Offset
• type Partition
• type Topic

Types

type Broker

type Broker struct {
	ID   int
	Host string
	Port int
}

type ConsumerGroup

type ConsumerGroup struct {
	Name string
}

type LowHighOffset

type LowHighOffset struct {
	Low  int64 // the earliest offset
	High int64 // the latest offset
}

type Offset

type Offset struct {
	Topic      string
	Group      string // optional; used only when getting offsets for a consumer group
	Partitions map[int]LowHighOffset
}

type Partition

type Partition struct {
	ID       int
	Leader   int
	Replicas []int
	Isrs     []int // in-sync replicas
}

type Topic

type Topic struct {
	Name       string
	Partitions []Partition
}