Metadata

Documentation

Index

• func NewRequest(topics []string) *api.Request
• type Broker
  • func (b *Broker) Addr() string
  • func (b *Broker) String() string
• type PartitionMetadata
• type Request
• type Response
  • func (r *Response) Broker(id int32) *Broker
  • func (r *Response) Leaders(topic string) map[int32]*Broker
  • func (r *Response) Partitions(topic string) map[int32]*PartitionMetadata
• type TopicMetadata

Functions

func NewRequest

func NewRequest(topics []string) *api.Request

Types

type Broker

type Broker struct {
	NodeId int32
	Host   string
	Port   int32
	Rack   string
}

func (*Broker) Addr

func (b *Broker) Addr() string

func (*Broker) String

func (b *Broker) String() string

type PartitionMetadata

type PartitionMetadata struct {
	ErrorCode       int16
	Partition       int32
	Leader          int32
	Replicas        []int32
	Isr             []int32
	OfflineReplicas []int32
}

type Request

type Request struct {
	Topics                 []string
	AllowAutoTopicCreation bool
}

type Response

type Response struct {
	ThrottleTimeMs int32
	Brokers        []Broker
	ClusterId      string
	ControllerId   int32
	TopicMetadata  []TopicMetadata
}

func (*Response) Broker

func (r *Response) Broker(id int32) *Broker

func (*Response) Leaders

func (r *Response) Leaders(topic string) map[int32]*Broker

func (*Response) Partitions

func (r *Response) Partitions(topic string) map[int32]*PartitionMetadata

type TopicMetadata

type TopicMetadata struct {
	ErrorCode         int16
	Topic             string
	IsInternal        bool
	PartitionMetadata []PartitionMetadata
}