Struct AppStateInner 

pub struct AppStateInner {

    pub config: Arc<Config>,
    pub token: CancellationToken,
    pub stream_engine: Arc<StreamEngine>,
    pub callrecord_sender: Option<CallRecordSender>,
    pub endpoint: Endpoint,
    pub registration_handles: Mutex<HashMap<String, RegistrationHandle>>,
    pub alive_users: Arc<RwLock<HashSet<String>>>,
    pub dialog_layer: Arc<DialogLayer>,
    pub create_invitation_handler: Option<FnCreateInvitationHandler>,
    pub invitation: Invitation,
    pub routing_state: Arc<RoutingState>,
    pub pending_playbooks: Arc<Mutex<HashMap<String, String>>>,
    pub pending_params: Arc<Mutex<HashMap<String, HashMap<String, Value>>>>,
    pub active_calls: Arc<Mutex<HashMap<String, ActiveCallRef>>>,
    pub total_calls: AtomicU64,
    pub total_failed_calls: AtomicU64,
    pub uptime: DateTime<Local>,
    pub shutting_down: Arc<AtomicBool>,
}

Fields

config: Arc<Config>

token: CancellationToken

stream_engine: Arc<StreamEngine>

callrecord_sender: Option<CallRecordSender>

endpoint: Endpoint

registration_handles: Mutex<HashMap<String, RegistrationHandle>>

alive_users: Arc<RwLock<HashSet<String>>>

dialog_layer: Arc<DialogLayer>

create_invitation_handler: Option<FnCreateInvitationHandler>

invitation: Invitation

routing_state: Arc<RoutingState>

pending_playbooks: Arc<Mutex<HashMap<String, String>>>

pending_params: Arc<Mutex<HashMap<String, HashMap<String, Value>>>>

active_calls: Arc<Mutex<HashMap<String, ActiveCallRef>>>

total_calls: AtomicU64

total_failed_calls: AtomicU64

uptime: DateTime<Local>

shutting_down: Arc<AtomicBool>

Implementations

impl AppStateInner

pub fn get_dump_events_file(&self, session_id: &String) -> String

pub fn get_recorder_file(&self, session_id: &String) -> String

pub async fn serve(self: Arc<Self>) -> Result<()>

pub fn stop(&self)

pub async fn start_registration(&self) -> Result<usize>

pub fn find_credentials_for_callee( &self, callee: &str, ) -> Option<UserCredential>

pub async fn stop_registration( &self, wait_for_clear: Option<Duration>, ) -> Result<()>

pub async fn register(&self, option: RegisterOption) -> Result<()>

Trait Implementations

impl Drop for AppStateInner

fn drop(&mut self)

Executes the destructor for this type.