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