remote

package

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

Details

This section is empty.

This section is empty.

func AwaitsCallback(result models.NodeResult) bool

AwaitsCallback reports whether result is a remote node waiting for its service to call back, which only an answer naming a port can resume.

func CallbackAllowed(result models.NodeResult, token string) bool

CallbackAllowed reports whether token is the callback token handed out with the call that left result waiting.

func Normalize(nodeType *models.RemoteNodeType)

func Prepare(nodeType *models.RemoteNodeType) error

Prepare validates a node type the way the platform API accepts it and fills its defaults.

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

func New(nodeType models.RemoteNodeType, id string, config map[string]any, client *http.Client, callbackBase string) *Node

func (n *Node) Execute(execution models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)

func (n *Node) ID() string

func (n *Node) InputPorts() []models.InputPort

func (n *Node) OutputPorts() []models.OutputPort

func (n *Node) Type() string

func (n *Node) Validate(config map[string]any) error

type Types map[string]models.RemoteNodeType

Types holds node types in memory by id.

func ReadTypes(path string) (Types, error)

ReadTypes reads a JSON object of node types keyed by id, each with the body of PUT /platform/node-types/:id, and prepares every one.

func (t Types) Get(_ context.Context, id string) (*models.RemoteNodeType, error)

Get returns the node type with the given id.