raft

type ApplyMsg struct {
	Index    uint64
	Term     uint64
	Entry    internal.LogEntry
	ResultCh chan error
}

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

type CandidateStatus struct {
	NodeID           string
	Term             uint64
	VotesGranted     int
	VotesDenied      int
	VotesNeeded      int
	TotalVotes       int
	ElectionStarted  time.Time
	ElectionDuration time.Duration
	ElectionTimeout  time.Duration
	TimeRemaining    time.Duration
}

type Config struct {
	// Node identification
	NodeID    string `json:"node_id"    yaml:"node_id"`
	ClusterID string `json:"cluster_id" yaml:"cluster_id"`

	// Timing parameters
	ElectionTimeoutMin time.Duration `json:"election_timeout_min" yaml:"election_timeout_min"`
	ElectionTimeoutMax time.Duration `json:"election_timeout_max" yaml:"election_timeout_max"`
	HeartbeatInterval  time.Duration `json:"heartbeat_interval"   yaml:"heartbeat_interval"`
	HeartbeatTimeout   time.Duration `json:"heartbeat_timeout"    yaml:"heartbeat_timeout"`
	ApplyInterval      time.Duration `json:"apply_interval"       yaml:"apply_interval"`
	CommitTimeout      time.Duration `json:"commit_timeout"       yaml:"commit_timeout"`

	// Snapshot configuration
	SnapshotInterval  time.Duration `json:"snapshot_interval"  yaml:"snapshot_interval"`
	SnapshotThreshold uint64        `json:"snapshot_threshold" yaml:"snapshot_threshold"`
	EnableSnapshots   bool          `json:"enable_snapshots"   yaml:"enable_snapshots"`

	// Replication configuration
	MaxAppendEntries     int           `json:"max_append_entries"     yaml:"max_append_entries"`
	ReplicationBatchSize int           `json:"replication_batch_size" yaml:"replication_batch_size"`
	ReplicationTimeout   time.Duration `json:"replication_timeout"    yaml:"replication_timeout"`
	EnablePipeline       bool          `json:"enable_pipeline"        yaml:"enable_pipeline"`

	// Performance tuning
	MaxInflightReplications int           `json:"max_inflight_replications" yaml:"max_inflight_replications"`
	BatchInterval           time.Duration `json:"batch_interval"            yaml:"batch_interval"`
	MaxBatchSize            int           `json:"max_batch_size"            yaml:"max_batch_size"`

	// Log configuration
	MaxLogEntries        uint64 `json:"max_log_entries"        yaml:"max_log_entries"`
	LogCacheSize         int    `json:"log_cache_size"         yaml:"log_cache_size"`
	LogCompactionEnabled bool   `json:"log_compaction_enabled" yaml:"log_compaction_enabled"`
	TrailingLogs         uint64 `json:"trailing_logs"          yaml:"trailing_logs"`

	// Safety
	PreVoteEnabled bool `json:"pre_vote_enabled" yaml:"pre_vote_enabled"`
	CheckQuorum    bool `json:"check_quorum"     yaml:"check_quorum"`

	// Observability
	EnableMetrics bool `json:"enable_metrics" yaml:"enable_metrics"`
	EnableTracing bool `json:"enable_tracing" yaml:"enable_tracing"`
}

type ConfigChangeMsg struct {
	Type     ConfigChangeType
	NodeID   string
	Address  string
	Port     int
	ResultCh chan error
}

type ConfigChangeType int

type ElectionResult struct {
	Won          bool
	Term         uint64
	VotesFor     int
	VotesAgainst int
	VotesNeeded  int
}

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

type FollowerStatus struct {
	NodeID             string
	CurrentLeader      string
	LastHeartbeat      time.Time
	TimeSinceHeartbeat time.Duration
	ElectionTimeout    time.Duration
	TimeUntilTimeout   time.Duration
	Healthy            bool
}

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

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

type LogEntryBatch struct {
	Entries    []internal.LogEntry
	StartIndex uint64
	EndIndex   uint64
}

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

type PeerState struct {
	ID            string
	Address       string
	Port          int
	NextIndex     uint64
	MatchIndex    uint64
	LastContact   time.Time
	Replicating   bool
	ReplicationMu sync.Mutex
}

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

type ReplicationResult struct {
	Success    bool
	MatchIndex uint64
	NodeID     string
	Term       uint64
	Error      error
}

type ReplicationState struct {
	NextIndex     uint64
	MatchIndex    uint64
	LastContact   time.Time
	Inflight      int
	LastHeartbeat time.Time
}

type ReplicationStatus struct {
	PeerID        string
	NextIndex     uint64
	MatchIndex    uint64
	Lag           uint64
	LastHeartbeat time.Time
	Healthy       bool
}

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

type SnapshotManagerConfig struct {
	NodeID            string
	SnapshotInterval  time.Duration
	SnapshotThreshold uint64
}

type SnapshotMeta struct {
	Index    uint64
	Term     uint64
	Size     int64
	Checksum string
	Created  time.Time
}

type SnapshotMsg struct {
	Index    uint64
	Term     uint64
	ResultCh chan error
}

type State int

type VoteResponse struct {
	Term        uint64
	VoteGranted bool
	NodeID      string
}