pub struct DecodedFlightData {
    pub inner: FlightData,
    pub payload: DecodedPayload,
}Expand description
FlightData and the decoded payload (Schema, RecordBatch), if any
Fields§
§inner: FlightDataThe original FlightData message
payload: DecodedPayloadThe decoded payload
Implementations§
Source§impl DecodedFlightData
 
impl DecodedFlightData
Sourcepub fn new_none(inner: FlightData) -> Self
 
pub fn new_none(inner: FlightData) -> Self
Create a new DecodedFlightData with no payload
Sourcepub fn new_schema(inner: FlightData, schema: SchemaRef) -> Self
 
pub fn new_schema(inner: FlightData, schema: SchemaRef) -> Self
Create a new DecodedFlightData with a Schema payload
Sourcepub fn new_record_batch(inner: FlightData, batch: RecordBatch) -> Self
 
pub fn new_record_batch(inner: FlightData, batch: RecordBatch) -> Self
Create a new DecodedFlightData with a RecordBatch payload
Sourcepub fn app_metadata(&self) -> Bytes
 
pub fn app_metadata(&self) -> Bytes
Return the metadata field of the inner flight data
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for DecodedFlightData
impl !RefUnwindSafe for DecodedFlightData
impl Send for DecodedFlightData
impl Sync for DecodedFlightData
impl Unpin for DecodedFlightData
impl !UnwindSafe for DecodedFlightData
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
 
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
 
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
 
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
 
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
 
fn into_request(self) -> Request<T>
Wrap the input message 
T in a tonic::Request§impl<L> LayerExt<L> for L
 
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
    L: Layer<S>,
 
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
    L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].