Struct Mailbox 

struct Mailbox {
    receiver: Receiver<MailboxActorMessage>,
    queue: BinaryHeap<QueueItem>,
    pool: PgPool,
    telemetry_sender: Sender<String>,
    log_sender: Sender<String>,
}

Fields

receiver: Receiver<MailboxActorMessage>

queue: BinaryHeap<QueueItem>

pool: PgPool

telemetry_sender: Sender<String>

log_sender: Sender<String>

Implementations

impl Mailbox

async fn new(receiver: Receiver<MailboxActorMessage>) -> Self

fn run_telemetry_broadcaster(receiver: Receiver<String>)

fn run_log_broadcaster(receiver: Receiver<String>)

async fn create_mailbox_schema(pool: &PgPool) -> Result<(), Error>

async fn handle_message(&mut self, msg: MailboxActorMessage)

async fn add_message(&mut self, message: MailboxMessage)

fn get_next_message(&mut self) -> Option<MailboxMessage>

async fn save_message_to_db( &self, message: &MailboxMessage, ) -> Result<(), Error>

async fn save_gps_to_db(&self, gps: Gps) -> Result<(), Error>

async fn process_queue(&mut self)

fn get_priority(msg_type: &MailboxMessageType) -> u8