Enum Originator 

pub enum Originator {
    Local {
        user: Option<String>,
    },
    Replicated {
        from_node: String,
    },
    Internal {
        component: String,
    },
}

Identity of the party that initiated a write.

Captured on every LogEntry so audit queries can answer “who/what wrote this record” without a sidecar table, and replication can distinguish between locally-originated writes (which must be streamed to peers) and remotely-applied writes (which were received over the wire and must NOT be re-streamed).

Variants

Local

Locally-initiated write through the request pipeline. user is the authenticated principal when available; None for anonymous writes (e.g., public tables with @export(public: [create])).

Fields

user: Option<String>

Authenticated username, if the write went through the auth pipeline.

Replicated

Write applied locally in response to a peer’s replication stream. Carries the source node id so replication’s outgoing log writer can filter out these entries — we don’t re-stream what we received.

Fields

from_node: String

Node id of the source peer that originated the write.

Internal

Internal write performed by the platform itself — startup bootstrap, system-table maintenance, scheduled compaction. component is a short label for diagnostics ("auth-bootstrap", "ttl-sweep", etc.).

Fields

component: String

Name of the platform component that issued the write.

Implementations

impl Originator

pub const fn anonymous() -> Self

Convenience constructor for anonymous local writes.

pub fn local(user: impl Into<String>) -> Self

Convenience constructor for authenticated local writes.

pub const fn is_replicated(&self) -> bool

True if this write was received over the replication wire (i.e., should not be re-streamed). Used by the outgoing-log writer to filter out apply-from-peer writes.

Trait Implementations

impl Clone for Originator

fn clone(&self) -> Originator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Originator

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Originator

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Originator

impl PartialEq for Originator

fn eq(&self, other: &Originator) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Originator

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Originator