Module auteur::node

source · []
Expand description

Implementation of a node management system

Nodes are Actix actors in charge of building and scheduling the state of GStreamer pipelines.

Nodes can produce and / or consume data, and are connected to one another through StreamProducer

Structs

Add a property control point, sent from NodeManager to any Node

Sent from controllers, this is our public interface.

Retrieves node-specific information. Sent from NodeManager to any Node.

Getter for stream producers, sent from NodeManager to any producer node to connect them to consumers

NodeManager acts as a tracker of all nodes, and dispatches messages accordingly

Sent from any NodeStatusMessage recipient to NodeManager to register a state listener

Remove a control point, sent from NodeManager to any Node

Reschedule a node, sent from NodeManager to any Node

Start a node, sent from NodeManager to any Node

Sent from NodeManager to any Node in order to make it initiate orderly teardown immediately.

A node has stopped, sent from any node to NodeManager

Enums

Sent from NodeManager to any consumer node in order to let them connect and disconnect from stream producers, and to control properties on individual slots

Node 🔒

All the node types NodeManager supports

Sent from Node to NodeManager so that it can inform listeners of nodes’ status