cluster

type AnnouncementMessage struct {
	MessageType string    `json:"message_type"` // "node_announcement"
	NodeID      string    `json:"node_id"`
	NodeAddr    string    `json:"node_addr"`
	Role        NodeRole  `json:"role"`
	Epoch       uint64    `json:"epoch"`
	Term        uint64    `json:"term"`
	Priority    int       `json:"priority"`
	Timestamp   time.Time `json:"timestamp"`
}

type ClusterConfig struct {
	// Node identification
	NodeID   string // Unique identifier for this node
	NodeAddr string // Address other nodes can reach this node at (host:port)

	// Seed nodes for initial discovery
	SeedNodes []string // List of seed node addresses for bootstrapping

	// Election configuration
	ElectionTimeout   time.Duration // Time without heartbeat before starting election (default: 5s)
	HeartbeatInterval time.Duration // Interval between heartbeats (default: 1s)
	MinQuorumSize     int           // Minimum nodes for quorum (typically N/2 + 1)
	Priority          int           // Election priority (higher wins ties)

	// Feature flags for gradual rollout
	EnableAutoFailover bool // Enable automatic failover (default: false)
	EnableQuorumWrites bool // Enable quorum-based writes (default: false)

	// Timeouts and limits
	VoteRequestTimeout time.Duration // Timeout waiting for vote responses (default: 2s)
	MaxElectionRetries int           // Maximum consecutive election failures before backing off
}

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

type DiscoveryResponse struct {
	MessageType string     `json:"message_type"` // "node_list"
	Nodes       []NodeInfo `json:"nodes"`
	Success     bool       `json:"success"`
	Error       string     `json:"error,omitempty"`
}

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

type ElectionState int

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

type NodeInfo struct {
	ID               string    // Unique node identifier
	Addr             string    // Network address (host:port)
	Role             NodeRole  // Current role in cluster
	LastSeen         time.Time // Last heartbeat received
	LastHeartbeatSeq uint64    // Last heartbeat sequence number
	Epoch            uint64    // Cluster generation number
	Term             uint64    // Election term
	LastLSN          uint64    // Last known LSN for this node
	Priority         int       // Election priority
}

type NodeRole int

type VoteRequest struct {
	MessageType string `json:"message_type"` // "vote_request"
	CandidateID string `json:"candidate_id"`
	Term        uint64 `json:"term"`
	LastLSN     uint64 `json:"last_lsn"`
	Epoch       uint64 `json:"epoch"`
	Priority    int    `json:"priority"`
}

type VoteResponse struct {
	MessageType string `json:"message_type"` // "vote_response"
	VoterID     string `json:"voter_id"`
	Term        uint64 `json:"term"`
	VoteGranted bool   `json:"vote_granted"`
	Reason      string `json:"reason,omitempty"`
}