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: String,
    },
    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,
    },
    McpServerAdded {
        server: McpServerSummary,
    },
    McpServerRemoved {
        server_id: i64,
    },
    McpServerStarted {
        server_id: i64,
        server_name: String,
    },
    McpServerStopped {
        server_id: i64,
        server_name: String,
    },
    McpServerError {
        error: McpErrorInfo,
    },
    VoiceStateChanged {
        state: String,
    },
    VoiceTranscript {
        text: String,
        is_final: bool,
    },
    VoiceSpeakingStarted,
    VoiceSpeakingFinished,
    VoiceAudioLevel {
        level: f32,
    },
    VoiceError {
        message: String,
    },
    VoiceModelDownloadProgress {
        model_id: String,
        bytes_downloaded: u64,
        total_bytes: u64,
        percent: f64,
    },
    ProxyStarted {
        port: u16,
    },
    ProxyStopped,
    ProxyCrashed,
}

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).

model_name: String

Name of the model being served.

error: String

Error description.

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.

McpServerAdded

An MCP server was added to the configuration.

Fields

server: McpServerSummary

Summary of the added server.

McpServerRemoved

An MCP server was removed from the configuration.

Fields

server_id: i64

ID of the removed server.

McpServerStarted

An MCP server has started and is ready.

Fields

server_id: i64

ID of the server.

server_name: String

Name of the server.

McpServerStopped

An MCP server has been stopped.

Fields

server_id: i64

ID of the server.

server_name: String

Name of the server.

McpServerError

An MCP server encountered an error.

Fields

error: McpErrorInfo

User-safe error information.

VoiceStateChanged

Voice pipeline state changed (idle → listening → recording → …).

Fields

state: String

Lowercase state label: "idle", "listening", "recording", "transcribing", "thinking", "speaking", or "error".

VoiceTranscript

Speech transcript produced by the STT engine.

Fields

text: String

Transcript text.

is_final: bool

Whether this is a final (committed) transcript.

VoiceSpeakingStarted

TTS playback has started.

VoiceSpeakingFinished

TTS playback has finished.

VoiceAudioLevel

Microphone audio level sample (0.0 – 1.0) for UI visualisation.

Throttled to ≤ 20 fps at the SSE bridge before entering the bus.

Fields

level: f32

Normalised audio level in [0.0, 1.0].

VoiceError

Voice pipeline encountered a non-fatal error.

Fields

message: String

Human-readable error message.

VoiceModelDownloadProgress

Download progress for a voice model (STT / TTS / VAD).

Emitted by VoiceService during download_stt_model, download_tts_model, and download_vad_model calls so that SSE subscribers receive live progress without Tauri’s app.emit().

Fields

model_id: String

Identifier of the model being downloaded (e.g. "base.en").

bytes_downloaded: u64

Bytes downloaded so far.

total_bytes: u64

Total bytes to download (0 if the server did not send Content-Length).

percent: f64

Progress percentage (0.0–100.0; 0.0 when total is unknown).

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).

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 fn download_started( id: impl Into<String>, _display_name: impl Into<String>, ) -> Self

Create a download started event.

pub fn download_progress( id: impl Into<String>, downloaded: u64, total: u64, speed_bps: f64, eta_seconds: f64, percentage: f64, ) -> Self

Create a download progress event.

pub fn download_completed( id: impl Into<String>, message: Option<String>, ) -> Self

Create a download completed event.

pub fn download_failed(id: impl Into<String>, error: impl Into<String>) -> Self

Create a download failed event.

pub fn download_cancelled(id: impl Into<String>) -> Self

Create a download cancelled event.

impl AppEvent

pub const fn mcp_server_added(server: McpServerSummary) -> Self

Create an MCP server added event.

pub const fn mcp_server_removed(server_id: i64) -> Self

Create an MCP server removed event.

pub fn mcp_server_started( server_id: i64, server_name: impl Into<String>, ) -> Self

Create an MCP server started event.

pub fn mcp_server_stopped( server_id: i64, server_name: impl Into<String>, ) -> Self

Create an MCP server stopped event.

pub const fn mcp_server_error(error: McpErrorInfo) -> Self

Create an MCP server error 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: impl Into<String>, ) -> Self

Create a server error event.

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

Create a server snapshot event.

impl AppEvent

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

Get the event name for wire protocols.

This provides consistent event naming across Tauri and SSE transports.

impl AppEvent

pub fn voice_state_changed(state: impl Into<String>) -> Self

Create a [VoiceStateChanged] event.

pub fn voice_transcript(text: impl Into<String>, is_final: bool) -> Self

Create a [VoiceTranscript] event.

pub const fn voice_speaking_started() -> Self

Create a [VoiceSpeakingStarted] event.

pub const fn voice_speaking_finished() -> Self

Create a [VoiceSpeakingFinished] event.

pub const fn voice_audio_level(level: f32) -> Self

Create a [VoiceAudioLevel] event.

pub fn voice_error(message: impl Into<String>) -> Self

Create a [VoiceError] event.

impl AppEvent

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

Create a [ProxyStarted] event.

pub const fn proxy_stopped() -> Self

Create a [ProxyStopped] event.

pub const fn proxy_crashed() -> Self

Create a [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.