Struct AeronExclusivePublication

Source

pub struct AeronExclusivePublication { /* private fields */ }

Implementations§

Source §

impl AeronExclusivePublication

Source

pub fn new( async_: &AeronAsyncAddExclusivePublication, ) -> Result<Self, AeronCError>

Source §

impl AeronExclusivePublication

Source

pub fn new_zeroed_on_heap() -> Self

creates zeroed struct where the underlying c struct is on the heap

Source

pub fn new_zeroed_on_stack() -> Self

creates zeroed struct where the underlying c struct is on the stack (Use with care)

Source

pub fn offerv<AeronReservedValueSupplierHandlerImpl: AeronReservedValueSupplierCallback>( &self, iov: &AeronIovec, iovcnt: usize, reserved_value_supplier: Option<&Handler<AeronReservedValueSupplierHandlerImpl>>, ) -> i64

Non-blocking publish by gathering buffer vectors into a message.

§Parameters

iov array for the vectors
iovcnt of the number of vectors
reserved_value_supplier to use for setting the reserved value field or NULL.
clientd to pass to the reserved_value_supplier.

§Return

the new stream position otherwise a negative error value.

Source

pub fn offerv_fn<AeronReservedValueSupplierHandlerImpl: FnMut(&mut [u8]) -> i64>( &self, iov: &AeronIovec, iovcnt: usize, reserved_value_supplier: AeronReservedValueSupplierHandlerImpl, ) -> i64

Non-blocking publish by gathering buffer vectors into a message.

§Parameters

iov array for the vectors
iovcnt of the number of vectors
reserved_value_supplier to use for setting the reserved value field or NULL.
clientd to pass to the reserved_value_supplier.

§Return

the new stream position otherwise a negative error value.

Stack-borrowed closure (_fn variant): the FnMut closure lives on the caller’s stack and is borrowed for this call only — the callback fires synchronously inside the call, so nothing is heap-allocated, nothing is stored, and the closure may borrow local state. Prefer this over the retained Handler-based form on the hot path; only generated for callbacks the C client does not retain (i.e. not stored for later firing).

§Panics

A panic inside the closure cannot unwind across the extern "C" callback boundary and aborts the process (since Rust 1.81). Return early instead of panicking in production fragment handlers.

Source

pub fn append_padding(&self, length: usize) -> i64

Append a padding record log of a given length to make up the log to a position.

§Parameters

length of the range to claim, in bytes.

§Return

the new stream position otherwise a negative error value.

Source

pub fn offer_block(&self, buffer: &[u8]) -> i64

Offer a block of pre-formatted message fragments directly into the current term.

§Parameters

buffer containing the pre-formatted block of message fragments.
offset offset in the buffer at which the first fragment begins.

§Return

the new stream position otherwise a negative error value.

Source

pub fn channel_status(&self) -> i64

Get the status of the media channel for this publication.

The status will be ERRORED (-1) if a socket exception occurs on setup and ACTIVE (1) if all is well.

§Return

1 for ACTIVE, -1 for ERRORED

Source

pub fn constants( &self, constants: &AeronPublicationConstants, ) -> Result<i32, AeronCError>

Fill in a structure with the constants in use by a publication.

§Parameters

publication to get the constants for.
constants structure to fill in with the constants

§Return

0 for success and -1 for error.

Source

pub fn get_constants(&self) -> Result<AeronPublicationConstants, AeronCError>

Fill in a structure with the constants in use by a publication.

Source

pub fn position(&self) -> i64

Get the current position to which the publication has advanced for this stream.

§Return

the current position to which the publication has advanced for this stream or a negative error value.

Source

pub fn position_limit(&self) -> i64

Get the position limit beyond which this publication will be back pressured.

This should only be used as a guide to determine when back pressure is likely to be applied.

§Return

the position limit beyond which this publication will be back pressured or a negative error value.

Source

pub fn revoke_on_close(&self)

Revoke this publication when it’s closed.

Source

pub fn revoke<AeronNotificationHandlerImpl: AeronNotificationCallback + 'static>( &self, on_close_complete: Option<AeronNotificationHandlerImpl>, ) -> Result<Option<Handler<AeronNotificationHandlerImpl>>, AeronCError>

Asynchronously revoke and close the publication. Will callback on the on_complete notification when the publicaiton is closed. The callback is optional, use NULL for the on_complete callback if not required.

§Parameters

on_close_complete optional callback to execute once the publication has been revoked, closed and freed. This may happen on a separate thread, so the caller should ensure that clientd has the appropriate lifetime.
on_close_complete_clientd parameter to pass to the on_complete callback.

§Return

0 for success or -1 for error.

The callback is retained by the C client; this resource keeps it alive automatically. Returns the created Handler for optional state access — safe to ignore. Closures with a matching signature are accepted directly.

Source

pub fn is_closed(&self) -> bool

Has the exclusive publication closed?

§Return

true if this publication is closed.

Source

pub fn is_connected(&self) -> bool

Has the exclusive publication seen an active Subscriber recently?

§Return

true if this publication has recently seen an active subscriber otherwise false.

Source

pub fn local_sockaddrs( &self, address_vec: &AeronIovec, address_vec_len: usize, ) -> Result<i32, AeronCError>

Get all of the local socket addresses for this exclusive publication. Typically only one representing the control address.

@see aeron_subscription_local_sockaddrs

§Parameters

address_vec to hold the received addresses
address_vec_len available length of the vector to hold the addresses

§Return

number of addresses found or -1 if there is an error.

Source

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

Source

pub unsafe fn get_inner_mut(&self) -> &mut aeron_exclusive_publication_t

Mutable access to the underlying C struct, minted from &self: nothing prevents two live &mut at once, so the caller must ensure exclusive access for the lifetime of the returned reference.

§Safety

No other reference (& or &mut) to the underlying struct may be alive while the returned &mut is in use.

Source

pub fn get_inner_ref(&self) -> &aeron_exclusive_publication_t

Source §

impl AeronExclusivePublication

Source

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

Closes this resource in the C client immediately; all clones of this handle become closed (their pointer is nulled) and must not be used.

Source §

impl AeronExclusivePublication

Source

pub fn close_with_handler<AeronNotificationHandlerImpl: AeronNotificationCallback>( self, on_close_complete: Option<&Handler<AeronNotificationHandlerImpl>>, ) -> Result<(), AeronCError>

Like Self::close, but notifies on_close_complete when the close finishes. The handler must outlive the notification (keep your Handler alive until it has fired).

Source §

pub fn async_add_destination( &self, client: &Aeron, destination: &CStr, ) -> Result<AeronAsyncDestination, AeronCError>

Source

pub fn add_destination( &self, destination: &CStr, timeout: Duration, ) -> Result<(), AeronCError>

Add destination (see AeronSubscription::add_destination); the owning Aeron client is retrieved from the publication’s dependency graph.

Source §

impl AeronExclusivePublication

Source

pub fn offer_raw<H: AeronReservedValueSupplierCallback>( &self, buffer: &[u8], reserved_value_supplier: Option<&Handler<H>>, ) -> i64

Raw, branch-free variant of Self::offer: returns the new stream position, or a negative Aeron sentinel (see AeronOfferError::from_position).

Distinct name from the generated offer method (different signatures) to avoid macro-hygiene name conflicts.

Source

pub fn try_claim_raw( &self, length: usize, buffer_claim: &AeronBufferClaim, ) -> i64

Raw, branch-free variant of Self::try_claim: position or negative sentinel.

Source

pub fn offer_with_reserved_value<H: AeronReservedValueSupplierCallback>( &self, buffer: &[u8], reserved_value_supplier: Option<&Handler<H>>, ) -> Result<i64, AeronOfferError>

Self::offer with a reserved-value supplier.

Source

pub fn try_claim_owned( &self, length: usize, ) -> Result<AeronClaim, AeronOfferError>

Zero-copy claim returning a RAII AeronClaim that is auto-aborted on drop unless explicitly committed or aborted.

Source

pub fn offer_parts(&self, parts: &[&[u8]]) -> Result<i64, AeronOfferError>

Gathering (vectored) publish: offer up to MAX_OFFER_PARTS buffers as ONE message without concatenating them — zero allocation, zero copy on the caller side (the driver gathers the parts directly).

This is the header+payload send: instead of building a Vec per message (vec.extend(header); vec.extend(payload); offer(&vec)), pass the parts:

publication.offer_parts(&[&header_bytes, payload])?;

The aeron_iovec_t array is built on the stack. Same typed-error semantics as Self::offer. Returns AeronOfferError::TooManyParts if more than MAX_OFFER_PARTS parts are passed (use Self::offerv with your own iovec array for larger gathers).

Source

pub fn status(&self) -> AeronStatus

High-level connection state derived from the publication handle.

Source

pub fn registration_id(&self) -> Result<i64, AeronCError>

Convenience accessor for the registration id (no direct C accessor exists; backed by Self::get_constants). session_id, stream_id and channel have cheap direct getters — prefer those; for registration_id / max_payload_length in a hot loop, call Self::get_constants once and reuse the returned AeronPublicationConstants.

Source