Struct EventSystem 

pub struct EventSystem { /* private fields */ }

Owns an event-system directory and creates typed event streams within it.

Implementations

impl EventSystem

pub fn new( event_system_directory: impl AsRef<Path>, ) -> Result<Self, CreateEventSystemError>

Creates an event system directory in the given path, event_system_directory.

Note:

• If the directory path already exists, it must be empty.
• This functions creates the given directory and any missing parents.
• The given path is canonicalized.
• The directory is emptied once this EventSystem, its clones, and all of its streams (including their PublisherFactorys and publishers) are dropped. The directory itself is left in place, and can be reused by a later call to EventSystem::new.

pub fn stub() -> Self

Creates a no-op event system on any platform, including Linux.

No filesystem access is performed. Streams ignore their configuration and policy, and their factories always return publishers that discard events without serializing them.

pub fn create_stream<E: Event>( &self, stream_name: StreamName, stream_config: StreamConfig, ) -> Result<PublisherFactory<E>, CreateStreamError>

Creates a stream named stream_name for event type E and returns its PublisherFactory.

pub fn set_stream_policy(&self, stream_policy: StreamPolicy)

Applies the given StreamPolicy on the streams created by this EventSystem.

The applied stream policy will also be applied to future stream creations of this event system.

Trait Implementations

impl Clone for EventSystem

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 EventSystem

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

Formats the value using the given formatter.