Struct HttpUsageEmitter 

pub struct HttpUsageEmitter { /* private fields */ }

Posts usage events to an HTTP endpoint in bounded batches, retrying and optionally spooling to disk when the endpoint is unavailable.

UpdateSent events are not posted one per message. Updates for the same connection, deployment, identity and view are summed over a 10-second window and posted as one event carrying the total messages and bytes, stamped with the time of the last update it covers. Consumers should sum those fields rather than count events. Every other event type is posted as emitted.

Implementations

impl HttpUsageEmitter

pub fn new(endpoint: String, auth_token: Option<String>) -> Self

pub fn new_attributed( endpoint: String, auth_token: Option<String>, build_id: impl Into<String>, ) -> Result<Self, InvalidUsageBuildId>

pub fn with_spool_dir( endpoint: String, auth_token: Option<String>, spool_dir: impl Into<PathBuf>, ) -> Self

pub fn with_attributed_spool_dir( endpoint: String, auth_token: Option<String>, spool_dir: impl Into<PathBuf>, build_id: impl Into<String>, ) -> Result<Self, InvalidUsageBuildId>

pub fn with_config( endpoint: String, auth_token: Option<String>, batch_size: usize, flush_interval: Duration, ) -> Self

Trait Implementations

impl WebSocketUsageEmitter for HttpUsageEmitter

fn emit<'life0, 'async_trait>( &'life0 self, event: WebSocketUsageEvent, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

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

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

Finish or durably preserve every event accepted before this call while leaving the emitter available for later events.

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

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

Finish or durably preserve every event accepted before this call.