cluster

type GossipConfig struct {
	JoinList                 []string
	Network                  NetworkConfig
	WANMode                  bool
	DistributedStateDelegate memberlist.Delegate
	NodeEventDelegate        membership.Recorder
}

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

type NetworkConfig struct {
	AdvertizedHost string
	AdvertizedPort int
	ListeningPort  int
}

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

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

type NodeRPCServer struct {
}

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