Struct CaepTransmitter 

pub struct CaepTransmitter { /* private fields */ }

CAEP event transmitter — manages streams and dispatches events.

Implementations

impl CaepTransmitter

pub fn new(issuer: &str) -> Self

pub async fn create_stream(&self, config: StreamConfig) -> String

Register a new event stream. Returns the stream ID.

pub async fn get_stream_config(&self, stream_id: &str) -> Option<StreamConfig>

Get stream configuration.

pub async fn set_stream_status( &self, stream_id: &str, status: StreamStatus, ) -> Result<()>

Update stream status.

pub async fn get_stream_status(&self, stream_id: &str) -> Option<StreamStatus>

Get stream status.

pub async fn delete_stream(&self, stream_id: &str) -> bool

Delete a stream.

pub async fn emit_session_revoked( &self, subject: SubjectIdentifier, reason: Option<&str>, ) -> Result<CaepEvent>

Emit a session-revoked event to all enabled streams.

pub async fn emit_credential_change( &self, subject: SubjectIdentifier, change_type: ChangeType, ) -> Result<CaepEvent>

Emit a credential-change event.

pub async fn emit_device_compliance_change( &self, subject: SubjectIdentifier, previous_status: &str, current_status: &str, ) -> Result<CaepEvent>

Emit a device-compliance-change event.

pub async fn emit_token_claims_change( &self, subject: SubjectIdentifier, claims: HashMap<String, Value>, ) -> Result<CaepEvent>

Emit a token-claims-change event.

Signals that one or more claims in a previously issued token have changed.

pub async fn emit_assurance_level_change( &self, subject: SubjectIdentifier, current_level: &str, previous_level: &str, change_direction: &str, ) -> Result<CaepEvent>

Emit an assurance-level-change event.

Signals that the authentication assurance level for a subject has changed.

pub async fn poll_events(&self, stream_id: &str) -> Result<Vec<CaepEvent>>

Poll events for a stream (for pull-based delivery).

pub async fn active_stream_count(&self) -> usize

Count active (enabled) streams.