Struct RemoteAgentClient 

pub struct RemoteAgentClient { /* private fields */ }

A client for interacting with the Datadog Agent’s internal gRPC-based API.

Implementations

impl RemoteAgentClient

pub async fn connect( config: &RemoteAgentClientConfiguration, ) -> Result<Self, GenericError>

Connects to the Core Agent’s gRPC IPC endpoint using the given client configuration.

Errors

If the connection can’t be established, the authentication token or IPC certificate can’t be read, or the initial health-check RPC fails, an error will be returned. Each of these is retried first.

pub async fn get_hostname(&mut self) -> Result<String, GenericError>

Gets the detected hostname from the Agent.

Errors

If there is an error querying the Agent API, an error will be returned.

pub fn get_tagger_stream( &mut self, cardinality: TagCardinality, prefixes: Option<Vec<String>>, ) -> StreamingResponse<StreamTagsResponse>

Gets a stream of tagger entities at the given cardinality, optionally limited to a set of entity ID prefixes.

When prefixes is given, the server only sends events for entities whose ID carries one of those prefixes, which avoids paying the serialization and bandwidth cost of entities that the caller has no use for. Passing None applies no filtering, and the server sends events for every prefix it knows about.

If there is an error with the initial request, or an error occurs while streaming, the next message in the stream will be Some(Err(status)), where the status indicates the underlying error.

pub fn get_workloadmeta_stream( &mut self, ) -> StreamingResponse<WorkloadmetaStreamResponse>

Gets a stream of all workloadmeta entities.

If there is an error with the initial request, or an error occurs while streaming, the next message in the stream will be Some(Err(status)), where the status indicates the underlying error.

pub async fn register_remote_agent( &mut self, pid: u32, display_name: &str, flavor: &str, api_endpoint: &str, services: Vec<String>, ) -> Result<Response<RegisterRemoteAgentResponse>, GenericError>

Registers a Remote Agent with the Agent.

Errors

If there is an error sending the request to the Agent API, an error will be returned.

pub async fn refresh_remote_agent( &mut self, session_id: &SessionId, ) -> Result<Response<()>, GenericError>

Refreshes the given remote agent session with the Agent.

Errors

If there is an error sending the request to the Agent API, an error will be returned.

pub async fn report_remote_agent_event( &mut self, request: ReportRemoteAgentEventRequest, ) -> Result<Response<ReportRemoteAgentEventResponse>, GenericError>

Reports one or more operational events for a remote agent session to the Agent.

Errors

If there is an error sending the request to the Agent API, an error will be returned.

pub async fn get_host_tags( &self, ) -> Result<Response<HostTagReply>, GenericError>

Gets the host tags from the Agent.

Errors

If there is an error querying the Agent API, an error will be returned.

pub fn get_autodiscovery_stream( &mut self, ) -> StreamingResponse<AutodiscoveryStreamResponse>

Gets a stream of autodiscovery config updates.

If there is an error with the initial request, or an error occurs while streaming, the next message in the stream will be Some(Err(status)), where the status indicates the underlying error.

pub fn stream_config_events( &mut self, session_id: &SessionId, ) -> StreamingResponse<ConfigEvent>

Gets a stream of config events.

If there is an error with the initial request, or an error occurs while streaming, the next message in the stream will be Some(Err(status)), where the status indicates the underlying error.

Trait Implementations

impl Clone for RemoteAgentClient

fn clone(&self) -> RemoteAgentClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.