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 register_filter( &mut self, node_id: impl Into<String>, filter: Box<dyn Filter>, )

Register a filter that this worker can execute.

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).

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

Check if this worker matches a remote target.