registry

Documentation

Index

• Variables
• func AllNodes() ([]*memberlist.Node, error)
• func BaseUrl(node *memberlist.Node) (string, error)
• func Leave(timeout time.Duration)
• func LocalNode() *memberlist.Node
• func MetaWeight(node *memberlist.Node) (int, error)
• func NewNode(data ...map[string]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 Leave

func Leave(timeout time.Duration)

Leave leaves the cluster on purpose

func LocalNode

func LocalNode() *memberlist.Node

func MetaWeight

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

func NewNode

func NewNode(data ...map[string]interface{}) error

NewNode creates a new go-doudou node. service related custom data (<= 512 bytes after being marshalled as json format) can be passed into it by data parameter. it is made as a variadic function only for backward compatibility purposes, only first parameter will be used.

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      map[string]interface{} `json:"data"`
	Host      string                 `json:"host"`
	SvcPort   int                    `json:"svcPort"`
	MemPort   int                    `json:"memPort"`
}

NodeInfo wraps node information

func Info

func Info(node *memberlist.Node) NodeInfo

Info return node info