group

type CoordinatorConfig struct {
	// Default session timeout
	DefaultSessionTimeoutMs int32

	// Default rebalance timeout
	DefaultRebalanceTimeoutMs int32

	// Min session timeout
	MinSessionTimeoutMs int32

	// Max session timeout
	MaxSessionTimeoutMs int32

	// Heartbeat check interval
	HeartbeatCheckIntervalMs int32

	// Offset retention time
	OffsetRetentionMs int64
}

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

type GroupError struct {
	Code int16
}

type GroupMetadata struct {
	// Group identifier
	GroupID string

	// Current group state
	State GroupState

	// Protocol type (e.g., "consumer")
	ProtocolType string

	// Protocol name (e.g., "range", "roundrobin")
	ProtocolName string

	// Group leader member ID
	LeaderID string

	// Generation ID (incremented on each rebalance)
	GenerationID int32

	// Members in the group
	Members map[string]*MemberMetadata

	// Timestamp of state change
	StateTimestamp time.Time

	// Rebalance timeout
	RebalanceTimeoutMs int32

	// Session timeout
	SessionTimeoutMs int32
}

type GroupOffsets struct {
	// Group identifier
	GroupID string

	// Offsets by topic and partition
	// Map structure: topic -> partition -> OffsetAndMetadata
	Offsets map[string]map[int32]*OffsetAndMetadata
}

type GroupState string

type HeartbeatRequest struct {
	// Group identifier
	GroupID string

	// Generation ID
	GenerationID int32

	// Member identifier
	MemberID string
}

type HeartbeatResponse struct {
	// Error code
	ErrorCode int16
}

type JoinGroupMember struct {
	MemberID string
	Metadata []byte
}

type JoinGroupRequest struct {
	// Group identifier
	GroupID string

	// Session timeout in milliseconds
	SessionTimeoutMs int32

	// Rebalance timeout in milliseconds
	RebalanceTimeoutMs int32

	// Member identifier (empty for new members)
	MemberID string

	// Client identifier
	ClientID string

	// Protocol type (e.g., "consumer")
	ProtocolType string

	// List of supported protocols and their metadata
	Protocols []ProtocolMetadata
}

type JoinGroupResponse struct {
	// Error code
	ErrorCode int16

	// Generation ID
	GenerationID int32

	// Selected protocol name
	ProtocolName string

	// Assigned member ID
	MemberID string

	// Leader member ID
	LeaderID string

	// All members (only populated for leader)
	Members []JoinGroupMember
}

type LeaveGroupRequest struct {
	// Group identifier
	GroupID string

	// Member identifier
	MemberID string
}

type LeaveGroupResponse struct {
	// Error code
	ErrorCode int16
}

type MemberAssignment struct {
	// Version of assignment
	Version int16

	// Partition assignments by topic
	Partitions map[string][]int32

	// User data (for custom assignment strategies)
	UserData []byte
}

type MemberAssignmentData struct {
	MemberID   string
	Assignment []byte
}

type MemberMetadata struct {
	// Unique member identifier
	MemberID string

	// Client ID for logging
	ClientID string

	// Client host
	ClientHost string

	// Member state
	State MemberState

	// Topics the member is subscribed to
	Subscription []string

	// Current partition assignment
	Assignment *MemberAssignment

	// Protocol metadata provided by member
	ProtocolMetadata []byte

	// Timestamp of last heartbeat
	LastHeartbeat time.Time

	// Session timeout in milliseconds
	SessionTimeoutMs int32

	// Rebalance timeout in milliseconds
	RebalanceTimeoutMs int32

	// Join timestamp
	JoinTime time.Time
}

type MemberState string

type MemberSubscription struct {
	MemberID string
	Topics   []string
}

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

type MetadataStore interface {
	StoreGroupOffset(groupID string, topic string, partition int32, offset *OffsetAndMetadata) error
	FetchGroupOffset(groupID string, topic string, partition int32) (*OffsetAndMetadata, error)
	FetchGroupOffsets(groupID string) (*GroupOffsets, error)
	DeleteGroupOffsets(groupID string) error
}

type OffsetAndMetadata struct {
	// Committed offset
	Offset int64

	// Metadata string (optional)
	Metadata string

	// Commit timestamp
	CommitTime time.Time

	// Expiration timestamp (for cleanup)
	ExpireTime time.Time

	// LeaderEpoch is the epoch of the partition leader when this offset was committed.
	// Used for offset validation - if leader epoch has changed significantly,
	// the committed offset may no longer be valid (truncation may have occurred).
	LeaderEpoch int64
}

type OffsetCommitData struct {
	Offset   int64
	Metadata string
}

type OffsetCommitLog struct {
	GroupID   string
	Topic     string
	Partition int32
	Offset    int64
	Metadata  string
	Timestamp int64
	MemberID  string
}

type OffsetCommitRequest struct {
	// Group identifier
	GroupID string

	// Generation ID (-1 for simple consumer)
	GenerationID int32

	// Member identifier
	MemberID string

	// Offsets to commit by topic and partition
	Offsets map[string]map[int32]OffsetCommitData
}

type OffsetCommitResponse struct {
	// Errors by topic and partition
	Errors map[string]map[int32]int16
}

type OffsetFetchData struct {
	Offset    int64
	Metadata  string
	ErrorCode int16
}

type OffsetFetchRequest struct {
	// Group identifier
	GroupID string

	// Topics and partitions to fetch (nil means all)
	Topics map[string][]int32
}

type OffsetFetchResponse struct {
	// Offsets by topic and partition
	Offsets map[string]map[int32]OffsetFetchData
}

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

type OffsetStorage interface {
	// StoreOffset stores an offset for a group/topic/partition
	StoreOffset(groupID string, topic string, partition int32, offset *OffsetAndMetadata) error

	// FetchOffset fetches an offset for a group/topic/partition
	FetchOffset(groupID string, topic string, partition int32) (*OffsetAndMetadata, error)

	// FetchOffsets fetches all offsets for a group
	FetchOffsets(groupID string) (*GroupOffsets, error)

	// DeleteOffsets deletes offsets for a group
	DeleteOffsets(groupID string) error
}

type PartitionAssignor interface {
	Name() string
	Assign(members []MemberSubscription, partitions []TopicPartition) map[string][]TopicPartition
}

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

type ProtocolMetadata struct {
	// Protocol name (e.g., "range", "roundrobin")
	Name string

	// Protocol-specific metadata
	Metadata []byte
}

type RangeAssignor struct{}

type RoundRobinAssignor struct{}

type StickyAssignor struct{}

type SyncGroupRequest struct {
	// Group identifier
	GroupID string

	// Generation ID
	GenerationID int32

	// Member identifier
	MemberID string

	// Assignments (only provided by leader)
	Assignments []MemberAssignmentData
}

type SyncGroupResponse struct {
	// Error code
	ErrorCode int16

	// Member assignment
	Assignment []byte
}

type TopicPartition struct {
	Topic     string
	Partition int32
}