registry

package

v0.2.1 Latest Latest Go to latest Published: Oct 22, 2026 License: BSD-2-Clause Imports: 16 Imported by: 0

Details

Package registry provides node factory registration for the registry system.

This section is empty.

View Source

var ErrNodeNotRegistered = errors.New("node type not registered")

ErrNodeNotRegistered is returned when a node type is not registered.

This section is empty.

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

func NewRegistry() *Registry

func (r *Registry) CreateNode(
	ctx context.Context,
	nodeType string,
	nodeID string,
	config map[string]any,
) (protocol.Node, error)

CreateNode creates a new node instance based on the provided node type and configuration.

func (r *Registry) RegisterDefaultNodes()

RegisterDefaultNodes registers all built-in node factories with the registry.

func (r *Registry) RegisterNode(nodeFactory protocol.NodeFactory)

func (r *Registry) UseCallbackURL(base string)

UseCallbackURL sets the public base URL remote nodes call back to when they answer later.

func (r *Registry) UseRemoteTypes(types RemoteTypes)

UseRemoteTypes makes CreateNode fall back to node types registered by the platform and served over HTTP.

type RemoteTypes interface {
	Get(ctx context.Context, id string) (*models.RemoteNodeType, error)
}