discovery

Documentation

Index

• Constants
• func GenMemberAddrs(ms []Member) (addrs []string)
• func GenNodesFile(file string, ms []Member) error
• type Event
• type Member
  • func ReadMembers(file string) []Member
• type Node

Constants

const (
	EventJoin = iota
	EventLeave
	EventFailed
	EventUpdate
	EventReap
)

const (
	TagRaftPort = "raft-port"
	TagGrpcPort = "grpc-port"
)

Functions

func GenMemberAddrs

func GenMemberAddrs(ms []Member) (addrs []string)

func GenNodesFile

func GenNodesFile(file string, ms []Member) error

Types

type Event

type Event struct {
	Member
	Type int
}

type Member

type Member struct {
	Name string            `json:"name"`
	Addr string            `json:"addr"`
	Port int               `json:"port"`
	Tags map[string]string `json:"tags,omitempty"`
}

func ReadMembers

func ReadMembers(file string) []Member

type Node

type Node interface {
	Setup() error
	Stop()
	BindMqttServer(server *mqtt.Server)
	LocalAddr() string
	LocalName() string
	NumMembers() int
	Members() []Member
	EventChan() <-chan *Event
	SendToNode(nodeName string, msg []byte) error
	SendToOthers(msg []byte)
	Stat() map[string]int64
	Join(existing []string) (int, error)
	Leave() error
}