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 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 !=.

impl StructuralPartialEq for PersistenceSchema