meta

package

v0.0.2 Latest Latest Go to latest Published: Nov 4, 2021 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/peter-evans/kdef

Documentation ¶

Index ¶

type Broker
type Brokers
type PartitionReassignment
type PartitionReassignments
- func (p PartitionReassignments) Sort()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Broker ¶

type Broker struct {
	Id   int32
	Rack string
}

A cluster broker

type Brokers ¶

type Brokers []Broker

An array of Broker

func (Brokers) BrokersByRack ¶

func (b Brokers) BrokersByRack() map[string][]int32

A map of brokers by non-empty broker rack ID

func (Brokers) Ids ¶

func (b Brokers) Ids() []int32

An array of the broker IDs

func (Brokers) Racks ¶

func (b Brokers) Racks() []string

A unique, sorted array of non-empty broker rack IDs

func (Brokers) RacksByBroker ¶

func (b Brokers) RacksByBroker() map[int32]string

A map of racks by broker ID

type PartitionReassignment ¶

type PartitionReassignment struct {
	Partition        int32   `json:"partition"`
	Replicas         []int32 `json:"replicas"`
	AddingReplicas   []int32 `json:"addingReplicas"`
	RemovingReplicas []int32 `json:"removingReplicas"`
}

A partition reassignment

type PartitionReassignments ¶

type PartitionReassignments []PartitionReassignment

An array of PartitionReassignment

func (PartitionReassignments) Sort ¶

func (p PartitionReassignments) Sort()

Sort by partition ID

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL