Struct Worker 

pub struct Worker {
    pub id: WorkerId,
    pub capabilities: Capabilities,
    /* private fields */
}

Worker state: manages execution of plans received from a coordinator.

Fields

id: WorkerId

capabilities: Capabilities

Implementations

impl Worker

pub fn new(id: impl Into<String>, capabilities: Capabilities) -> Self

pub fn with_cache(self, cache: Arc<dyn CacheStore>) -> Self

Set a custom cache store (e.g. tiered or shared).

pub fn with_data_store(self, store: Arc<dyn DataStore>) -> Self

Set a persistent DataStore (S3, Zarr, etc.) for large data references.

pub fn with_temp_dir(self, path: PathBuf) -> Self

Set a custom temp directory for HTTP bulk uploads.

pub fn temp_store(&self) -> &Arc<LocalDataStore>

Get the temp store (for HTTP upload endpoint).

pub fn register_filter( &mut self, node_id: impl Into<String>, filter: Box<dyn Filter>, )

Register a filter that this worker can execute.

pub fn get_filter(&self, node_id: &str) -> Option<Arc<dyn Filter>>

Get a filter by node_id (for stream executor construction).

pub fn get_filter_state(&self, node_id: &str) -> Value

Get trained state for a filter.

pub fn set_filter_state(&mut self, node_id: &str, state: Value)

Set trained state for a filter.

pub fn wrap_output(&self, output: Value) -> OutputDelivery

Wrap output in the right delivery: inline for small, DataRef for large.

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to execution events.

pub fn registration_message(&self) -> WorkerToCoordinator

Build a registration message.

pub fn execute_plan(&mut self, plan: &SerializedPlan) -> PlanResult

Execute a serialized plan.

If the plan contains serialized filter definitions, they are registered temporarily for this execution (alongside any pre-registered filters).

In Fit mode: fits each filter (topological order), stores trained states, then forwards to propagate outputs. Returns states so the client can cache them.

In Forward mode: executes the compiled plan directly.

pub fn matches_target(&self, target: &RemoteTarget) -> bool

Check if this worker matches a remote target.