cluster

type API interface {
	GetClusterTopology(ctx context.Context, opts ...foptions.FacadeOption) (Topology, error)
}

type Broker struct {
	Host       string
	NodeId     int32
	Partitions []Partition
	Port       int32
	Version    string
}

type Partition struct {
	Health      PartitionHealth
	PartitionId int32
	Role        PartitionRole
}

type PartitionHealth string

type PartitionRole string

type Topology struct {
	Brokers               []Broker
	ClusterSize           int32
	GatewayVersion        string
	PartitionsCount       int32
	ReplicationFactor     int32
	LastCompletedChangeId string
}