[−][src]Struct aeron_rs::concurrent::logbuffer::buffer_claim::BufferClaim
Represents a claimed range in a buffer to be used for recording a message without copy semantics for later commit.
The claimed space is in {@link #buffer()} between {@link #offset()} and {@link #offset()} + {@link #length()}. When the buffer is filled with message data, use {@link #commit()} to make it available to subscribers.
Methods
impl BufferClaim
[src]
pub fn wrap(&mut self, buffer: *mut u8, length: Index)
[src]
pub fn wrap_with_offset(
&mut self,
buffer: &AtomicBuffer,
offset: Index,
length: Index
)
[src]
&mut self,
buffer: &AtomicBuffer,
offset: Index,
length: Index
)
pub fn buffer(&self) -> AtomicBuffer
[src]
The buffer to be used.
@return the buffer to be used..
pub const fn offset(&self) -> Index
[src]
The offset in the buffer at which the claimed range begins.
@return offset in the buffer at which the range begins.
pub fn length(&self) -> Index
[src]
The length of the claimed range in the buffer.
@return length of the range in the buffer.
pub fn flags(&self) -> u8
[src]
Get the value of the flags field.
@return the value of the header flags field.
pub fn set_flags(&mut self, flags: u8) -> &Self
[src]
Set the value of the header flags field.
@param flags value to be set in the header. @return this for a fluent API.
pub fn header_type(&self) -> u16
[src]
Get the value of the header type field.
@return the value of the header type field.
pub fn set_header_type(&mut self, header_type: u16) -> &Self
[src]
Set the value of the header type field.
@param type value to be set in the header. @return this for a fluent API.
pub fn reserved_value(&self) -> i64
[src]
Get the value stored in the reserve space at the end of a data frame header.
@return the value stored in the reserve space at the end of a data frame header.
pub fn set_reserved_value(&mut self, value: i64) -> &Self
[src]
Write the provided value into the reserved space at the end of the data frame header.
@param value to be stored in the reserve space at the end of a data frame header. @return this for fluent API semantics.
pub fn commit(&mut self)
[src]
Commit the message to the log buffer so that is it available to subscribers.
pub fn abort(&mut self)
[src]
Abort a claim of the message space to the log buffer so that log can progress ignoring this claim.
Trait Implementations
impl Clone for BufferClaim
[src]
fn clone(&self) -> BufferClaim
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for BufferClaim
[src]
impl Default for BufferClaim
[src]
fn default() -> BufferClaim
[src]
Auto Trait Implementations
impl RefUnwindSafe for BufferClaim
impl !Send for BufferClaim
impl !Sync for BufferClaim
impl Unpin for BufferClaim
impl UnwindSafe for BufferClaim
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,