pub struct DataConverter { /* private fields */ }Expand description
Combines a PayloadConverter, FailureConverter, and PayloadCodec to handle all
serialization needs for communicating with the Temporal server.
Implementations§
Source§impl DataConverter
impl DataConverter
Sourcepub fn new(
payload_converter: PayloadConverter,
failure_converter: impl FailureConverter + Send + Sync + 'static,
codec: impl PayloadCodec + Send + Sync + 'static,
) -> Self
pub fn new( payload_converter: PayloadConverter, failure_converter: impl FailureConverter + Send + Sync + 'static, codec: impl PayloadCodec + Send + Sync + 'static, ) -> Self
Create a new DataConverter with the given payload converter, failure converter, and codec.
Sourcepub async fn to_payload<T: TemporalSerializable + 'static>(
&self,
data: &SerializationContextData,
val: &T,
) -> Result<Payload, PayloadConversionError>
pub async fn to_payload<T: TemporalSerializable + 'static>( &self, data: &SerializationContextData, val: &T, ) -> Result<Payload, PayloadConversionError>
Serialize a value into a single payload, applying the codec.
Sourcepub async fn from_payload<T: TemporalDeserializable + 'static>(
&self,
data: &SerializationContextData,
payload: Payload,
) -> Result<T, PayloadConversionError>
pub async fn from_payload<T: TemporalDeserializable + 'static>( &self, data: &SerializationContextData, payload: Payload, ) -> Result<T, PayloadConversionError>
Deserialize a value from a single payload, applying the codec.
Sourcepub async fn to_payloads<T: TemporalSerializable + 'static>(
&self,
data: &SerializationContextData,
val: &T,
) -> Result<Vec<Payload>, PayloadConversionError>
pub async fn to_payloads<T: TemporalSerializable + 'static>( &self, data: &SerializationContextData, val: &T, ) -> Result<Vec<Payload>, PayloadConversionError>
Serialize a value into multiple payloads (e.g. for multi-arg support), applying the codec.
Sourcepub async fn from_payloads<T: TemporalDeserializable + 'static>(
&self,
data: &SerializationContextData,
payloads: Vec<Payload>,
) -> Result<T, PayloadConversionError>
pub async fn from_payloads<T: TemporalDeserializable + 'static>( &self, data: &SerializationContextData, payloads: Vec<Payload>, ) -> Result<T, PayloadConversionError>
Deserialize a value from multiple payloads (e.g. for multi-arg support), applying the codec.
Sourcepub fn payload_converter(&self) -> &PayloadConverter
pub fn payload_converter(&self) -> &PayloadConverter
Returns the payload converter component of this data converter.
Sourcepub fn codec(&self) -> &(dyn PayloadCodec + Send + Sync)
pub fn codec(&self) -> &(dyn PayloadCodec + Send + Sync)
Returns the codec component of this data converter.
Trait Implementations§
Source§impl Clone for DataConverter
impl Clone for DataConverter
Source§fn clone(&self) -> DataConverter
fn clone(&self) -> DataConverter
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for DataConverter
impl Debug for DataConverter
Auto Trait Implementations§
impl Freeze for DataConverter
impl !RefUnwindSafe for DataConverter
impl Send for DataConverter
impl Sync for DataConverter
impl Unpin for DataConverter
impl UnsafeUnpin for DataConverter
impl !UnwindSafe for DataConverter
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
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request