Enum AppEvent 

pub enum AppEvent {
    ServerStarted {
        model_id: i64,
        model_name: String,
        port: u16,
    },
    ServerStopped {
        model_id: i64,
        model_name: String,
    },
    ServerError {
        model_id: Option<i64>,
        model_name: String,
        error: RuntimeErrorEnvelope,
    },
    ServerSnapshot {
        servers: Vec<ServerSnapshotEntry>,
    },
    Download {
        event: DownloadEvent,
    },
    ModelAdded {
        model: ModelSummary,
    },
    ModelRemoved {
        model_id: i64,
    },
    ModelUpdated {
        model: ModelSummary,
    },
    VerificationProgress {
        model_id: i64,
        model_name: String,
        shard_name: String,
        bytes_processed: u64,
        total_bytes: u64,
    },
    VerificationComplete {
        model_id: i64,
        model_name: String,
        overall_health: OverallHealth,
    },
    ServerHealthChanged {
        server_id: i64,
        model_id: i64,
        status: ServerHealthStatus,
        detail: Option<String>,
        timestamp: u64,
    },
    ProxyStarted {
        port: u16,
    },
    ProxyStopped,
    ProxyCrashed,
    RemoteEnabled {
        ticket_fingerprint: String,
    },
    RemoteDisabled,
    RemotePaired {
        peer: Option<String>,
    },
    RemoteConnected {
        port: u16,
    },
    RemoteDisconnected,
    RemoteAway {
        port: u16,
    },
    RemoteBack {
        port: u16,
    },
}

Canonical event types for all adapters.

This enum unifies server, download, and model events into a single discriminated union. Each variant includes all necessary context for the event to be self-describing.

Variants

ServerStarted

A model server has started and is ready to accept requests.

Fields

model_id: i64

ID of the model being served.

model_name: String

Name of the model being served.

port: u16

Port the server is listening on.

ServerStopped

A model server has been stopped (clean shutdown).

Fields

model_id: i64

ID of the model that was being served.

model_name: String

Name of the model that was being served.

ServerError

A model server encountered an error.

Fields

model_id: Option<i64>

ID of the model being served (if known).

Serde always sends the key — an unparseable model ID arrives as null, not as an absent field.

model_name: String

Name of the model being served.

error: RuntimeErrorEnvelope

Structured error detail (message, type discriminant, retryable flag), mirroring the HTTP layer’s ErrorResponse shape.

ServerSnapshot

Snapshot of all currently running servers.

Fields

servers: Vec<ServerSnapshotEntry>

List of currently running servers.

Download

Download lifecycle + progress events (including shard progress).

Wraps DownloadEvent verbatim to preserve all detail including shard-specific progress information.

Fields

event: DownloadEvent

The download event payload.

ModelAdded

A model was added to the library.

Fields

model: ModelSummary

Summary of the added model.

ModelRemoved

A model was removed from the library.

Fields

model_id: i64

ID of the removed model.

ModelUpdated

A model was updated in the library.

Fields

model: ModelSummary

Summary of the updated model.

VerificationProgress

Model verification progress update.

Fields

model_id: i64

ID of the model being verified.

model_name: String

Name of the model being verified.

shard_name: String

Name of the shard being verified.

bytes_processed: u64

Bytes processed so far.

total_bytes: u64

Total bytes to process.

VerificationComplete

Model verification completed.

Fields

model_id: i64

ID of the verified model.

model_name: String

Name of the verified model.

overall_health: OverallHealth

Overall health status.

ServerHealthChanged

Server health status has changed.

Emitted by continuous monitoring when a server’s health state changes.

Fields

server_id: i64

Unique server instance identifier.

model_id: i64

ID of the model being served.

status: ServerHealthStatus

New health status.

detail: Option<String>

Optional detail message (e.g., error description).

timestamp: u64

Unix timestamp in milliseconds when status changed.

ProxyStarted

The OpenAI-compatible proxy has started.

Fields

port: u16

Port the proxy is listening on.

ProxyStopped

The proxy has been stopped (clean shutdown).

ProxyCrashed

The proxy crashed (task exited without cancellation).

RemoteEnabled

The remote tunnel is up and has a ticket. The ticket itself is never on the event stream — any local GUI client can read it — so this carries the same twelve-character fingerprint the logs use.

Fields

ticket_fingerprint: String

Fingerprint of the ticket this session minted.

RemoteDisabled

The remote tunnel was taken down; nothing answers its ticket until enable puts the same one back.

RemotePaired

A device redeemed the pairing code and now holds the key.

Fields

peer: Option<String>

The tunnel edge’s fingerprint for that device, when it sent one.

RemoteConnected

This machine’s connect side is up: a local port that is the remote proxy.

Fields

port: u16

The loopback port the tunnel is bound to on this machine.

RemoteDisconnected

The connect side was taken down.

RemoteAway

The far machine has been away past the grace. The port stays bound and is still being dialled; this says so, so a client is not left reading “connected” over nothing.

Fields

port: u16

The loopback port that is still bound.

RemoteBack

The far machine answered again after being away.

Fields

port: u16

The loopback port, unchanged.

Implementations

impl AppEvent

pub const fn model_added(model: ModelSummary) -> Self

Create a model added event.

pub const fn model_removed(model_id: i64) -> Self

Create a model removed event.

pub const fn model_updated(model: ModelSummary) -> Self

Create a model updated event.

impl AppEvent

pub const fn remote_enabled(ticket_fingerprint: String) -> Self

Create a AppEvent::RemoteEnabled event.

pub const fn remote_disabled() -> Self

Create a AppEvent::RemoteDisabled event.

pub const fn remote_paired(peer: Option<String>) -> Self

Create a AppEvent::RemotePaired event.

pub const fn remote_connected(port: u16) -> Self

Create a AppEvent::RemoteConnected event.

pub const fn remote_disconnected() -> Self

Create a AppEvent::RemoteDisconnected event.

pub const fn remote_away(port: u16) -> Self

Create a AppEvent::RemoteAway event.

pub const fn remote_back(port: u16) -> Self

Create a AppEvent::RemoteBack event.

impl AppEvent

pub fn server_started( model_id: i64, model_name: impl Into<String>, port: u16, ) -> Self

Create a server started event.

pub fn server_stopped(model_id: i64, model_name: impl Into<String>) -> Self

Create a server stopped event.

pub fn server_error( model_id: Option<i64>, model_name: impl Into<String>, error: RuntimeErrorEnvelope, ) -> Self

Create a server error event.

pub const fn server_snapshot(servers: Vec<ServerSnapshotEntry>) -> Self

Create a server snapshot event.

pub fn from_server_started(server: &ServerSummary) -> Self

Build a ServerStarted event from a ServerSummary.

pub fn from_server_stopped(server: &ServerSummary) -> Self

Build a ServerStopped event from a ServerSummary.

pub fn from_server_error( server: &ServerSummary, error: RuntimeErrorEnvelope, ) -> Self

Build a ServerError event from a ServerSummary.

pub fn from_server_snapshot(servers: &[ServerSummary]) -> Self

Build a ServerSnapshot event from a slice of ServerSummary.

impl AppEvent

pub const fn event_name(&self) -> &'static str

Colon-separated event names.

Not what goes on the wire. AppEvent is #[serde(tag = "type", rename_all = "snake_case")], so SSE carries download/model_added; these download:started spellings are the Tauri-bus vocabulary from before the GUI backend moved into the daemon, and the Tauri event branch that subscribed to them is gone.

Nothing outside this module’s tests calls it. Retiring it belongs with the rest of the residual-Rust sweep, not here.

impl AppEvent

pub const fn proxy_started(port: u16) -> Self

Create a AppEvent::ProxyStarted event.

pub const fn proxy_stopped() -> Self

Create a AppEvent::ProxyStopped event.

pub const fn proxy_crashed() -> Self

Create a AppEvent::ProxyCrashed event.

Trait Implementations

impl Clone for AppEvent

fn clone(&self) -> AppEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AppEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AppEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AppEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.