ion

Documentation

Index

• type Node
  • func NewNode(nid string) Node
  • func (n *Node) Close()
  • func (n *Node) GetNeighborNodes() map[string]discovery.Node
  • func (n *Node) KeepAlive(node discovery.Node) error
  • func (n *Node) NatsConn() *nats.Conn
  • func (n *Node) NewNatsRPCClient(service, peerNID string, parameters map[string]interface{}) (*nrpc.Client, error)
  • func (n *Node) ServiceRegistrar() grpc.ServiceRegistrar
  • func (n *Node) Start(natURL string) error
  • func (n *Node) Watch(service string) error

Types

type Node

type Node struct {
	// Node ID
	NID string
	// contains filtered or unexported fields
}

Node .

func NewNode

func NewNode(nid string) Node

NewNode .

func (*Node) Close

func (n *Node) Close()

Close .

func (*Node) GetNeighborNodes

func (n *Node) GetNeighborNodes() map[string]discovery.Node

GetNeighborNodes get neighbor nodes.

func (*Node) KeepAlive

func (n *Node) KeepAlive(node discovery.Node) error

KeepAlive Upload your node info to registry.

func (*Node) NatsConn

func (n *Node) NatsConn() *nats.Conn

NatsConn .

func (*Node) NewNatsRPCClient

func (n *Node) NewNatsRPCClient(service, peerNID string, parameters map[string]interface{}) (*nrpc.Client, error)

func (*Node) ServiceRegistrar

func (n *Node) ServiceRegistrar() grpc.ServiceRegistrar

ServiceRegistrar return grpc.ServiceRegistrar of this node, used to create grpc services

func (*Node) Start

func (n *Node) Start(natURL string) error

Start .

func (*Node) Watch

func (n *Node) Watch(service string) error

Watch the neighbor nodes