cluster

Documentation

Index

• type Config
  • func ConvertJSONToConfig(jsonString string) (*Config, error)
  • func (config *Config) AddNode(node Node)
  • func (config *Config) Equals(config2 *Config) bool
  • func (config *Config) ToJSON() (string, error)
• type EtcdServer
  • func CreateEtcdServer(thisNode Node, config Config, dataPath string) *EtcdServer
  • func (server *EtcdServer) CurrentCluster() Config
  • func (server *EtcdServer) Leader() string
  • func (server *EtcdServer) Members() []Node
  • func (server *EtcdServer) Start()
  • func (server *EtcdServer) Stop()
  • func (server *EtcdServer) StorageDir() string
  • func (server *EtcdServer) WaitToStart()
  • func (server *EtcdServer) WaitToStop()
• type Node
  • func (node *Node) Equals(node2 *Node) bool
• type RelayServer
  • func CreateRelayServer(thisNode Node, clusterConfig Config) *RelayServer
  • func (server *RelayServer) Broadcast(msg []byte) error
  • func (server *RelayServer) Receive() chan []byte
  • func (server *RelayServer) Shutdown()

Types

type Config

type Config struct {
	Nodes  []Node `json:"nodes"`
	Leader Node   `json:"leader"`
}

func ConvertJSONToConfig

func ConvertJSONToConfig(jsonString string) (*Config, error)

func (*Config) AddNode

func (config *Config) AddNode(node Node)

func (*Config) Equals

func (config *Config) Equals(config2 *Config) bool

func (*Config) ToJSON

func (config *Config) ToJSON() (string, error)

type EtcdServer

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

func CreateEtcdServer

func CreateEtcdServer(thisNode Node, config Config, dataPath string) *EtcdServer

func (*EtcdServer) CurrentCluster

func (server *EtcdServer) CurrentCluster() Config

func (*EtcdServer) Leader

func (server *EtcdServer) Leader() string

func (*EtcdServer) Members

func (server *EtcdServer) Members() []Node

func (*EtcdServer) Start

func (server *EtcdServer) Start()

func (*EtcdServer) Stop

func (server *EtcdServer) Stop()

func (*EtcdServer) StorageDir

func (server *EtcdServer) StorageDir() string

func (*EtcdServer) WaitToStart

func (server *EtcdServer) WaitToStart()

func (*EtcdServer) WaitToStop

func (server *EtcdServer) WaitToStop()

type Node

type Node struct {
	Name           string `json:"name"`
	Host           string `json:"host"`
	EtcdClientPort int    `json:"port"`     // Etcd default 2379
	EtcdPeerPort   int    `json:"peerport"` // Etcd default 2380
	RelayPort      int    `json:"relayport"`
	APIPort        int    `json:"apiport"`
}

func (*Node) Equals

func (node *Node) Equals(node2 *Node) bool

type RelayServer

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

func CreateRelayServer

func CreateRelayServer(thisNode Node, clusterConfig Config) *RelayServer

func (*RelayServer) Broadcast

func (server *RelayServer) Broadcast(msg []byte) error

Send a message to all ReplayServers in the Cluster

func (*RelayServer) Receive

func (server *RelayServer) Receive() chan []byte

func (*RelayServer) Shutdown

func (server *RelayServer) Shutdown()