broker

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

type BrokerInfo struct {
	ID        int32            `json:"id"`
	Host      string           `json:"host"`
	Port      int              `json:"port"`
	Status    string           `json:"status"`
	Leader    bool             `json:"leader"`
	Version   string           `json:"version"`
	Uptime    string           `json:"uptime"`
	Resources *BrokerResources `json:"resources,omitempty"`
}

type BrokerResources struct {
	CPUPercent    float64 `json:"cpu_percent"`
	MemoryPercent float64 `json:"memory_percent"`
	DiskPercent   float64 `json:"disk_percent"`
	DiskUsedGB    int64   `json:"disk_used_gb"`
	DiskTotalGB   int64   `json:"disk_total_gb"`
}

type BrokerStatus int

type ClusterInfo struct {
	ClusterID       string `json:"cluster_id"`
	ControllerID    int32  `json:"controller_id"`
	Version         string `json:"version"`
	TotalBrokers    int    `json:"total_brokers"`
	ActiveBrokers   int    `json:"active_brokers"`
	TotalTopics     int    `json:"total_topics"`
	TotalPartitions int    `json:"total_partitions"`
	Uptime          string `json:"uptime"`
}

type Config struct {
	// Broker identity
	BrokerID int32
	Host     string
	Port     int

	// Network ports
	GRPCPort int
	HTTPPort int

	// Storage configuration
	DataDir string

	// Raft configuration
	RaftDataDir string
	RaftPeers   []consensus.Peer

	// Server configuration
	Server *server.Config

	// Security configuration
	Security *security.SecurityConfig

	// Multi-tenancy configuration
	EnableMultiTenancy bool

	// Logging
	LogLevel string
}

type ConsumerGroupInfo struct {
	GroupID     string       `json:"group_id"`
	State       string       `json:"state"`
	Protocol    string       `json:"protocol"`
	Members     []MemberInfo `json:"members"`
	Coordinator int32        `json:"coordinator"`
	TotalLag    int64        `json:"total_lag"`
}

type LagInfo struct {
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
	MemberID  string `json:"member_id"`
	Offset    int64  `json:"offset"`
	EndOffset int64  `json:"end_offset"`
	Lag       int64  `json:"lag"`
}

type MemberInfo struct {
	MemberID   string  `json:"member_id"`
	ClientID   string  `json:"client_id"`
	ClientHost string  `json:"client_host"`
	Partitions []int32 `json:"partitions"`
	JoinedAt   int64   `json:"joined_at"`
}

type MessageInfo struct {
	Offset    int64             `json:"offset"`
	Key       string            `json:"key,omitempty"`
	Value     string            `json:"value"`
	Headers   map[string]string `json:"headers,omitempty"`
	Timestamp int64             `json:"timestamp"`
}

type PartitionInfo struct {
	ID              int32   `json:"id"`
	Leader          int32   `json:"leader"`
	Replicas        []int32 `json:"replicas"`
	ISR             []int32 `json:"isr"`
	BeginningOffset int64   `json:"beginning_offset"`
	EndOffset       int64   `json:"end_offset"`
	MessageCount    int64   `json:"message_count"`
}

type SchemaRegistrationRequest struct {
	Format     string `json:"format"`
	Definition string `json:"definition"`
}

type SchemaResponse struct {
	ID         int32  `json:"id"`
	Subject    string `json:"subject,omitempty"`
	Version    int32  `json:"version,omitempty"`
	Format     string `json:"format,omitempty"`
	Definition string `json:"definition,omitempty"`
}

type TopicResponse struct {
	Name              string          `json:"name"`
	NumPartitions     int             `json:"num_partitions"`
	ReplicationFactor int             `json:"replication_factor"`
	Partitions        []PartitionInfo `json:"partitions,omitempty"`
}