Struct AeronArchiveProxy

pub struct AeronArchiveProxy { /* private fields */ }

Implementations

impl AeronArchiveProxy

pub fn new( ctx: &AeronArchiveContext, exclusive_publication: &AeronExclusivePublication, retry_attempts: c_int, ) -> Result<Self, AeronCError>

pub fn ctx(&self) -> AeronArchiveContext

pub fn exclusive_publication(&self) -> AeronExclusivePublication

pub fn control_session_id(&self) -> i64

pub fn retry_attempts(&self) -> c_int

pub fn buffer(&self) -> [u8; 8192]

pub fn init( &self, ctx: &AeronArchiveContext, exclusive_publication: &AeronExclusivePublication, retry_attempts: c_int, ) -> Result<i32, AeronCError>

pub fn set_control_esssion_id( &self, control_session_id: i64, ) -> Result<i32, AeronCError>

pub fn close(&self) -> Result<i32, AeronCError>

pub fn delete(&self) -> Result<i32, AeronCError>

pub fn try_connect( &self, control_response_channel: &str, control_response_stream_id: i32, encoded_credentials: &AeronArchiveEncodedCredentials, correlation_id: i64, ) -> bool

pub fn archive_id(&self, correlation_id: i64) -> bool

pub fn challenge_response( &self, encoded_credentials: &AeronArchiveEncodedCredentials, correlation_id: i64, ) -> bool

pub fn close_session(&self) -> bool

pub fn start_recording( &self, recording_channel: &str, recording_stream_id: i32, local_source: bool, auto_stop: bool, correlation_id: i64, ) -> bool

pub fn get_recording_position( &self, correlation_id: i64, recording_id: i64, ) -> bool

pub fn get_start_position(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn get_stop_position(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn get_max_recorded_position( &self, correlation_id: i64, recording_id: i64, ) -> bool

pub fn stop_recording( &self, correlation_id: i64, channel: &str, stream_id: i32, ) -> bool

pub fn stop_recording_subscription( &self, correlation_id: i64, subscription_id: i64, ) -> bool

pub fn stop_recording_by_identity( &self, correlation_id: i64, recording_id: i64, ) -> bool

pub fn find_last_matching_recording( &self, correlation_id: i64, min_recording_id: i64, channel_fragment: &str, stream_id: i32, session_id: i32, ) -> bool

pub fn list_recording(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn list_recordings( &self, correlation_id: i64, from_recording_id: i64, record_count: i32, ) -> bool

pub fn list_recordings_for_uri( &self, correlation_id: i64, from_recording_id: i64, record_count: i32, channel_fragment: &str, stream_id: i32, ) -> bool

pub fn replay( &self, correlation_id: i64, recording_id: i64, replay_channel: &str, replay_stream_id: i32, params: &AeronArchiveReplayParams, ) -> bool

pub fn truncate_recording( &self, correlation_id: i64, recording_id: i64, position: i64, ) -> bool

pub fn stop_replay(&self, correlation_id: i64, replay_session_id: i64) -> bool

pub fn stop_all_replays(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn list_recording_subscriptions( &self, correlation_id: i64, pseudo_index: i32, subscription_count: i32, channel_fragment: &str, stream_id: i32, apply_stream_id: bool, ) -> bool

pub fn purge_recording(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn extend_recording( &self, recording_id: i64, recording_channel: &str, recording_stream_id: i32, local_source: bool, auto_stop: bool, correlation_id: i64, ) -> bool

pub fn replicate( &self, correlation_id: i64, src_recording_id: i64, src_control_stream_id: i32, src_control_channel: &str, params: &AeronArchiveReplicationParams, ) -> bool

pub fn stop_replication(&self, correlation_id: i64, replication_id: i64) -> bool

pub fn aeron_archive_request_replay_token( &self, correlation_id: i64, recording_id: i64, ) -> bool

pub fn detach_segments( &self, correlation_id: i64, recording_id: i64, new_start_position: i64, ) -> bool

pub fn delete_detached_segments( &self, correlation_id: i64, recording_id: i64, ) -> bool

pub fn purge_segments( &self, correlation_id: i64, recording_id: i64, new_start_position: i64, ) -> bool

pub fn attach_segments(&self, correlation_id: i64, recording_id: i64) -> bool

pub fn migrate_segments( &self, correlation_id: i64, src_recording_id: i64, dst_recording_id: i64, ) -> bool

pub fn get_inner(&self) -> *mut aeron_archive_proxy_t

Trait Implementations

impl Clone for AeronArchiveProxy

fn clone(&self) -> AeronArchiveProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AeronArchiveProxy

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

Formats the value using the given formatter.

impl Deref for AeronArchiveProxy

type Target = aeron_archive_proxy_stct

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<&AeronArchiveProxy> for *mut aeron_archive_proxy_t

fn from(value: &AeronArchiveProxy) -> Self

Converts to this type from the input type.

impl From<*const aeron_archive_proxy_stct> for AeronArchiveProxy

fn from(value: *const aeron_archive_proxy_t) -> Self

Converts to this type from the input type.

impl From<*mut aeron_archive_proxy_stct> for AeronArchiveProxy

fn from(value: *mut aeron_archive_proxy_t) -> Self

Converts to this type from the input type.

impl From<AeronArchiveProxy> for *mut aeron_archive_proxy_t

fn from(value: AeronArchiveProxy) -> Self

Converts to this type from the input type.

impl From<AeronArchiveProxy> for aeron_archive_proxy_t

fn from(value: AeronArchiveProxy) -> Self

Converts to this type from the input type.

impl From<aeron_archive_proxy_stct> for AeronArchiveProxy

fn from(value: aeron_archive_proxy_t) -> Self

Converts to this type from the input type.