registry

Documentation

Index

• type NodeItem
• type Registry
  • func NewRegistry(nc *nats.Conn, expire time.Duration) (*Registry, error)
  • func (s *Registry) Listen(ctx context.Context, ...) 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 time.Duration) (*Registry, error)

NewRegistry create a service instance

func (*Registry) Listen

func (s *Registry) Listen(ctx context.Context, handleNodeAction func(action discovery.Request) (bool, error)) error