registry

Documentation

Index

• Variables
• func AllNodes() ([]*memberlist.Node, error)
• func BaseUrl(node *memberlist.Node) (string, error)
• func LocalNode() *memberlist.Node
• func MetaWeight(node *memberlist.Node) (int, error)
• func NewNode(data ...interface{}) error
• func RegisterServiceProvider(sp IServiceProvider)
• func Shutdown()
• func SvcName(node *memberlist.Node) string
• type IServiceProvider
• type NodeInfo
  • func Info(node *memberlist.Node) NodeInfo

Variables

var BroadcastQueue *memberlist.TransmitLimitedQueue

Functions

func AllNodes

func AllNodes() ([]*memberlist.Node, error)

AllNodes return all memberlist nodes except dead and left nodes

func BaseUrl

func BaseUrl(node *memberlist.Node) (string, error)

func LocalNode

func LocalNode() *memberlist.Node

func MetaWeight

func MetaWeight(node *memberlist.Node) (int, error)

func NewNode

func NewNode(data ...interface{}) error

NewNode creates new go-doudou node

func RegisterServiceProvider

func RegisterServiceProvider(sp IServiceProvider)

func Shutdown

func Shutdown()

Shutdown stops all connections and communications with other nodes in the cluster

func SvcName

func SvcName(node *memberlist.Node) string

Types

type IServiceProvider

type IServiceProvider interface {
	SelectServer() string
	AddNode(node *memberlist.Node)
	UpdateWeight(node *memberlist.Node)
	RemoveNode(node *memberlist.Node)
}

IServiceProvider defines service provider interface for server discovery

type NodeInfo

type NodeInfo struct {
	SvcName   string `json:"svcName"`
	Hostname  string `json:"hostname"`
	BaseUrl   string `json:"baseUrl"`
	Status    string `json:"status"`
	Uptime    string `json:"uptime"`
	GoVer     string `json:"goVer"`
	GddVer    string `json:"gddVer"`
	BuildUser string `json:"buildUser"`
	BuildTime string `json:"buildTime"`
	Data      string `json:"data"`
}

NodeInfo wraps node information

func Info

func Info(node *memberlist.Node) NodeInfo

Info return node info