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) NumNodes() (numNodes int)
  • func (r Node) Register() error
  • func (n *Node) String() string
• type NodeOption
  • func WithData(data interface{}) NodeOption
• type NodeState
  • func (s NodeState) String() string

Types

type IRegistry

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

type Node

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

func NewNode

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

func (*Node) BaseUrl

func (n *Node) BaseUrl() string

func (Node) Discover

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

func (*Node) NumNodes

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

func (Node) Register

func (r Node) Register() error

func (*Node) String

func (n *Node) String() string

type NodeOption

type NodeOption func(*Node)

func WithData

func WithData(data interface{}) NodeOption

type NodeState

type NodeState int

const (
	Alive NodeState = iota
	Leaving
	Left
	Shutdown
)

func (NodeState) String

func (s NodeState) String() string