Method dispatch

components/scheduler/src/vm_session.rs:161–195

Sends an event to the vm, recording a pending ack for it. On send failure the worker is broken and the ack payload is handed back so the caller can retry on a new session.

(
        &mut self,
        name: String,
        data: serde_json::Value,
        ack: PendingAckType,
        source: EventSource,
        ts: DateTime<Utc>,
    )

    /// On send failure the worker is broken and the ack payload is handed back
    /// so the caller can retry on a new session.
    pub fn dispatch(
        &mut self,
        name: String,
        data: serde_json::Value,
        ack: PendingAckType,
        source: EventSource,
        ts: DateTime<Utc>,
    ) -> Result<(), PendingAckType> {
        let evt_id = self.gen_dispatch_id();

        match self.worker.tx.send(SchedulerMessage::Dispatch(VmDispatchEvent {
            name,
            seq: evt_id,
            value: data,
            source,
            source_timestamp: ts,
        })) {
            Ok(()) => {
                self.pending_acks.insert(
                    evt_id,
                    PendingAck {
                        dispatched_session_id: self.vm_session_id,
                        kind: ack,
                        dispatched: Some(DispatchMeta {
                            source,
                            source_timestamp: ts,
                            vm_cold: self.vm_cold,
                        }),
                    },
                );
                Ok(())
            }
            Err(_) => Err(ack),
        }
    }

    /// Asks the vm to finish its pending work and shut down gracefully, the
    /// worker will send a [WorkerMessage::Shutdown] for the current session