Enum SourceRef 

pub enum SourceRef {
    Message {
        stream: u32,
        topic: u32,
        partition: u32,
        offset: u64,
        conversation: Option<String>,
    },
    Kv {
        namespace: String,
        key: String,
    },
    Memory {
        id: String,
    },
}

Where a graph element was last observed: the source record an extraction came from, so a reader can navigate back to its origin. On an edge this is the record that asserted the relationship (the meaningful provenance, kept last-writer since the edge is rewritten on each observation to maintain its validity window). On a node it is the first record the entity was seen in (first-writer, so a re-observed node’s stored bytes stay stable). Excluded from the content-addressed id, so it never affects identity or idempotent upsert. The complete history is the source log, which the projector can replay. Absent on the wire when unknown.

Variants

Message

A record on the message log, by numeric stream id, topic id, partition, and offset. Ids, not names: the pointer is route-ready and survives a rename. The conversation is the record’s gen_ai.conversation.id, kept for the conversation lens but excluded from the content-addressed id, so the same element re-observed from another conversation keeps its identity. Omitted on the wire when unset.

Fields

stream: u32

topic: u32

partition: u32

offset: u64

conversation: Option<String>

Kv

A key in the managed key-value store.

Fields

namespace: String

key: String

Memory

A managed memory item, by its id.

Fields

id: String

Trait Implementations

impl Clone for SourceRef

fn clone(&self) -> SourceRef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceRef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceRef

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SourceRef

impl PartialEq for SourceRef

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SourceRef

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 SourceRef