type RequestVoteArgs struct {
    Term         int  // 候補者の任期
    CandidateID  int  // 候補者のID
    LastLogIndex int  // 最後のログインデックス
    LastLogTerm  int  // 最後のログの任期
}

type AppendEntriesArgs struct {
    Term         int        // リーダーの任期
    LeaderID     int        // リーダーのID
    PrevLogIndex int        // 直前のログインデックス
    PrevLogTerm  int        // 直前のログの任期
    Entries      []LogEntry // 追加するエントリ
    LeaderCommit int        // リーダーのコミットインデックス
}

package main

import (
    "github.com/example/raft/pkg/raft"
    "github.com/example/raft/pkg/rpc"
)

func main() {
    // トランスポート層を作成
    transport := rpc.NewInMemoryTransport()

    // クラスタを作成（5ノード）
    cluster := raft.NewCluster(5, transport, nil)

    // 各ノードをトランスポートに登録
    for _, node := range cluster.GetNodes() {
        transport.RegisterNode(node)
    }

    // クラスタを起動
    cluster.Start()

    // リーダーを取得してコマンドを提案
    leader := cluster.GetLeader()
    if leader != nil {
        leader.Propose("SET key value")
    }

    // クラスタを停止
    cluster.Stop()
}

config := &raft.Config{
    // 選挙タイムアウト: リーダーからのハートビートが途絶えた際に
    // フォロワーが候補者に移行するまでの待ち時間（ランダムに選択される範囲）
    ElectionTimeoutMin: 150 * time.Millisecond,
    ElectionTimeoutMax: 300 * time.Millisecond,

    // ハートビート間隔: リーダーがフォロワーに生存を通知する間隔
    // 選挙タイムアウトより十分短くする必要がある
    HeartbeatInterval:  50 * time.Millisecond,
}

cluster := raft.NewCluster(5, transport, config)

type Node struct {
    // 永続化される状態
    currentTerm int        // 現在の任期
    votedFor    int        // 投票先
    log         *Log       // ログエントリ

    // 揮発性の状態
    commitIndex int        // コミット済みインデックス
    lastApplied int        // 適用済みインデックス

    // リーダーのみ
    nextIndex   map[int]int  // 次に送るインデックス
    matchIndex  map[int]int  // 複製済みインデックス
}

type Log struct {
    entries []LogEntry
}

type LogEntry struct {
    Term    int         // 作成された任期
    Index   int         // ログ内の位置
    Command interface{} // コマンド
}