discovery

Documentation

Index

• type Node
  • func (n *Node) ID() string
• type Service
  • func NewService(service string, dc string, addrs []string) (*Service, error)
  • func (s *Service) Close()
  • func (s *Service) GetNodes(service string, nodes map[string]Node) error
  • func (s *Service) KeepAlive()
  • func (s *Service) NID() string
  • func (s *Service) Watch(service string, onStateChange func(state State, id string, node *Node))
• type State

Types

type Node

type Node struct {
	DC      string
	Service string
	NID     string
	IP      string
}

Node represents a node info

func (*Node) ID

func (n *Node) ID() string

ID return the node id with scheme prefix

type Service

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

Service represents a service node

func NewService

func NewService(service string, dc string, addrs []string) (*Service, error)

NewService create a service instance

func (*Service) Close

func (s *Service) Close()

Close service

func (*Service) GetNodes

func (s *Service) GetNodes(service string, nodes map[string]Node) error

GetNodes get the service nodes

func (*Service) KeepAlive

func (s *Service) KeepAlive()

KeepAlive service keepalive

func (*Service) NID

func (s *Service) NID() string

NID return node id

func (*Service) Watch

func (s *Service) Watch(service string, onStateChange func(state State, id string, node *Node))

Watch the service nodes

type State

type State int32

State define the node state type

const (
	// NodeUp node starting up
	NodeUp State = 0
	// NodeDown node shutdown
	NodeDown State = 1
)