pub struct SyncGroup {
pub name: String,
pub policy: SyncPolicy,
pub backpressure: Option<BackpressureStrategy>,
pub capacity: Option<usize>,
pub ports: Vec<String>,
}Expand description
Sync grouping metadata for a node.
use daedalus_core::sync::{SyncGroup, SyncPolicy};
let group = SyncGroup {
name: "aligned".to_string(),
policy: SyncPolicy::AllReady,
backpressure: None,
capacity: Some(4),
ports: vec!["left".into(), "right".into()],
};
assert_eq!(group.ports.len(), 2);Fields§
§name: StringLogical name for the group.
policy: SyncPolicyAlignment policy for this group.
backpressure: Option<BackpressureStrategy>Optional override for backpressure strategy; defaults to engine setting.
capacity: Option<usize>Optional override for buffer capacity; defaults to engine/edge depth.
ports: Vec<String>Ports that participate in this group.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for SyncGroup
impl<'de> Deserialize<'de> for SyncGroup
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl Eq for SyncGroup
impl StructuralPartialEq for SyncGroup
Auto Trait Implementations§
impl Freeze for SyncGroup
impl RefUnwindSafe for SyncGroup
impl Send for SyncGroup
impl Sync for SyncGroup
impl Unpin for SyncGroup
impl UnwindSafe for SyncGroup
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more