pub struct AeronArchiveReplicationParamsBuilder { /* private fields */ }Expand description
Fluent builder for AeronArchiveReplicationParams, starting from aeron’s defaults:
replicate into a new recording at the destination, no live merge, the context’s
default replication channel, and no credentials.
Implementations§
Source§impl AeronArchiveReplicationParamsBuilder
impl AeronArchiveReplicationParamsBuilder
Sourcepub fn stop_position(self, position: i64) -> Self
pub fn stop_position(self, position: i64) -> Self
Stop the replication at this position (default: continuous until synced).
Sourcepub fn extend_recording(self, dst_recording_id: i64) -> Self
pub fn extend_recording(self, dst_recording_id: i64) -> Self
Extend this existing recording at the destination (default: create a new one).
Sourcepub fn live_destination(self, destination: &str) -> Self
pub fn live_destination(self, destination: &str) -> Self
Merge to this live destination once caught up (default: no merge).
Sourcepub fn replication_channel(self, channel: &str) -> Self
pub fn replication_channel(self, channel: &str) -> Self
Channel to replicate over (default: the context’s replication channel).
Sourcepub fn src_response_channel(self, channel: &str) -> Self
pub fn src_response_channel(self, channel: &str) -> Self
Source archive response channel when replicating over response channels.
Sourcepub fn channel_tag_id(self, tag: i64) -> Self
pub fn channel_tag_id(self, tag: i64) -> Self
Tag for the destination archive’s replication subscription channel.
Sourcepub fn subscription_tag_id(self, tag: i64) -> Self
pub fn subscription_tag_id(self, tag: i64) -> Self
Subscription tag for the destination archive’s replication subscription.
Sourcepub fn file_io_max_length(self, length: i32) -> Self
pub fn file_io_max_length(self, length: i32) -> Self
Maximum size of a file IO operation during the replay driving the replication.
Sourcepub fn replication_session_id(self, session_id: i32) -> Self
pub fn replication_session_id(self, session_id: i32) -> Self
Session id for the replicated recording (default: keep the source’s session id).
Sourcepub fn encoded_credentials(self, credentials: &str) -> Self
pub fn encoded_credentials(self, credentials: &str) -> Self
Credentials passed to the source archive (simple authentication only).
pub fn build(self) -> Result<AeronArchiveReplicationParamsOwned, AeronCError>
Trait Implementations§
Source§impl Clone for AeronArchiveReplicationParamsBuilder
impl Clone for AeronArchiveReplicationParamsBuilder
Source§fn clone(&self) -> AeronArchiveReplicationParamsBuilder
fn clone(&self) -> AeronArchiveReplicationParamsBuilder
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more