Struct eventstore_tcp::raw::client_messages::CreatePersistentSubscription
[−]
[src]
pub struct CreatePersistentSubscription<'a> { pub subscription_group_name: Cow<'a, str>, pub event_stream_id: Cow<'a, str>, pub resolve_link_tos: bool, pub start_from: i32, pub message_timeout_milliseconds: i32, pub record_statistics: bool, pub live_buffer_size: i32, pub read_batch_size: i32, pub buffer_size: i32, pub max_retry_count: i32, pub prefer_round_robin: bool, pub checkpoint_after_time: i32, pub checkpoint_max_count: i32, pub checkpoint_min_count: i32, pub subscriber_max_count: i32, pub named_consumer_strategy: Option<Cow<'a, str>>, }
Fields
subscription_group_name: Cow<'a, str>
event_stream_id: Cow<'a, str>
resolve_link_tos: bool
start_from: i32
message_timeout_milliseconds: i32
record_statistics: bool
live_buffer_size: i32
read_batch_size: i32
buffer_size: i32
max_retry_count: i32
prefer_round_robin: bool
checkpoint_after_time: i32
checkpoint_max_count: i32
checkpoint_min_count: i32
subscriber_max_count: i32
named_consumer_strategy: Option<Cow<'a, str>>
Methods
impl<'a> CreatePersistentSubscription<'a>
[src]
fn from_reader(r: &mut BytesReader, bytes: &'a [u8]) -> Result<Self>
Trait Implementations
impl<'a> Debug for CreatePersistentSubscription<'a>
[src]
impl<'a> Default for CreatePersistentSubscription<'a>
[src]
fn default() -> CreatePersistentSubscription<'a>
Returns the "default value" for a type. Read more
impl<'a> PartialEq for CreatePersistentSubscription<'a>
[src]
fn eq(&self, __arg_0: &CreatePersistentSubscription<'a>) -> bool
This method tests for self
and other
values to be equal, and is used by ==
. Read more
fn ne(&self, __arg_0: &CreatePersistentSubscription<'a>) -> bool
This method tests for !=
.
impl<'a> Clone for CreatePersistentSubscription<'a>
[src]
fn clone(&self) -> CreatePersistentSubscription<'a>
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0
Performs copy-assignment from source
. Read more
impl<'a> MessageWrite for CreatePersistentSubscription<'a>
[src]
fn get_size(&self) -> usize
Computes necessary binary size of self once serialized in protobuf
fn write_message<W: Write>(&self, w: &mut Writer<W>) -> Result<()>
Writes Self
into W writer
fn write_file<P>(&self, p: P) -> Result<(), Error> where P: AsRef<Path>
Writes self into a file