cluster

type Cluster interface {
	// LocateNode find the node given a UUID.
	LocateNode(string) (api.Node, error)

	// AddEventListener adds an event listener and exposes cluster events.
	AddEventListener(ClusterListener) error

	// Enumerate lists all the nodes in the cluster.
	Enumerate() (api.Cluster, error)

	// Remove node(s) from the cluster permanently.
	Remove(nodes []api.Node) error

	// Shutdown node(s) or the entire cluster.
	Shutdown(cluster bool, nodes []api.Node) error

	// Start starts the cluster manager and state machine.
	// It also causes this node to join the cluster.
	Start() error

	ClusterData
}

type ClusterData interface {
	// Update node data associated with this node
	UpdateData(dataKey string, value interface{})

	// Get data associated with all nodes.
	// Key is the node id
	GetData() map[string]*api.Node

	// Enables cluster data updates to be sent to listeners
	EnableUpdates()

	// Disables cluster data updates to be sent to listeners
	DisableUpdates()

	// Status of nodes according to gossip
	GetState() *ClusterState
}

type ClusterListener interface {
	// String returns a string representation of this listener.
	String() string

	// ClusterInit is called when a brand new cluster is initialized.
	ClusterInit(self *api.Node, db *Database) error

	// Init is called when this node is joining an existing cluster for the first time.
	Init(self *api.Node, db *Database) error

	// CleanupInit is called when Init failed.
	CleanupInit(self *api.Node, db *Database) error

	// Join is called when this node is joining an existing cluster.
	Join(self *api.Node, db *Database) error

	// Add is called when a new node joins the cluster.
	Add(node *api.Node) error

	// Remove is called when a node leaves the cluster
	Remove(node *api.Node) error

	// Update is called when a node status changes significantly
	// in the cluster changes.
	Update(node *api.Node) error

	// Leave is called when this node leaves the cluster.
	Leave(node *api.Node) error
}

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

type ClusterState struct {
	History    []*types.GossipSessionInfo
	NodeStatus []types.NodeValue
}

type Config struct {
	ClusterId string
	NodeId    string
	MgtIface  string
	DataIface string
}

type Database struct {
	Status      api.Status
	Id          string
	NodeEntries map[string]NodeEntry
}

type NodeEntry struct {
	Id        string
	Ip        string
	GenNumber uint64
}