main.go

package main

import (
	"fmt"
	"log"
	"net/http"
	"os"
)

func main() {
	// load config
	config, err := LoadConfig("config.yaml")
	if err != nil {
		log.Fatalf("failed to load config: %v", err)
	}

	// get this node's own address from environment
	id := os.Getenv("NODE_ID")
	if id == "" {
		log.Fatal("NODE_ID environment variable is required")
	}

	// boot the node
	node := NewNode(id, config)

	// register HTTP endpoints
	http.HandleFunc("/append-entries", node.handleAppendEntries)
	http.HandleFunc("/request-vote", node.handleRequestVote)
	http.HandleFunc("/write", node.handleWrite)
	http.HandleFunc("/read", node.handleRead)

	// start background goroutines
	go node.runElectionTimeout()

	listenAddr := os.Getenv("LISTEN_ADDR")
	if listenAddr == "" {
		log.Fatal("LISTEN_ADDR environment variable is required")
	}
	fmt.Printf("node %s listening on %s\n", id, listenAddr)
	if err := http.ListenAndServe(listenAddr, nil); err != nil {
		log.Fatalf("server failed: %v", err)
	}
}