gen

Documentation

Index

• func ReassignPartitionsToJson(network, address string, req Req) (string, error)
• type Body
• type BodyPartition
• type Gen
  • func (g *Gen) Reassign(network, address string, req Req) (Body, error)
  • func (g *Gen) ReassignToJson(network, address string, req Req) (string, error)
• type Req

Functions

func ReassignPartitionsToJson

func ReassignPartitionsToJson(network, address string, req Req) (string, error)

Types

type Body

type Body struct {
	Version    int             `json:"version"`
	Partitions []BodyPartition `json:"partitions"`
}

type BodyPartition

type BodyPartition struct {
	Topic     string `json:"topic"`
	Partition int    `json:"partition"`
	Replicas  []int  `json:"replicas"`
}

type Gen

type Gen struct{}

func (*Gen) Reassign

func (g *Gen) Reassign(network, address string, req Req) (Body, error)

func (*Gen) ReassignToJson

func (g *Gen) ReassignToJson(network, address string, req Req) (string, error)

type Req

type Req struct {
	Version   int    `json:"version"`
	Topic     string `json:"topic"`
	Partition int    `json:"partition"`
	Replica   int    `json:"replica"`
}