Struct ClientConfigBuilder

pub struct ClientConfigBuilder<TypedBuilderFields = ((HashSet<String>,), (), (), ())> { /* private fields */ }

Builder for ClientConfig instances.

See ClientConfig::builder() for more info.

Implementations

impl<__subscriptions, __app_name, __buffer_capacity> ClientConfigBuilder<(__subscriptions, (), __app_name, __buffer_capacity)>

pub fn endpoint( self, endpoint: Uri, ) -> ClientConfigBuilder<(__subscriptions, (Uri,), __app_name, __buffer_capacity)>

Zeek WebSocket endpoint to connect to.

impl<__subscriptions, __endpoint, __buffer_capacity> ClientConfigBuilder<(__subscriptions, __endpoint, (), __buffer_capacity)>

pub fn app_name( self, app_name: impl Into<String>, ) -> ClientConfigBuilder<(__subscriptions, __endpoint, (String,), __buffer_capacity)>

String use by the client to identify itself against Zeek.

impl<__subscriptions, __endpoint, __app_name> ClientConfigBuilder<(__subscriptions, __endpoint, __app_name, ())>

pub fn buffer_capacity( self, buffer_capacity: usize, ) -> ClientConfigBuilder<(__subscriptions, __endpoint, __app_name, (usize,))>

How many events to buffer before exerting backpressure.

impl<__endpoint, __app_name, __buffer_capacity> ClientConfigBuilder<((HashSet<String>,), __endpoint, __app_name, __buffer_capacity)>

pub fn subscribe<S: Into<String>>( self, topic: S, ) -> ClientConfigBuilder<((HashSet<String>,), __endpoint, __app_name, __buffer_capacity)>

Subscribe to topic to receive events.

impl<__buffer_capacity: Optional<usize>> ClientConfigBuilder<((HashSet<String>,), (Uri,), (String,), __buffer_capacity)>

pub fn build(self) -> Result<Client, Error>

Finalise the builder and create its ClientConfig instance

Trait Implementations

impl<TypedBuilderFields> Clone for ClientConfigBuilder<TypedBuilderFields>

where TypedBuilderFields: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.