funk

type Cluster interface {
	// NodeID is the local cluster node's ID
	NodeID() string

	// Name returns the cluster's name
	Name() string

	// Start launches the cluster, ie joins a Serf cluster and announces its
	// presence
	Start() error

	// Stop stops the cluster
	Stop()

	// Role is the current role of the node
	Role() NodeRole

	// State is the current cluster state
	State() NodeState

	// Events returns an event channel for the cluster. The channel will
	// be closed when the cluster is stopped. Events are for information only
	Events() <-chan Event

	// SetEndpoint registers an endpoint on the local node
	SetEndpoint(name string, endpoint string)

	// Leader returns the node ID of the leader in the cluster. If no leader
	// is currently elected it will return a blank string.
	Leader() string

	// Nodes returns a list of the node IDs of each member
	Nodes() []string

	// GetEndpoint returns the endpoint for a particular node. If the node
	// or endpoint isn't found it will return a blank. The endpoint is
	// retrieved from the Serf cluster. Note that there's no guarantee
	// that the node will be responding on that endpoint.
	GetEndpoint(nodeID string, endpointName string) string
}

type Event struct {
	State NodeState // State is the state of the local cluster node
	Role  NodeRole  // Role is the role (leader, follower...) of the local cluster node
}

type GRPCServerParameters struct {
	Endpoint string `kong:"help='Server endpoint'"`
	TLS      bool   `kong:"help='Enable TLS'"`
	CertFile string `kong:"help='Certificate file',type='existingfile'"`
	KeyFile  string `kong:"help='Certificate key file',type='existingfile'"`
}

type LeaderChangedEvent struct {
}

type LeaderLostEvent struct {
}

type LivenessChecker interface {
	// Add adds a new new check to the list.
	Add(id string, endpoint string)

	// Remove removes a single checker
	Remove(id string)

	// DeadEvents returns the event channel. The ID from the Add method is
	// echoed on this channel when a client stops responding.
	DeadEvents() <-chan string

	// AliveEvents returns an event channel for alive events.
	AliveEvents() <-chan string

	// Clear removes all endpoint checks.
	Clear()

	// Shutdown shuts down the checker and closes the event channel. The
	// checker will no longer be in an usable state after this.
	Shutdown()
}

type LocalLivenessEndpoint interface {
	Stop()
}

type LocalNodeStoppedEvent struct {
}

type LogMessage struct {
	MessageType LogMessageType
	AckEndpoint string
	Index       uint64
	Data        []byte
}

type LogMessageType byte

type NodeAddedEvent struct {
}

type NodeEvent struct {
	Event SerfEventType
	Node  SerfMember
}

type NodeRemovedEvent struct {
}

type NodeRetiredEvent struct {
}

type NodeRole int32

type NodeState int32

type Parameters struct {
	AutoJoin         bool                 `kong:"help='Auto join via SerfEvents',default='true'"`
	Name             string               `kong:"help='Cluster name',default='clusterfunk'"`
	Interface        string               `kong:"help='Interface address for services'"`
	Verbose          bool                 `kong:"help='Verbose logging for Serf and Raft'"`
	NodeID           string               `kong:"help='Node ID for Serf and Raft'"`
	ZeroConf         bool                 `kong:"help='Zero-conf startup',default='true'"`
	NonVoting        bool                 `kong:"help='Nonvoting node',default='false'"`
	NonMember        bool                 `kong:"help='Non-member',default='false'"`
	LivenessInterval time.Duration        `kong:"help='Liveness checker intervals',default='150ms'"`
	LivenessRetries  int                  `kong:"help='Number of retries for liveness checks',default='3'"`
	LivenessEndpoint string               `kong:"help='Liveness UDP endpoint'"`
	AckTimeout       time.Duration        `kong:"help='Ack timeout for nodes in the cluster',default='500ms'"`
	Metrics          string               `kong:"help='Metrics sink to use',enum='blackhole,prometheus',default='prometheus'"`
	Raft             RaftParameters       `kong:"embed,prefix='raft-'"`
	Serf             SerfParameters       `kong:"embed,prefix='serf-'"`
	Management       GRPCServerParameters `kong:"embed,prefix='management-'"`
	LeaderEndpoint   string               // This isn't a parameter, it's set by the service
}

type RaftEventType int

type RaftNode struct {
	Nodes toolbox.StringSet
	// contains filtered or unexported fields
}

type RaftParameters struct {
	RaftEndpoint string `kong:"help='Endpoint for Raft',default=''"`
	DiskStore    bool   `kong:"help='Disk-based store',default='false'"`
	Bootstrap    bool   `kong:"help='Bootstrap a new Raft cluster',default='false'"`
	Verbose      bool   `kong:"help='Verbose Raft logging',default='false'"`
	DebugLog     bool   `kong:"help='Show debug log messages for Raft',default='false'"`
}

type SerfEventType int

type SerfMember struct {
	NodeID string
	State  string
	Tags   map[string]string
}

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

type SerfParameters struct {
	Endpoint    string `kong:"help='Endpoint for Serf',default=''"`
	JoinAddress string `kong:"help='Join address and port for Serf cluster'"`
	Verbose     bool   `kong:"help='Verbose logging for Serf'"`
}