Skip to main content

DataObjectOwnedView

Struct DataObjectOwnedView 

Source
pub struct DataObjectOwnedView(/* private fields */);
Expand description

Self-contained, 'static owned view of a DataObject message.

Wraps ::buffa::OwnedView<DataObjectView<'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 DataObjectView when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.

Implementations§

Source§

impl DataObjectOwnedView

Source

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.

Source

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.

Source

pub fn from_owned(msg: &DataObject) -> Result<Self, DecodeError>

Build from an owned message via an encode → decode round-trip.

§Errors

Returns ::buffa::DecodeError if the re-encoded bytes are somehow invalid (should not happen for well-formed messages).

Source

pub fn view(&self) -> &DataObjectView<'_>

Borrow the full DataObjectView with its lifetime tied to &self.

Source

pub fn to_owned_message(&self) -> DataObject

Convert to the owned message type.

Source

pub fn bytes(&self) -> &Bytes

The underlying bytes buffer.

Source

pub fn into_bytes(self) -> Bytes

Consume the handle, returning the underlying bytes buffer.

Source

pub fn name(&self) -> &str

A fully qualified name that uniquely identifies a data object.

For example, a table’s fully qualified name is in the format of <catalog>.<schema>.<table>,

Field 1: name

Source

pub fn data_object_type(&self) -> EnumValue<DataObjectType>

Type of the data object.

Field 2: data_object_type

Source

pub fn added_at(&self) -> Option<i64>

The time when this data object is added to the share, in epoch milliseconds.

Field 3: added_at

Source

pub fn added_by(&self) -> Option<&str>

Username of the sharer.

Field 4: added_by

Source

pub fn comment(&self) -> Option<&str>

A user-provided comment when adding the data object to the share.

Field 5: comment

Source

pub fn shared_as(&self) -> Option<&str>

A user-provided new name for the data object within the share.

If this new name is not provided, the object’s original name will be used as the shared_as name. The shared_as name must be unique within a share. For tables, the new name must follow the format of <schema>.<table>.

Field 6: shared_as

Source

pub fn partitions(&self) -> &RepeatedView<'_, &str>

Array of partitions for the shared data.

Field 7: partitions

Source

pub fn enable_cdf(&self) -> Option<bool>

Whether to enable cdf or indicate if cdf is enabled on the shared object.

Field 8: enable_cdf

Source

pub fn history_data_sharing_status(&self) -> Option<EnumValue<HistoryStatus>>

Whether to enable or disable sharing of data history. If not specified, the default is DISABLED.

Field 9: history_data_sharing_status

Source

pub fn start_version(&self) -> Option<i64>

The start version associated with the object.

This allows data providers to control the lowest object version that is accessible by clients. If specified, clients can query snapshots or changes for versions >= start_version. If not specified, clients can only query starting from the version of the object at the time it was added to the share.

NOTE: The start_version should be <= the current version of the object.

Field 10: start_version

Trait Implementations§

Source§

impl AsRef<OwnedView<DataObjectView<'static>>> for DataObjectOwnedView

Source§

fn as_ref(&self) -> &OwnedView<DataObjectView<'static>>

Converts this type into a shared reference of the (usually inferred) input type.
Source§

impl Clone for DataObjectOwnedView

Source§

fn clone(&self) -> DataObjectOwnedView

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for DataObjectOwnedView

Source§

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

Formats the value using the given formatter. Read more
Source§

impl From<DataObjectOwnedView> for OwnedView<DataObjectView<'static>>

Source§

fn from(wrapper: DataObjectOwnedView) -> Self

Converts to this type from the input type.
Source§

impl From<OwnedView<DataObjectView<'static>>> for DataObjectOwnedView

Source§

fn from(inner: OwnedView<DataObjectView<'static>>) -> Self

Converts to this type from the input type.
Source§

impl Serialize for DataObjectOwnedView

Source§

fn serialize<__S: Serializer>(&self, __s: __S) -> Result<__S::Ok, __S::Error>

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

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
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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

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

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> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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.
Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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