pub struct TaskResultMessage {
pub task_id: i32,
pub result_name: String,
pub data: Vec<u8>,
pub format: ResultFormat,
pub is_final: bool,
pub kind: ResultKind,
pub stash_handle: String,
pub stash_format: ResultFormat,
pub stash_size: u64,
}Expand description
Transport-agnostic result message sent from ResultSink
to the runtime, which converts it to the appropriate wire format
(e.g. proto::TaskResult for gRPC, postcard for IPC).
Fields§
§task_id: i32ID of the task this result belongs to.
result_name: StringLogical name identifying this result (e.g. "yara_matches").
data: Vec<u8>Payload bytes (inline result data, or empty for ref messages).
format: ResultFormatHow to interpret data.
is_final: boolWhether this is the final message for the task.
kind: ResultKindWhat kind of message this is (inline result, stash ref, or progress).
stash_handle: StringFor ResultRef: the stash handle. Empty for inline results.
stash_format: ResultFormatFor ResultRef: format of the original stashed data.
stash_size: u64For ResultRef: byte size of the stashed data.
Trait Implementations§
Source§impl Clone for TaskResultMessage
impl Clone for TaskResultMessage
Source§fn clone(&self) -> TaskResultMessage
fn clone(&self) -> TaskResultMessage
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 moreAuto Trait Implementations§
impl Freeze for TaskResultMessage
impl RefUnwindSafe for TaskResultMessage
impl Send for TaskResultMessage
impl Sync for TaskResultMessage
impl Unpin for TaskResultMessage
impl UnsafeUnpin for TaskResultMessage
impl UnwindSafe for TaskResultMessage
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,
§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].