registry

Documentation

Index

• type IRegistry
• type Node
  • func NewNode(opts ...NodeOption) (*Node, error)
  • func (n *Node) BaseUrl() string
  • func (r Node) Discover(svc string) ([]*Node, error)
  • func (n *Node) Info() NodeInfo
  • func (n *Node) NumNodes() (numNodes int)
  • func (r Node) Register() error
  • func (n *Node) Shutdown()
  • func (n *Node) String() string
• type NodeInfo
• type NodeOption
  • func WithData(data interface{}) NodeOption

Types

type IRegistry

type IRegistry interface {
	Register() error
	Discover(svc string) ([]*Node, error)
}

IRegistry wraps service registry behaviors

type Node

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

Node represents go-doudou node

var LocalNode *Node

LocalNode store local node globally

func NewNode

func NewNode(opts ...NodeOption) (*Node, error)

NewNode creates new go-doudou node

func (*Node) BaseUrl

func (n *Node) BaseUrl() string

BaseUrl return base url for restful service

func (Node) Discover

func (r Node) Discover(svc string) ([]*Node, error)

Discover finds nodes which supplying specified service

func (*Node) Info

func (n *Node) Info() NodeInfo

Info return node info

func (*Node) NumNodes

func (n *Node) NumNodes() (numNodes int)

NumNodes return node number in the cluster

func (Node) Register

func (r Node) Register() error

Register registers local node to cluster

func (*Node) Shutdown

func (n *Node) Shutdown()

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

func (*Node) String

func (n *Node) String() string

String return string representation

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

type NodeOption

type NodeOption func(*Node)

NodeOption sets node properties

func WithData

func WithData(data interface{}) NodeOption

WithData sets data that local node carrying