Struct EndpointRegistry 

pub struct EndpointRegistry { /* private fields */ }

Available on crate feature server only.

A registry that holds the sources and sinks of a simulation bench.

Implementations

impl EndpointRegistry

pub fn new() -> Self

Creates a new, empty registry.

pub fn add_event_source<T>( &mut self, source: EventSource<T>, name: impl Into<String>, ) -> Result<(), EventSource<T>>

where T: DeserializeOwned + Clone + Send + 'static,

Adds an event source to the registry.

If the specified name is already in use for another event source, the source provided as argument is returned in the error.

pub fn add_query_source<T, R>( &mut self, source: QuerySource<T, R>, name: impl Into<String>, ) -> Result<(), QuerySource<T, R>>

where T: DeserializeOwned + Clone + Send + 'static, R: Serialize + Send + 'static,

Adds a query source to the registry.

If the specified name is already in use for another query source, the source provided as argument is returned in the error.

pub fn add_event_sink<S>( &mut self, sink: S, name: impl Into<String>, ) -> Result<(), S>

where S: EventSinkReader + Send + Sync + 'static, S::Item: Serialize,

Adds an event sink to the registry.

If the specified name is already in use for another event sink, the event sink provided as argument is returned in the error.

Trait Implementations

impl Debug for EndpointRegistry

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

Formats the value using the given formatter.

impl Default for EndpointRegistry

fn default() -> EndpointRegistry

Returns the “default value” for a type.