Enum Value 

#[non_exhaustive]
pub enum Value {
    Tensor {
        values: Arc<Vec<f64>>,
        shape: Vec<usize>,
    },
    Text(Arc<str>),
    Json(Arc<Value>),
    Bytes(Arc<Vec<u8>>),
    Object(Arc<Vec<u8>>),
    Empty,
}

Typed values flowing between filters in a pipeline.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Tensor

Numeric tensor data (shape + flat data). values is wrapped in Arc so that cloning a Value is O(1).

Fields

values: Arc<Vec<f64>>

Flat data in row-major order; Arc-shared, never mutated in place.

shape: Vec<usize>

Dimension sizes; the product must equal values.len().

Text(Arc<str>)

UTF-8 text (Arc-wrapped for cheap cloning).

Distinct from Json(String): a prompt or completion is text, not a JSON document that happens to be a string. Keeping them apart means no round-trip through quoting/escaping on every hop, and lets a schema say “this edge carries text” — see crate::schema::DataType.

Json(Arc<Value>)

Structured JSON data (Arc-wrapped for cheap cloning).

Bytes(Arc<Vec<u8>>)

Raw bytes (Arc-wrapped for cheap cloning).

Object(Arc<Vec<u8>>)

Opaque serialized object (e.g. Python pickle). Soma passes it through without interpreting the contents. Used for efficient inter-filter data transfer when the producing and consuming runtimes share a serialization format.

Empty

Empty / void value

Implementations

impl Value

pub fn tensor(values: Vec<f64>, shape: Vec<usize>) -> Self

Create a tensor from flat row-major data and a shape.

pub fn text(s: impl AsRef<str>) -> Self

Create a text value.

pub fn json(val: Value) -> Self

Create a JSON value.

pub fn bytes(data: Vec<u8>) -> Self

Create a raw bytes value.

pub fn object(data: Vec<u8>) -> Self

Create an opaque serialized object (e.g. a Python pickle).

pub fn is_empty(&self) -> bool

Is this the Value::Empty variant?

pub fn as_tensor(&self) -> Option<(&[f64], &[usize])>

Try to extract tensor data.

pub fn as_text(&self) -> Option<&str>

Try to extract text.

A Json string counts: a filter that returns "hello" as JSON and one that returns it as text should both satisfy a consumer wanting text.

pub fn as_json(&self) -> Option<&Value>

Try to extract JSON value.

pub fn to_plain_json(&self) -> Value

Natural JSON form for user-facing fan-in: tensors become (nested) number arrays, Json unwraps, Empty is null. This is what a multi-predecessor node receives per upstream branch — never the internal serde-tagged encoding.

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

Short name of the variant, for error messages.

Unlike Display this never renders the payload, so it is safe to put in an error that may reach a log — a JSON value can hold a prompt.

pub fn size(&self) -> usize

Number of elements (for tensors) or bytes.

Trait Implementations

impl Clone for Value

fn clone(&self) -> Value

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Value

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Value

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Value

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

Formats the value using the given formatter.

impl From<Value> for Value

fn from(v: Value) -> Self

Converts to this type from the input type.

impl From<Value> for VirtualValue

fn from(value: Value) -> Self

Converts to this type from the input type.

impl From<Vec<f64>> for Value

fn from(values: Vec<f64>) -> Self

Converts to this type from the input type.

impl PartialEq for Value

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Value

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 Value