Enum DakeraEvent 

pub enum DakeraEvent {
    NamespaceCreated {
        namespace: String,
        dimension: usize,
    },
    NamespaceDeleted {
        namespace: String,
    },
    OperationProgress {
        operation_id: String,
        namespace: Option<String>,
        op_type: String,
        progress: u8,
        status: OpStatus,
        message: Option<String>,
        updated_at: u64,
    },
    JobProgress {
        job_id: String,
        job_type: String,
        namespace: Option<String>,
        progress: u8,
        status: String,
    },
    VectorsMutated {
        namespace: String,
        op: VectorMutationOp,
        count: usize,
    },
    StreamLagged {
        dropped: u64,
        hint: String,
    },
    Connected {
        timestamp: u64,
    },
}

An event received from a Dakera SSE stream.

Mirrors the server-side DakeraEvent enum. Events are delivered over GET /v1/namespaces/:ns/events (namespace-scoped, Read scope) or GET /ops/events (global, Admin scope).

Use [DakeraClient::stream_namespace_events] or [DakeraClient::stream_global_events] to subscribe.

Variants

NamespaceCreated

A new namespace was created.

Fields

namespace: String

dimension: usize

NamespaceDeleted

A namespace was deleted.

Fields

namespace: String

OperationProgress

Progress update for a long-running operation (progress: 0–100).

Fields

operation_id: String

namespace: Option<String>

op_type: String

progress: u8

Progress percentage 0–100.

status: OpStatus

message: Option<String>

updated_at: u64

Unix milliseconds.

JobProgress

A background job changed status.

Fields

job_id: String

job_type: String

namespace: Option<String>

progress: u8

status: String

VectorsMutated

Vectors were upserted or deleted in bulk (threshold: >100 vectors).

Fields

namespace: String

op: VectorMutationOp

count: usize

StreamLagged

Subscriber fell too far behind — some events were dropped. Reconnect to resume the stream.

Fields

dropped: u64

hint: String

Connected

Emitted immediately on stream subscription to confirm the connection is live.

Clients can use this to distinguish connected-and-idle from not-yet-connected.

Fields

timestamp: u64

Unix milliseconds when the connection was confirmed.

Implementations

impl DakeraEvent

pub fn event_type(&self) -> &'static str

Returns the SSE event type string for this event variant.

Trait Implementations

impl Clone for DakeraEvent

fn clone(&self) -> DakeraEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DakeraEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DakeraEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DakeraEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.