Struct rusteron_archive::bindings::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 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 Copy for aeron_archive_replication_params_stct