Enum ShapeType 

#[non_exhaustive]
pub enum ShapeType {
    Document {
        collection: String,
        predicate: Vec<u8>,
    },
    Graph {
        root_nodes: Vec<String>,
        max_depth: usize,
        edge_label: Option<String>,
    },
    Vector {
        collection: String,
        field_name: Option<String>,
    },
    Array {
        array_name: String,
        coord_range: Option<ArrayCoordRange>,
    },
}

Shape type: determines how mutations are evaluated for inclusion.

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.

Document

Document shape: all documents in a collection matching a predicate.

Predicate is serialized filter bytes (MessagePack). Empty = all documents.

Fields

collection: String

predicate: Vec<u8>

Serialized predicate bytes. Empty = no filter (all documents).

Graph

Graph shape: N-hop subgraph from root nodes.

Includes all nodes and edges reachable within max_depth hops from the root nodes. Edge label filter is optional.

Fields

root_nodes: Vec<String>

max_depth: usize

edge_label: Option<String>

Vector

Vector shape: all vectors in a collection/namespace.

Optionally filtered by field_name (named vector fields).

Fields

collection: String

field_name: Option<String>

Array

Array shape: all ops on a named ND-array within an optional coordinate range.

coord_range = None means “subscribe to all ops on this array”. When set, only ops whose coord falls within the range are delivered.

Fields

array_name: String

coord_range: Option<ArrayCoordRange>

Trait Implementations

impl Archive for ShapeType

where String: Archive, Vec<u8>: Archive, Vec<String>: Archive, usize: Archive, Option<String>: Archive, Option<ArrayCoordRange>: Archive,

type Archived = ArchivedShapeType

The archived representation of this type.

type Resolver = ShapeTypeResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

fn resolve( &self, resolver: <Self as Archive>::Resolver, out: Place<<Self as Archive>::Archived>, )

Creates the archived version of this value at the given position and writes it to the given output.

const COPY_OPTIMIZATION: CopyOptimization<Self> = _

An optimization flag that allows the bytes of this type to be copied directly to a writer instead of calling serialize.

impl Clone for ShapeType

fn clone(&self) -> ShapeType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShapeType

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ShapeType

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<__D: Fallible + ?Sized> Deserialize<ShapeType, __D> for Archived<ShapeType>

where String: Archive, <String as Archive>::Archived: Deserialize<String, __D>, Vec<u8>: Archive, <Vec<u8> as Archive>::Archived: Deserialize<Vec<u8>, __D>, Vec<String>: Archive, <Vec<String> as Archive>::Archived: Deserialize<Vec<String>, __D>, usize: Archive, <usize as Archive>::Archived: Deserialize<usize, __D>, Option<String>: Archive, <Option<String> as Archive>::Archived: Deserialize<Option<String>, __D>, Option<ArrayCoordRange>: Archive, <Option<ArrayCoordRange> as Archive>::Archived: Deserialize<Option<ArrayCoordRange>, __D>,

fn deserialize( &self, deserializer: &mut __D, ) -> Result<ShapeType, <__D as Fallible>::Error>

Deserializes using the given deserializer

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ShapeType

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl<__S: Fallible + ?Sized> Serialize<__S> for ShapeType

where String: Serialize<__S>, Vec<u8>: Serialize<__S>, Vec<String>: Serialize<__S>, usize: Serialize<__S>, Option<String>: Serialize<__S>, Option<ArrayCoordRange>: Serialize<__S>,

fn serialize( &self, serializer: &mut __S, ) -> Result<<Self as Archive>::Resolver, <__S as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl Serialize for ShapeType

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToMessagePack for ShapeType

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.