cluster

Documentation

Index

• Constants
• func Broadcast(config config.NetworkConfig, req *Request)
• func GetActivePeers() ([]string, map[string]*Node)
• func GetLeader() string
• func GetLocalActivePeersCount() int
• func GetLocalPeers() map[string]*Node
• func GetPeers() []string
• func GetRaftStatus() string
• func GetStats() map[string]string
• func InitAPI()
• func Open() (err error)
• func RestoreClusterState()
• func ServeMulticastDiscovery(config config.NetworkConfig, h func(*net.UDPAddr, int, []byte), ...)
• func SnapshotClusterState()
• type ClusterAPI
• type ClusterFSM
  • func NewFSM() *ClusterFSM
  • func (f *ClusterFSM) Apply(l *raft.Log) interface{}
  • func (f *ClusterFSM) GetClusterMetadata() Metadata
  • func (f *ClusterFSM) Restore(rc io.ReadCloser) error
  • func (f *ClusterFSM) Snapshot() (raft.FSMSnapshot, error)
• type Command
• type Metadata
  • func GetClusterReadonlyMetadata() Metadata
• type Node
  • func (v *Node) GetRPCAddr() *net.TCPAddr
• type NullWriter
  • func (NullWriter) Write([]byte) (int, error)
• type RaftModule
  • func New(config *config.ClusterConfig) *RaftModule
  • func (s *RaftModule) Down(raftAddr, rpcAddr string) error
  • func (s *RaftModule) ExecuteCommand(c *Command) error
  • func (s *RaftModule) Leave(raftAddr, rpcAddr string) error
  • func (s *RaftModule) Up(node *Node) error
• type Request

Constants

const EVENT_LEADER_DISCOVERY = "LEADER_DISCOVERY"

const EVENT_LEADER_ECHO = "LEADER_ECHO"

const EVENT_LEADER_NOMINATE = "LEADER_NOMINATE"

const EVENT_LEADER_READY = "LEADER_READY"

const NodeDown string = "NODE_DOWN"

const NodeLeave string = "NODE_LEAVE"

const NodeUp string = "NODE_UP"

Functions

func Broadcast

func Broadcast(config config.NetworkConfig, req *Request)

send a Broadcast message to network to discovery the cluster

func GetActivePeers

func GetActivePeers() ([]string, map[string]*Node)

func GetLeader

func GetLeader() string

func GetLocalActivePeersCount

func GetLocalActivePeersCount() int

func GetLocalPeers

func GetLocalPeers() map[string]*Node

func GetPeers

func GetPeers() []string

func GetRaftStatus

func GetRaftStatus() string

func GetStats

func GetStats() map[string]string

func InitAPI

func InitAPI()

func Open

func Open() (err error)

func RestoreClusterState

func RestoreClusterState()

RestorePersistID will take the snapshot and restore to id seeds

func ServeMulticastDiscovery

func ServeMulticastDiscovery(config config.NetworkConfig, h func(*net.UDPAddr, int, []byte), signal chan bool)

func SnapshotClusterState

func SnapshotClusterState()

SnapshotPersistID will make a snapshot and persist id stats to disk

Types

type ClusterAPI

type ClusterAPI struct {
	api.Handler
}

type ClusterFSM

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

func NewFSM

func NewFSM() *ClusterFSM

func (*ClusterFSM) Apply

func (f *ClusterFSM) Apply(l *raft.Log) interface{}

Apply applies a Raft log entry to the key-value store.

func (*ClusterFSM) GetClusterMetadata

func (f *ClusterFSM) GetClusterMetadata() Metadata

func (*ClusterFSM) Restore

func (f *ClusterFSM) Restore(rc io.ReadCloser) error

Restore stores the key-value store to a previous state.

func (*ClusterFSM) Snapshot

func (f *ClusterFSM) Snapshot() (raft.FSMSnapshot, error)

Snapshot returns a snapshot of the key-value store.

type Command

type Command struct {
	Op    string `json:"op,omitempty,omitempty"`
	Key   string `json:"key,omitempty,omitempty"`
	Value string `json:"value,omitempty,omitempty"`
}

type Metadata

type Metadata struct {
	KnownNodesRPCEndpoint map[string]*Node `json:"known_nodes"`
}

func GetClusterReadonlyMetadata

func GetClusterReadonlyMetadata() Metadata

type Node

type Node struct {
	ID   string `json:"id,omitempty"`
	Name string `json:"name,omitempty"`

	ClusterName string `json:"cluster,omitempty"`
	Token       string `json:"token,omitempty"`

	//RaftEndpoint string `json:"raft_endpoint,omitempty"`
	APIEndpoint string `json:"api_endpoint,omitempty"`
	RPCEndpoint string `json:"rpc_endpoint,omitempty"`

	Active bool `json:"active"`

	StartTime int64 `json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) GetRPCAddr

func (v *Node) GetRPCAddr() *net.TCPAddr

type NullWriter

type NullWriter int

func (NullWriter) Write

func (NullWriter) Write([]byte) (int, error)

type RaftModule

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

func New

func New(config *config.ClusterConfig) *RaftModule

func (*RaftModule) Down

func (s *RaftModule) Down(raftAddr, rpcAddr string) error

func (*RaftModule) ExecuteCommand

func (s *RaftModule) ExecuteCommand(c *Command) error

func (*RaftModule) Leave

func (s *RaftModule) Leave(raftAddr, rpcAddr string) error

func (*RaftModule) Up

func (s *RaftModule) Up(node *Node) error

Up joins a node, located at addr, to this store. The node must be ready to respond to Raft communications at that address.

type Request

type Request struct {
	NodeType string `json:"type,omitempty"`
	Node     Node   `json:"node,omitempty"`
	FromNode Node   `json:"local_node,omitempty"`
}