Struct aeron_archive_replication_params_stct

#[repr(C)]
pub struct aeron_archive_replication_params_stct {
    pub stop_position: i64,
    pub dst_recording_id: i64,
    pub live_destination: *const c_char,
    pub replication_channel: *const c_char,
    pub src_response_channel: *const c_char,
    pub channel_tag_id: i64,
    pub subscription_tag_id: i64,
    pub file_io_max_length: i32,
    pub replication_session_id: i32,
    pub encoded_credentials: *mut aeron_archive_encoded_credentials_t,
}

Struct containing the available replication parameters.

Fields

stop_position: i64

The stop position for the replication. The default of AERON_NULL_VALUE indicates a continuous replication.

dst_recording_id: i64

The recording id of the destination Archive to extend. The default of AERON_NULL_VALUE triggers the creation of a new recording at the destination Archive.

live_destination: *const c_char

Specify the destination for the live stream if a merge is required. The default of an empty string means no merge will occur.

replication_channel: *const c_char

Specify the channel to use to replicate the recording. The default of an empty string will trigger the use of the context’s default replication channel.

src_response_channel: *const c_char

Specify the control address of the source archive when using response channels during replication.

channel_tag_id: i64

Specify a tag to apply to the channel used by the Archive’s subscription for replication.

subscription_tag_id: i64

Specify a subscription tag to apply to the channel used by the Archive’s subscription for replication.

file_io_max_length: i32

Specify the max length for file IO operations used in the replay.

replication_session_id: i32

Specify session id to be used for the replicated file instead of the session id from the source archive. This is useful in cases where we are replicating the same recording in multiple stages.

encoded_credentials: *mut aeron_archive_encoded_credentials_t

Specify the encoded credentials that will be passed to the source archive for authentication. Currently, only simple authentication (i.e. not challenge/response) is supported for replication.

Trait Implementations

impl Clone for aeron_archive_replication_params_stct

fn clone(&self) -> aeron_archive_replication_params_stct

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for aeron_archive_replication_params_stct

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

Formats the value using the given formatter.

impl Default for aeron_archive_replication_params_stct

fn default() -> Self

Returns the “default value” for a type.

impl From<aeron_archive_replication_params_stct> for AeronArchiveReplicationParams

fn from(value: aeron_archive_replication_params_t) -> Self

Converts to this type from the input type.

impl Hash for aeron_archive_replication_params_stct

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for aeron_archive_replication_params_stct

fn eq(&self, other: &aeron_archive_replication_params_stct) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for aeron_archive_replication_params_stct

impl Eq for aeron_archive_replication_params_stct

impl StructuralPartialEq for aeron_archive_replication_params_stct