clustering

Documentation

Index

• type Cluster
  • func (cluster Cluster) Locate(key string) INode
• type EndPoint
• type ICluster
  • func CreateCluster(endPoints ...EndPoint) ICluster
• type INode
• type Node
  • func (node *Node) SendCommand(cmd message.CommandOpCode, key string, body []byte) (result []byte, err error)
  • func (node *Node) Start(endPoint EndPoint)

Types

type Cluster

type Cluster struct {
	Nodes []INode
}

func (Cluster) Locate

func (cluster Cluster) Locate(key string) INode

type EndPoint

type EndPoint struct {
	Address string
	Port    string
}

type ICluster

type ICluster interface {
	Locate(key string) INode
}

func CreateCluster

func CreateCluster(endPoints ...EndPoint) ICluster

type INode

type INode interface {
	SendCommand(cmd message.CommandOpCode, key string, body []byte) (result []byte, err error)
	Start(endPoint EndPoint)
}

type Node

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

func (*Node) SendCommand

func (node *Node) SendCommand(cmd message.CommandOpCode, key string, body []byte) (result []byte, err error)

func (*Node) Start

func (node *Node) Start(endPoint EndPoint)