pub struct QueryResponseOwnedView(/* private fields */);Expand description
Self-contained, 'static owned view of a QueryResponse message.
Wraps ::buffa::OwnedView<QueryResponseView<'static>>: the decoded view and the ::buffa::bytes::Bytes buffer it borrows from travel together, so the handle is 'static and Send + Sync — suitable for async handlers, spawned tasks, and anywhere a 'static bound is required.
Field accessors return borrows tied to &self. Use Self::view to get the full QueryResponseView when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.
Implementations§
Source§impl QueryResponseOwnedView
impl QueryResponseOwnedView
Sourcepub fn decode(bytes: Bytes) -> Result<Self, DecodeError>
pub fn decode(bytes: Bytes) -> Result<Self, DecodeError>
Decode an owned view from a ::buffa::bytes::Bytes buffer.
The view borrows directly from the buffer’s data; the buffer is retained inside the returned handle.
§Errors
Returns ::buffa::DecodeError if the buffer contains invalid
protobuf data.
Sourcepub fn decode_with_options(
bytes: Bytes,
opts: &DecodeOptions,
) -> Result<Self, DecodeError>
pub fn decode_with_options( bytes: Bytes, opts: &DecodeOptions, ) -> Result<Self, DecodeError>
Decode with custom ::buffa::DecodeOptions (recursion limit,
max message size).
§Errors
Returns ::buffa::DecodeError if the buffer is invalid or
exceeds the configured limits.
Sourcepub fn from_owned(msg: &QueryResponse) -> Result<Self, DecodeError>
pub fn from_owned(msg: &QueryResponse) -> Result<Self, DecodeError>
Build from an owned message via an encode → decode round-trip.
§Errors
Returns ::buffa::DecodeError::MessageTooLarge if the
message’s encoded size exceeds the 2 GiB protobuf limit, or
another ::buffa::DecodeError if the re-encoded bytes are
somehow invalid (should not happen for well-formed messages).
Sourcepub fn view(&self) -> &QueryResponseView<'_>
pub fn view(&self) -> &QueryResponseView<'_>
Borrow the full QueryResponseView with its lifetime tied to &self.
Sourcepub fn to_owned_message(&self) -> QueryResponse
pub fn to_owned_message(&self) -> QueryResponse
Convert to the owned message type.
Infallible: this type’s constructors wire-decode their
buffer, and a view produced by wire decoding always
converts. Delegates to ::buffa::OwnedView::to_owned_message,
whose contract also governs handles converted from a raw
::buffa::OwnedView.
Sourcepub fn into_bytes(self) -> Bytes
pub fn into_bytes(self) -> Bytes
Consume the handle, returning the underlying bytes buffer.
Sourcepub fn results(&self) -> &[u8] ⓘ
pub fn results(&self) -> &[u8] ⓘ
Complete Arrow IPC stream containing the result schema and record batches. The schema is present even when the query returns no rows.
Field 1: results
Sourcepub fn sequence_number(&self) -> u64
pub fn sequence_number(&self) -> u64
Highest Store sequence observed. Queries that skip Store reads return the requested floor.
Field 3: sequence_number
Trait Implementations§
Source§impl AsRef<OwnedView<QueryResponseView<'static>>> for QueryResponseOwnedView
impl AsRef<OwnedView<QueryResponseView<'static>>> for QueryResponseOwnedView
Source§fn as_ref(&self) -> &OwnedView<QueryResponseView<'static>>
fn as_ref(&self) -> &OwnedView<QueryResponseView<'static>>
Source§impl Clone for QueryResponseOwnedView
impl Clone for QueryResponseOwnedView
Source§fn clone(&self) -> QueryResponseOwnedView
fn clone(&self) -> QueryResponseOwnedView
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for QueryResponseOwnedView
impl Debug for QueryResponseOwnedView
Source§impl From<OwnedView<QueryResponseView<'static>>> for QueryResponseOwnedView
impl From<OwnedView<QueryResponseView<'static>>> for QueryResponseOwnedView
Source§fn from(inner: OwnedView<QueryResponseView<'static>>) -> Self
fn from(inner: OwnedView<QueryResponseView<'static>>) -> Self
Source§impl From<QueryResponseOwnedView> for OwnedView<QueryResponseView<'static>>
impl From<QueryResponseOwnedView> for OwnedView<QueryResponseView<'static>>
Source§fn from(wrapper: QueryResponseOwnedView) -> Self
fn from(wrapper: QueryResponseOwnedView) -> Self
Auto Trait Implementations§
impl !Freeze for QueryResponseOwnedView
impl RefUnwindSafe for QueryResponseOwnedView
impl Send for QueryResponseOwnedView
impl Sync for QueryResponseOwnedView
impl Unpin for QueryResponseOwnedView
impl UnsafeUnpin for QueryResponseOwnedView
impl UnwindSafe for QueryResponseOwnedView
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
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