Function rusteron_archive::bindings::aeron_archive_replay_merge_init
source ยท pub unsafe extern "C" fn aeron_archive_replay_merge_init(
replay_merge: *mut *mut aeron_archive_replay_merge_t,
subscription: *mut aeron_subscription_t,
aeron_archive: *mut aeron_archive_t,
replay_channel: *const c_char,
replay_destination: *const c_char,
live_destination: *const c_char,
recording_id: i64,
start_position: i64,
epoch_clock: c_longlong,
merge_progress_timeout_ms: i64,
) -> c_int
Expand description
Create an aeron_archive_replay_merge_t to manage the merging of a replayed stream into a live stream.
@param replay_merge the aeron_archive_replay_merge_t to create and initialize @param subscription the subscription to use for the replay and live stream. Must be a multi-destination subscription @param aeron_archive the archive client @param replay_channel the channel to use for the replay @param replay_destination the replay channel to use for the destination added by the subscription @param live_destination the live stream channel to use for the destination added by the subscription @param recording_id the recording id of the archive to replay @param start_position the start position of the replay @param epoch_clock the clock to use for progress checks @param merge_progress_timeout_ms the timeout to use for progress checks @return 0 for success, -1 for failure