client

Documentation

Index

• type Client
  • func NewClient(nc *nats.Conn) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Get(service string, params map[string]interface{}) (*discovery.GetResponse, error)
  • func (c *Client) KeepAlive(node discovery.Node) error
  • func (c *Client) Watch(ctx context.Context, service string, handleNodeState NodeStateChangeCallback) error
• type NodeStateChangeCallback

Types

type Client

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

func NewClient

func NewClient(nc *nats.Conn) (*Client, error)

NewService create a service instance

func (*Client) Close

func (c *Client) Close()

func (*Client) Get

func (c *Client) Get(service string, params map[string]interface{}) (*discovery.GetResponse, error)

func (*Client) KeepAlive

func (c *Client) KeepAlive(node discovery.Node) error

func (*Client) Watch

func (c *Client) Watch(ctx context.Context, service string, handleNodeState NodeStateChangeCallback) error

type NodeStateChangeCallback

type NodeStateChangeCallback func(state discovery.NodeState, node *discovery.Node)