Struct MobKitConsoleAggregator 

pub struct MobKitConsoleAggregator { /* private fields */ }

Implementations

impl MobKitConsoleAggregator

pub fn new(store: Arc<dyn ConsoleLogStore>) -> Self

pub fn new_with_options( store: Arc<dyn ConsoleLogStore>, options: ConsoleAggregatorOptions, ) -> Self

pub fn in_memory() -> Self

pub fn in_memory_with_options(options: ConsoleAggregatorOptions) -> Self

pub fn subscribe(&self) -> Receiver<ConsoleTimelineEvent>

pub fn store(&self) -> Arc<dyn ConsoleLogStore>

pub fn register_runtime(&self, registration: ConsoleRuntimeRegistration)

pub async fn list_identities( &self, ) -> ConsoleLogResult<Vec<ConsoleIdentityRecord>>

pub async fn inspect_identity( &self, identity: &str, ) -> ConsoleLogResult<Option<ConsoleIdentityInspection>>

pub async fn retire_identity(&self, identity: &str) -> ConsoleLogResult<bool>

pub async fn clear_timeline_frames(&self) -> ConsoleLogResult<()>

pub async fn query_timeline( &self, query: ConsoleTimelineQuery, ) -> ConsoleLogResult<ConsoleTimelinePage>

pub async fn query_timeline_windowed( &self, query: ConsoleTimelineWindowQuery, ) -> ConsoleLogResult<ConsoleTimelineWindowPage>

pub async fn refresh_session_history(&self) -> ConsoleLogResult<()>

pub async fn latest_cursor(&self) -> ConsoleLogResult<Option<ConsoleCursor>>

pub async fn timeline_event_visible(&self, event: &ConsoleTimelineEvent) -> bool

pub async fn timeline_frame_visible_for_query( &self, frame: &ConsoleFrame, identity: Option<&str>, ) -> bool

pub async fn send( &self, request: ConsoleSendRequest, ) -> Result<ConsoleInteractionAccepted, ConsoleSendError>

pub async fn reserve_identity_first_interaction( &self, request: ConsoleSendRequest, session_id: Option<&str>, ) -> Result<ConsoleInteractionAccepted, ConsoleSendError>

pub async fn mark_interaction_delivery_failed( &self, input_frame_id: &str, ) -> Result<(), ConsoleSendError>

pub async fn mark_interaction_delivered( &self, input_frame_id: &str, ) -> Result<(), ConsoleSendError>

pub async fn mark_steer_interaction_delivered( &self, input_frame_id: &str, interaction_id: &str, ) -> Result<(), ConsoleSendError>

pub async fn binary_blob_store_for_identity( &self, identity: &str, ) -> Result<Option<Arc<dyn BinaryBlobStore>>, ConsoleSendError>

pub fn binary_blob_stores(&self) -> Vec<Arc<dyn BinaryBlobStore>>

Trait Implementations

impl Clone for MobKitConsoleAggregator

fn clone(&self) -> MobKitConsoleAggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.