Struct MobkitRuntimeHandle 

pub struct MobkitRuntimeHandle {
    pub lifecycle_events: Vec<LifecycleEvent>,
    pub supervisor_report: SupervisorReport,
    pub merged_events: Vec<EventEnvelope<UnifiedEvent>>,
    /* private fields */
}

Fields

lifecycle_events: Vec<LifecycleEvent>

supervisor_report: SupervisorReport

merged_events: Vec<EventEnvelope<UnifiedEvent>>

Implementations

impl MobkitRuntimeHandle

pub fn send_delivery( &mut self, request: DeliverySendRequest, ) -> Result<DeliveryRecord, DeliverySendError>

pub fn delivery_history( &self, request: DeliveryHistoryRequest, ) -> DeliveryHistoryResponse

pub fn delivery_rate_window_count_entries(&self) -> usize

impl MobkitRuntimeHandle

pub fn merged_events(&self) -> &[EventEnvelope<UnifiedEvent>]

pub fn subscribe_events( &self, request: SubscribeRequest, ) -> Result<SubscribeResponse, SubscribeError>

impl MobkitRuntimeHandle

pub fn evaluate_gating_action( &mut self, request: GatingEvaluateRequest, ) -> GatingEvaluateResult

pub fn list_gating_pending(&mut self) -> Vec<GatingPendingEntry>

pub fn decide_gating_action( &mut self, request: GatingDecideRequest, ) -> Result<GatingDecisionResult, GatingDecideError>

pub fn gating_audit_entries(&mut self, limit: usize) -> Vec<GatingAuditEntry>

impl MobkitRuntimeHandle

pub fn memory_stores(&self) -> Vec<MemoryStoreInfo>

pub fn memory_index( &mut self, request: MemoryIndexRequest, ) -> Result<MemoryIndexResult, MemoryIndexError>

pub fn memory_query(&self, request: MemoryQueryRequest) -> MemoryQueryResult

impl MobkitRuntimeHandle

pub fn list_runtime_routes(&self) -> Vec<RuntimeRoute>

pub fn add_runtime_route( &mut self, route: RuntimeRoute, ) -> Result<RuntimeRoute, RuntimeRouteMutationError>

pub fn delete_runtime_route( &mut self, route_key: &str, ) -> Result<RuntimeRoute, RuntimeRouteMutationError>

pub fn resolve_routing( &mut self, request: RoutingResolveRequest, ) -> Result<RoutingResolution, RoutingResolveError>

impl MobkitRuntimeHandle

pub fn evaluate_schedule_tick( &self, schedules: &[ScheduleDefinition], tick_ms: u64, ) -> Result<ScheduleEvaluation, ScheduleValidationError>

pub fn dispatch_schedule_tick( &mut self, schedules: &[ScheduleDefinition], tick_ms: u64, ) -> Result<ScheduleDispatchReport, ScheduleValidationError>

impl MobkitRuntimeHandle

pub fn shutdown(&mut self) -> RuntimeShutdownReport

pub fn is_running(&self) -> bool

pub fn loaded_modules(&self) -> Vec<String>

pub fn reconcile_modules( &mut self, modules: Vec<String>, timeout: Duration, ) -> Result<usize, RuntimeMutationError>

pub fn spawn_member( &mut self, module_id: &str, timeout: Duration, ) -> Result<(), RuntimeMutationError>

impl MobkitRuntimeHandle

pub fn lifecycle_events(&self) -> &[LifecycleEvent]

pub fn supervisor_report(&self) -> &SupervisorReport

Trait Implementations

impl Debug for MobkitRuntimeHandle

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

Formats the value using the given formatter.