kafka

type APIVersion struct {
	Name       string
	Key        int16
	MaxVersion int16
}

type Broker struct {
	Address            string
	ID                 int32
	GroupsCoordinating int64
	LeaderReplicas     int64
	PeerReplicas       int64
	TotalReplicas      int64
	MigratingReplicas  int64
	Overload           int64
}

type BrokerReplicas struct {
	BrokerID     int32
	ReplicaCount int32
}

type ClientFlags struct {
	Exact   bool
	Verbose bool
	Context string
	Version string
}

type GroupFlags struct {
	Describe bool
	Lag      bool
	Topic    bool
}

type GroupPartitionMeta struct {
	Group            string
	GroupOffset      int64
	Lag              int64
	GroupCoordinator string
}

type GroupTopicOffsetMeta struct {
	TopicPartitionMeta
	GroupPartitionMeta
}

type GrpLag struct {
	// contains filtered or unexported fields
}

type LagFlags struct {
	Group bool
	Topic bool
}

type MSGFlags struct {
	Partitions   []string
	Partition    int32
	Offset       int64
	Tail         int64
	TailTouched  bool
	Follow       bool
	FromTime     string
	ToTime       string
	LastDuration string
	JSONFilters  []string
}

type MetricFlags struct {
	Broker    bool
	Intervals int
	Seconds   int
}

type OffsetDetail struct {
	Topic             string
	Group             string
	Partition         int32
	TopicOffsetOldest int64
	TopicOffsetNewest int64
	GroupOffset       int64
	Lag               int64
}

type OffsetDetails struct {
	Details        []OffsetDetail
	IncludesGroups bool
}

type OffsetRangeMap struct {
	Ranges map[string]map[int32][2]int64
}

type OpsCreateFlags struct {
	DryRun            bool
	PartitionCount    int32
	ReplicationFactor int16
}

type OpsOffsetFlags struct {
	AllParts       bool
	OffsetNewest   bool
	OffsetOldest   bool
	ShowGroups     bool
	Delete         bool
	Group          string
	Partitions     []int32
	Offset         int64
	RelativeOffset int64
}

type OpsReplicaFlags struct {
	DryRun            bool
	AllParts          bool
	PreserveLeader    bool
	Brokers           []int32
	Partitions        []int32
	ReplicationFactor int
}

type PREFlags struct {
	AllTopics  bool
	Partition  int32
	Partitions []string
}

type PREList struct {
	Version    int            `json:"version"`
	Partitions []PREPartition `json:"partitions"`
}

type PREPartition struct {
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
}

type PRESummary struct {
	Topics   []string
	PRECount map[string]uint32
}

type PRETopicMeta struct {
	Partitions []kafkactl.TopicMeta
}

type PartitionLag struct {
	Group     string
	Topic     string
	Partition int32
	Host      string
	Member    string
	Offset    int64
	Lag       int64
}

type RAPartList struct {
	Version    int           `json:"version"`
	Partitions []RAPartition `json:"partitions"`
}

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

type ReplicaDetails struct {
	TopicMetadata []kafkactl.TopicMeta
}

type SendFlags struct {
	Key           string
	Value         string
	Delimiter     string
	DelimiterUsed bool
	Partitions    []string
	Partition     int32
	AllPartitions bool
	FromStdin     bool
	NoSplit       bool
	LineSplit     string
}

type TopicConfig struct {
	Topic     string
	Config    string
	Value     string
	ReadOnly  bool
	Default   bool
	Sensitive bool
}

type TopicConfigFlags struct {
	Config         string
	Value          string
	Configs        []string
	GetNonDefaults bool
	SetDefault     bool
}

type TopicFlags struct {
	FindPRE  bool
	Describe bool
	Group    bool
	Lag      bool
	Leaders  []int32
}

type TopicPartitionMeta struct {
	Topic       string
	Partition   int32
	TopicOffset int64
	TopicLeader int32
}

type TotalLag struct {
	Group    string
	Topic    string
	TotalLag int64
}