Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

Workers seen by the pick route within WORKER_SEEN_TTL.

Cheap to clone: clones share the same record.

Examples

use ironflow_api::worker_registry::WorkerRegistry;
use ironflow_store::entities::WorkerCapabilities;

let registry = WorkerRegistry::new();
registry.record("worker-1", Some(WorkerCapabilities::new(None, vec!["gpu".to_string()])));

let routing = registry.routing_for("transcode", &["gpu".to_string()]);
assert_eq!(routing.seen_workers, 1);
assert_eq!(routing.eligible_workers, 1);

Implementations

impl WorkerRegistry

pub fn new() -> Self

Create an empty registry using WORKER_SEEN_TTL.

Examples

use ironflow_api::worker_registry::WorkerRegistry;

let registry = WorkerRegistry::new();
assert_eq!(registry.routing_for("deploy", &[]).seen_workers, 0);

pub fn with_ttl(ttl: Duration) -> Self

Create an empty registry where a worker counts as seen for ttl.

Examples

use std::time::Duration;

use ironflow_api::worker_registry::WorkerRegistry;

let registry = WorkerRegistry::with_ttl(Duration::from_secs(30));
registry.record("worker-1", None);
assert_eq!(registry.routing_for("deploy", &[]).seen_workers, 1);

pub fn record(&self, worker_id: &str, capabilities: Option<WorkerCapabilities>)

Record that worker_id asked for a run with these capabilities.

Replaces what was known about that worker, and drops the workers not seen within the TTL.

Examples

use ironflow_api::worker_registry::WorkerRegistry;

let registry = WorkerRegistry::new();
registry.record("worker-1", None);
registry.record("worker-1", None);
assert_eq!(registry.routing_for("deploy", &[]).seen_workers, 1);

pub fn routing_for( &self, workflow_name: &str, required_tags: &[String], ) -> WorkerRouting

Count the workers seen within the TTL, and those that could take a run of workflow_name requiring required_tags.

A worker without capabilities (an older release) can take any run.

Examples

use ironflow_api::worker_registry::WorkerRegistry;
use ironflow_store::entities::WorkerCapabilities;

let registry = WorkerRegistry::new();
registry.record("cpu-1", Some(WorkerCapabilities::new(None, Vec::new())));

let routing = registry.routing_for("transcode", &["gpu".to_string()]);
assert_eq!(routing.seen_workers, 1);
assert_eq!(routing.eligible_workers, 0);

Trait Implementations

impl Clone for WorkerRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerRegistry

fn default() -> Self

Returns the “default value” for a type.