registry

Documentation

Index

• type NodeItem
• type Registry
  • func NewRegistry(nc *nats.Conn, expire int64) (*Registry, error)
  • func (s *Registry) Close()
  • func (s *Registry) Listen(...) error

Types

type NodeItem

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

type Registry

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

func NewRegistry

func NewRegistry(nc *nats.Conn, expire int64) (*Registry, error)

NewService create a service instance

func (*Registry) Close

func (s *Registry) Close()

func (*Registry) Listen

func (s *Registry) Listen(
	handleNodeAction func(action discovery.Action, node discovery.Node) (bool, error),
	handleGetNodes func(service string, params map[string]interface{}) ([]discovery.Node, error)) error