Struct PersistenceSchema 

pub struct PersistenceSchema { /* private fields */ }

Declares the Attributes, Channels, and Streams a Flow owns.

Return a schema from crate::Flow::persistence. Definitions must have unique names, and all values accessed by Step or RPC code must appear in the schema.

Examples

use dex_sdk::{Attribute, Channel, PersistenceSchema};

let status = Attribute::<String>::new("status");
let commands = Channel::<String>::new("commands");
let schema = PersistenceSchema::new().attribute(&status).channel(&commands);

Implementations

impl PersistenceSchema

pub fn new() -> Self

Creates an empty schema.

pub fn attribute<T>(self, attribute: &Attribute<T>) -> Self

Adds one single-value Attribute definition.

pub fn attribute_map<T>(self, attribute: &AttributeMap<T>) -> Self

Adds one keyed Attribute-map definition.

pub fn channel<T>(self, channel: &Channel<T>) -> Self

Adds one Channel definition.

pub fn channel_map<T>(self, channel: &ChannelMap<T>) -> Self

Adds one keyed Channel-map definition.

pub fn join<T>(self, join: &Join<T>) -> Self

Adds one Join definition.

A Join registers as the keyed Channel map that holds its branch results, under the Join’s name. The name must differ from every other definition in the Flow, including Channels and Channel maps; registration otherwise fails with a Flow definition error.

Since 1.44.0.

pub fn stream<T>(self, stream: &Stream<T>) -> Self

Adds one best-effort Stream definition.

Trait Implementations

impl Clone for PersistenceSchema

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PersistenceSchema

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

Formats the value using the given formatter.

impl Default for PersistenceSchema

fn default() -> Self

Returns the “default value” for a type.

impl Eq for PersistenceSchema

impl PartialEq for PersistenceSchema

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

Equality operator ==.

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

Inequality operator !=.