discovery

Documentation

Index

• type Getter
• type Registry
  • func NewRegistry(nc *nats.Conn) *Registry
  • func (s *Registry) Discover(ctx context.Context, subj string, instanceID string, getData func() []byte) error
  • func (s *Registry) LookupComponents(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)
  • func (s *Registry) LookupFlows(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)
  • func (s *Registry) LookupNodes(ctx context.Context, flowID string) ([]*modulepb.DiscoveryNode, error)
  • func (s *Registry) LookupServers(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)
  • func (s *Registry) LookupStatNodes(ctx context.Context, flowID string) ([]*modulepb.DiscoveryNode, error)
  • func (s *Registry) SetLogger(l zerolog.Logger) *Registry

Types

type Getter

type Getter func() [][]byte

type Registry

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

func NewRegistry

func NewRegistry(nc *nats.Conn) *Registry

func (*Registry) Discover

func (s *Registry) Discover(ctx context.Context, subj string, instanceID string, getData func() []byte) error

Discover universal method listens for subj messages and responses back to the reply subject

func (*Registry) LookupComponents

func (s *Registry) LookupComponents(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)

func (*Registry) LookupFlows

func (s *Registry) LookupFlows(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)

func (*Registry) LookupNodes

func (s *Registry) LookupNodes(ctx context.Context, flowID string) ([]*modulepb.DiscoveryNode, error)

func (*Registry) LookupServers

func (s *Registry) LookupServers(ctx context.Context, workspaceID string) ([]*modulepb.DiscoveryNode, error)

func (*Registry) LookupStatNodes

func (s *Registry) LookupStatNodes(ctx context.Context, flowID string) ([]*modulepb.DiscoveryNode, error)

func (*Registry) SetLogger

func (s *Registry) SetLogger(l zerolog.Logger) *Registry