Struct ResponseObserver 

pub struct ResponseObserver { /* private fields */ }

Component for observing HTTP responses and triggering agent info fetches.

This component checks HTTP responses for the Datadog-Agent-State header and sends trigger messages to the agent info fetcher when a new state is detected.

Implementations

impl ResponseObserver

pub fn new(trigger_tx: Sender<()>) -> Self

Create a new ResponseObserver with the given channel sender.

pub fn check_response(&self, response: &HttpResponse)

Check the given HTTP response for agent state changes and trigger a fetch if needed.

This method examines the Datadog-Agent-State header in the response and compares it with the previously seen state. If the state has changed, it sends a trigger message to the agent info fetcher.

pub fn manual_trigger(&self)

Manually send a message to the trigger channel.

Trait Implementations

impl Clone for ResponseObserver

fn clone(&self) -> ResponseObserver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResponseObserver

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

Formats the value using the given formatter.