models

type Assignment struct {
	Topic      string `json:"topic"`
	Partitions []int  `json:"partitions"`
}

type BrokerInfo struct {
	ID           int32  `json:"id"`
	Addr         string `json:"addr"`
	IsController bool   `json:"is_controller"`
}

type ClusterInfo struct {
	Brokers []BrokerInfo `json:"brokers"`
}

type Group struct {
	GroupID string `json:"group_id"`
	State   string `json:"state"`
	/// TODO:
	Offsets map[string][]Offset `json:"offsets"`
	// Protocol     string
	// ProtocolType string
	Members []Member `json:"members"`
}

type Member struct {
	Host        string       `json:"host"`
	ID          string       `json:"id"`
	Assignments []Assignment `json:"assignments"`
}

type Message struct {
	Headers   map[string]string
	Timestamp time.Time
	// TODO: remove
	BlockTimestamp time.Time

	Topic     string
	Partition int32
	Offset    int64
	Key       []byte
	Value     []byte
}

type Offset struct {
	Partition      int32 `json:"partition"`
	Offset         int64 `json:"offset"`
	HightWatermark int64 `json:"hight_watermark"`
	Lag            int64 `json:"lag"`
	LogStartOffset int64 `json:"log_start_offset"`
}

type PartitionInfo struct {
	Partition      int32   `json:"partition"`
	HightWatermark int64   `json:"hight_watermark"`
	Leader         int32   `json:"leader"`
	Replicas       int     `json:"replicas"`
	ISR            []int32 `json:"isr"`
	LogEndOffset   int64   `json:"log_end_offset"`
	LogStartOffset int64   `json:"log_start_offset"`
}

type Topic struct {
	Name       string
	Partitions int
	Replicas   int
}

type TopicConfigRecord struct {
	Name      string `json:"name,omitempty"`
	Value     string `json:"value,omitempty"`
	ReadOnly  bool   `json:"read_only,omitempty"`
	Sensitive bool   `json:"sensitive,omitempty"`
}

type TopicConsumerInfo struct {
	Name         string `json:"name,omitempty"`
	MembersCount int    `json:"members_count,omitempty"`
}

type TopicConsumers struct {
	Consumers []TopicConsumerInfo `json:"consumers,omitempty"`
}

type TopicInfo struct {
	TopicName  string              `json:"topic_name,omitempty"`
	Internal   bool                `json:"internal,omitempty"`
	Compacted  bool                `json:"compacted,omitempty"`
	Partitions []PartitionInfo     `json:"partitions,omitempty"`
	Config     []TopicConfigRecord `json:"config,omitempty"`
}