discovery

package

v0.0.4 Latest Latest Go to latest Published: May 10, 2023 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Getter func() [][]byte

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

func NewRegistry(nc *nats.Conn) *Registry

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 (s *Registry) Lookup(replySubject, subj string, minDur time.Duration, maxDur time.Duration) ([]*modulepb.DiscoveryNode, 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) LookupModules(ctx context.Context, serverID string) ([]*modulepb.DiscoveryNode, error)

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

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

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