Struct zenoh_config::AggregationConf

pub struct AggregationConf { /* private fields */ }

Implementations

impl AggregationConf

pub fn validate(&self) -> bool

pub fn new( subscribers: Vec<OwnedKeyExpr>, publishers: Vec<OwnedKeyExpr> ) -> Result<Self, Self>

pub fn subscribers(&self) -> &Vec<OwnedKeyExpr>

A list of key-expressions for which all included subscribers will be aggregated into.

pub fn set_subscribers( &mut self, value: Vec<OwnedKeyExpr> ) -> Result<Vec<OwnedKeyExpr>, Vec<OwnedKeyExpr>>

A list of key-expressions for which all included subscribers will be aggregated into.

pub fn publishers(&self) -> &Vec<OwnedKeyExpr>

A list of key-expressions for which all included publishers will be aggregated into.

pub fn set_publishers( &mut self, value: Vec<OwnedKeyExpr> ) -> Result<Vec<OwnedKeyExpr>, Vec<OwnedKeyExpr>>

A list of key-expressions for which all included publishers will be aggregated into.

impl AggregationConf

pub fn from_deserializer<'d, D: Deserializer<'d>>( d: D ) -> Result<Self, Result<Self, D::Error>>

where Self: Deserialize<'d>,

Trait Implementations

impl Clone for AggregationConf

fn clone(&self) -> AggregationConf

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AggregationConf

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

Formats the value using the given formatter.

impl Default for AggregationConf

fn default() -> AggregationConf

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AggregationConf

where AggregationConf: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AggregationConf

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ValidatedMap for AggregationConf

fn insert<'d, D: Deserializer<'d>>( &mut self, key: &str, value: D ) -> Result<(), InsertionError>

where InsertionError: From<D::Error>,

fn get<'a>(&'a self, key: &str) -> Result<&dyn Any, GetError>

fn get_json(&self, key: &str) -> Result<String, GetError>

type Keys = Vec<String>

fn keys(&self) -> Self::Keys

fn insert_json5(&mut self, key: &str, value: &str) -> Result<(), InsertionError>

impl<'a> ValidatedMapAssociatedTypes<'a> for AggregationConf

type Accessor = &'a (dyn Any + 'static)