Struct RemoteConfigurationWorker 

pub struct RemoteConfigurationWorker { /* private fields */ }

Drives polling and delivery for a RemoteConfigurationClient.

A supervisor can own and restart the worker, or the caller can drive it directly with run.

The worker does not exit on connection failures, on the Agent having remote configuration disabled, on the Agent reporting its configuration expired, or on a panic in a subscriber’s decoder. It keeps polling through all of them, so it exits only on a failure in the client itself.

A restart keeps every subscription and each product’s last accepted snapshot, and discards the protocol state, so the restarted worker fetches and decodes everything again. Subscribers may therefore see a snapshot equal to the one they already hold.

Failed polls, responses the client cannot apply, and rejected configurations are counted in the client’s metrics. Subscribers see only their own decoding errors, so they need the metrics or worker logs to see other failures.

Implementations

impl RemoteConfigurationWorker

pub async fn run(self) -> Result<(), GenericError>

Runs the worker without a supervisor.

This polls until the returned future is dropped.

Errors

Returns an error only on a failure in the client itself. Connection failures, remote configuration being disabled on the Agent, and rejected or panicking decoders are handled without returning.

Trait Implementations

impl Debug for RemoteConfigurationWorker

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

Formats the value using the given formatter.

impl Supervisable for RemoteConfigurationWorker

fn name(&self) -> &str

Returns the name of the process.

fn initialize<'life0, 'async_trait>( &'life0 self, process_shutdown: ShutdownHandle, ) -> Pin<Box<dyn Future<Output = Result<SupervisorFuture, InitializationError>> + Send + 'async_trait>>

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

Initializes the process asynchronously.

fn shutdown_strategy(&self) -> ShutdownStrategy

Returns the shutdown strategy for the process.

fn wants_shutdown_signal(&self) -> bool

Returns whether this process observes the shutdown signal it is given.