Struct WorkerClientImpl 

pub struct WorkerClientImpl { /* private fields */ }

Worker-side gRPC client. Construct via WorkerClientImpl::new, then spawn the background loops with WorkerClientImpl::start.

Implementations

impl WorkerClientImpl

pub fn new( servers: Vec<String>, token: Option<String>, profile: WorkerProfile, identity_dir: PathBuf, status_provider: Arc<dyn WorkerStatusProvider>, ) -> (Self, UnboundedReceiver<AssignmentEvent>, UnboundedReceiver<CommandEvent>)

Create a fresh worker client. Returns the client plus two receivers: assignment_rx and command_rx, which the agent’s executor drains to apply control-plane decisions locally.

Call start to spawn the background loops.

pub fn start(&self) -> JoinSet<()>

Start the background reconnect loop. Spawns one supervisor task that in turn fans out WatchAssignments, ReportStatus, and WatchCommands per connected session.

Trait Implementations

impl Debug for WorkerClientImpl

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

Formats the value using the given formatter.

impl WorkerClient for WorkerClientImpl

fn current_leader_addr<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<SocketAddr>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Currently-believed leader address (set by the most recent successful Register or WatchAssignments reconnect).

fn known_peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<NodeRecord>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Best-known peer list (the control plane sends snapshots over the gRPC stream).

fn assigned_node_id(&self) -> u64

Node-id assigned by the leader during Register.