cluster

type GossipConfig struct {
	JoinList                 []string
	Network                  NetworkConfig
	DistributedStateDelegate memberlist.Delegate
}

type MultiNode interface {
	Call(id uint64, f func(*grpc.ClientConn) error) error
	Node(cluster string, config RaftConfig) Node
	Shutdown() error
}

type NetworkConfig struct {
	AdvertizedHost string
	AdvertizedPort int
	ListeningPort  int
}

type Node interface {
	Run(context.Context)
	RunFromAppliedIndex(ctx context.Context, idx uint64)
	Shutdown() error
	Apply(context.Context, []byte) error
	Ready() <-chan struct{}
	Call(id uint64, f func(*grpc.ClientConn) error) error
	Index() uint64
}

type NodeConfig struct {
	ID            uint64
	ServiceName   string
	DataDirectory string
	GossipConfig  GossipConfig
	RaftConfig    RaftConfig
}

type NodeRPCServer struct {
}

type RaftConfig struct {
	ExpectedNodeCount         int
	AppliedIndex              uint64
	DisableProposalForwarding bool
	LeaderFunc                func(context.Context) error
	Network                   NetworkConfig
	GetStateSnapshot          func() ([]byte, error)
	CommitApplier             raft.CommitApplier
	SnapshotApplier           raft.SnapshotApplier
	ConfChangeApplier         raft.ConfChangeApplier
	OnNodeRemoved             func(id uint64, leader bool)
}