quorum

type Config struct {
	// Address which other nodes can reach this one from
	IP string
	// Port to expose HTTP API on
	Port string

	// Config to pass into Memberlist
	MemberlistConfig *memberlist.Config

	// Directory to store persistent raft data
	RaftDir string
	// Port for the raft library to listen on
	RaftPort string
	// Pool size of the underlying TCP Transport layer
	RaftPoolSize int
	// Timeout for each request of the underlying TCP Transport layer
	RaftTimeout time.Duration
	// Number of snapshots to retain
	RaftRetain int
	// Config to pass into Raft
	RaftConfig *raft.Config

	// Interface that will return the set of peers to join. This is also
	// used when trying to rejoin the cluster when we have been removed
	// or we are in split brain.
	PeerFinder PeerFinder

	// If the ratio of memberlist members to raft members is less than or
	// equal to this ratio, we are in split-brain. Typical this is set to
	// 0.5 which allows a majority of nodes to keep operating.
	QuorumRatio float64

	// How often to check the state of the quorum cluster and detect
	// split-brain
	CheckStatePeriod time.Duration
	// How often the leader checks membership info and removes dead servers
	// from the raft configuration
	LeaderLoopPeriod time.Duration
	// Timeout for requests to the cluster using the HTTP API
	APIRequestTimeout time.Duration
	// How long after a node is dead in memberlist do we prune it from the
	// raft group
	PruneDuration time.Duration

	// User specified FSM for the underlying raft layer
	FSM raft.FSM
}

type DefaultPeerFinder struct {
	InitialPeerSet []string
}

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

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

type IdMap map[string]string

type JoinRequest struct {
	ServerID      string `json:"server_id"`
	ServerAddress string `json:"server_address"`
}

type JoinResponse struct {
	OK     bool   `json:"ok"`
	Leader string `json:"leader"`
}

type LeaveRequest struct {
	ServerID string `json:"server_id"`
}

type LeaveResponse struct {
	OK bool `json:"ok"`
}

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

type PeerFinder interface {
	Peers() []string
}

type Population struct {
	Memberlist int64
	Raft       int64
}

type PruneMap map[string]time.Time

type QuorumNode struct {
	Config *Config

	Memberlist *memberlist.Memberlist
	Raft       *raft.Raft

	APIClient   *HTTPClient
	JoinRequest *JoinRequest

	Population *atomic.Value
	SplitBrain *int32
	// contains filtered or unexported fields
}