Skip to main content

EventRow

Struct EventRow 

Source
pub struct EventRow<'a> { /* private fields */ }
Expand description

Zero-copy, read-only accessor for a fixed-layout event row.

All field accessors are #[inline] for compiled-code performance. Type correctness is validated with debug_assert (zero overhead in release builds).

Implementations§

Source§

impl<'a> EventRow<'a>

Source

pub fn new(data: &'a [u8], schema: &'a RowSchema) -> Self

Creates an EventRow from a byte slice and schema.

§Panics

Debug-asserts that data.len() >= schema.min_row_size().

Source

pub fn data(&self) -> &'a [u8]

Returns the underlying byte slice.

Source

pub fn schema(&self) -> &'a RowSchema

Returns the schema.

Source

pub fn is_null(&self, field_idx: usize) -> bool

Returns true if the field at field_idx is null.

Null bitmap convention: bit = 1 means null, bit = 0 means valid.

Source

pub fn get_bool(&self, field_idx: usize) -> bool

Reads a bool field.

Source

pub fn get_i8(&self, field_idx: usize) -> i8

Reads an i8 field.

Source

pub fn get_i16(&self, field_idx: usize) -> i16

Reads an i16 field.

Source

pub fn get_i32(&self, field_idx: usize) -> i32

Reads an i32 field.

Source

pub fn get_i64(&self, field_idx: usize) -> i64

Reads an i64 field. Also accepts FieldType::TimestampMicros.

Source

pub fn get_u8(&self, field_idx: usize) -> u8

Reads a u8 field.

Source

pub fn get_u16(&self, field_idx: usize) -> u16

Reads a u16 field.

Source

pub fn get_u32(&self, field_idx: usize) -> u32

Reads a u32 field.

Source

pub fn get_u64(&self, field_idx: usize) -> u64

Reads a u64 field.

Source

pub fn get_f32(&self, field_idx: usize) -> f32

Reads an f32 field.

Source

pub fn get_f64(&self, field_idx: usize) -> f64

Reads an f64 field.

Source

pub fn get_str(&self, field_idx: usize) -> &'a str

Reads a variable-length UTF-8 string field.

Source

pub fn get_bytes(&self, field_idx: usize) -> &'a [u8]

Reads a variable-length binary field.

Source

pub fn field_ptr(&self, field_idx: usize) -> *const u8

Returns a raw pointer to the field’s inline data for JIT code.

Source

pub fn timestamp(&self) -> i64

Convenience: reads field 0 as i64 (convention: field 0 is event time).

Trait Implementations§

Source§

impl<'a> Debug for EventRow<'a>

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a> Freeze for EventRow<'a>

§

impl<'a> RefUnwindSafe for EventRow<'a>

§

impl<'a> Send for EventRow<'a>

§

impl<'a> Sync for EventRow<'a>

§

impl<'a> Unpin for EventRow<'a>

§

impl<'a> UnsafeUnpin for EventRow<'a>

§

impl<'a> UnwindSafe for EventRow<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
§

impl<T> ArchivePointee for T

§

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.
§

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

impl<T> LayoutRaw for T

§

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Returns the layout of the type.
§

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

§

unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool

Returns whether the given value has been niched. Read more
§

fn resolve_niched(out: Place<NichedOption<T, N1>>)

Writes data to out indicating that a T is niched.
§

impl<T> Pointee for T

§

type Metadata = ()

The metadata type for pointers and references to this type.
§

impl<T> PolicyExt for T
where T: ?Sized,

§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more
§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
§

impl<T> Scope for T

§

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,

Scoped with ownership.
§

fn with_ref<F, R>(&self, f: F) -> R
where F: FnOnce(&Self) -> R,

Scoped with reference.
§

fn with_mut<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut Self) -> R,

Scoped with mutable reference.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

§

impl<T> Value for T
where T: Send + Sync + 'static,