Struct RemoteAgentBootstrap 

pub struct RemoteAgentBootstrap { /* private fields */ }

Remote agent initialization.

This helper type is used to coordinate the initialization of remote agent state by registering to the Core Agent and acquiring the necessary information to allow initialization of the remote agent itself to proceed.

Implementations

impl RemoteAgentBootstrap

pub async fn new( client_config: &RemoteAgentClientConfiguration, secure_api_listen_address: &ListenAddress, ) -> Result<Self, GenericError>

Creates a new RemoteAgentBootstrap from the given configurations.

A remote agent client is created and immediately attempts to register with the Core Agent, advertising secure_api_listen_address as the address where the Core Agent reaches the status, flare, and telemetry services. This function does not return until the first registration attempt finishes, whether successful or not.

Registration runs in a background task that this function spawns outside of any supervision tree. The task refreshes the registration periodically, and registers again whenever a refresh fails, for the rest of the process’s lifetime: it doesn’t stop on shutdown, or when the returned RemoteAgentBootstrap is dropped.

Errors

Returns an error if secure_api_listen_address isn’t a valid gRPC target address, if the client can’t connect to the Core Agent, or if the first registration attempt fails.

If the first registration attempt fails, the background task keeps running and retries registration periodically, so it may still register with the Core Agent later. Treat this error as fatal rather than calling this function again: each call starts another background task, and each task registers its own session.

pub fn create_dataspace_anchor(&self) -> DataspaceAnchorWorker

Creates a worker that captures the dataspace from the supervisor context and makes it available to the diagnostic artifact collection service.

This worker must be added to the supervision tree. When it initializes, it runs inside a supervisor process where the dataspace task-local is set, and fills the shared OnceLock so that get_flare_files can collect diagnostic artifacts at request time. Without this, the gRPC handler tasks spawned by tonic would not have access to the dataspace since tonic’s tokio::spawn does not propagate task-locals.

pub fn create_event_reporter(&self) -> RemoteAgentEventReporter

Creates a worker that reports diagnostic events to the Core Agent as remote agent events.

pub fn create_services_worker( &self, status_sections: Vec<Arc<dyn StatusSectionProvider>>, telemetry_rules: Vec<RemapperRule>, ) -> RemoteAgentServicesWorker

Creates a worker that serves the status, flare, and telemetry services on the privileged API endpoint.

The status service always reports the built-in main section fields (version, Git commit, architecture, start time, and the Agent version this build was compiled against), followed by the fields written by each of the given status_sections, in order.

The telemetry service reports the internal metrics that match the given telemetry_rules, renamed to the names the Datadog Agent expects. Metrics that match no rule are not reported, so if telemetry_rules is empty, the service reports no metrics at all.

pub fn create_config_stream(&self) -> Receiver<ConfigUpdate>

Creates a config stream that receives configuration events from the Core Agent.

The stream is fed by a background task that this method spawns outside of any supervision tree. The task reconnects whenever the stream from the Core Agent ends, and doesn’t stop on shutdown. It only stops when it tries to deliver an update after the returned receiver is dropped.