pub struct AnyTask {
pub routing_key: String,
pub metadata: Bytes,
pub op: Bytes,
pub operation_id: u8,
pub input: Bytes,
pub serializer: Serializer,
}
Expand description
Fields§
§routing_key: String
The routing key used to identify the
Channel
to which execution results should
be sent.
metadata: Bytes
Serialized metadata associated with the Task
.
op: Bytes
The serialized Operation
to be executed.
operation_id: u8
The unique identifier of the Operation
to be executed.
input: Bytes
Serialized arguments to the Operation
.
serializer: Serializer
The Serializer
used to serialize and deserialize the Operation
arguments.
Implementations§
Source§impl AnyTask
impl AnyTask
Sourcepub async fn remote_execute(self) -> Result<AnyTaskOutput>
pub async fn remote_execute(self) -> Result<AnyTaskOutput>
Opaque execution of a Task
.
This function is used to execute arbitrary Operation
s. It uses the
RemoteExecute::ID
field to
acquire the correct execution pointer from the [static@OPERATIONS
]
slice.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for AnyTask
impl<'de> Deserialize<'de> for AnyTask
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl !Freeze for AnyTask
impl RefUnwindSafe for AnyTask
impl Send for AnyTask
impl Sync for AnyTask
impl Unpin for AnyTask
impl UnwindSafe for AnyTask
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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