cluster

Documentation

Index

• Constants
• type Config
• type MessageHandler
• type Node
  • func NewNode(config Config) Node
• type NodeConnection
• type NodeDropListener
• type NodeInfo
• type NodeJoinListener
• type OnPubSubMessage
• type PubSub
  • func NewPubSub(node Node, onMessage OnPubSubMessage) PubSub

Constants

const (
	NotifyPath  = "/kylin/cluster/notify"
	ListPath    = "/kylin/cluster/list"
	ConnectPath = "/kylin/cluster/connect"
)

Types

type Config

type Config struct {
	Address     string   `json:"address"`
	Description string   `json:"description"`
	Nodes       []string `json:"nodes"`
}

type MessageHandler

type MessageHandler func(message interface{}) (handled bool)

type Node

type Node interface {
	Info() NodeInfo
	Start() error
	Stop() error
	WaitForDone()
	AddNodeJoinListener(NodeJoinListener)
	AddNodeDropListener(NodeDropListener)
	List() []NodeInfo
	RegisterMessage(message interface{})
	Broadcast(message interface{})
	SendTo(address string, message interface{})
}

func NewNode

func NewNode(config Config) Node

type NodeConnection

type NodeConnection interface {
	Info() NodeInfo
	Start() error
	Stop() error
	AddMessageHandler(MessageHandler)
	Send(message interface{})
	Conn() *websocket.Conn
	WaitForDone()
}

type NodeDropListener

type NodeDropListener func(NodeConnection)

type NodeInfo

type NodeInfo struct {
	Address     string `json:"address"`
	Description string `json:"description"`
}

type NodeJoinListener

type NodeJoinListener func(NodeConnection)

type OnPubSubMessage

type OnPubSubMessage func(topic string, message interface{})

type PubSub

type PubSub interface {
	Publish(topic string, message interface{})
	Subscribe(topic string)
	Unsubscribe(topic string)
	GetSubscribersAsync(topic string, resultChan chan []string)
	GetSubscribers(topic string) []string
	Start() error
	Stop() error
	WaitForDone()
}

func NewPubSub

func NewPubSub(node Node, onMessage OnPubSubMessage) PubSub