Struct ResultSink 

pub struct ResultSink<'a> {
    pub(super) inner: &'a ContextInner,
}

Handle for pushing results back to the daemon during task execution.

Obtained from Context::results(). Only usable inside an on_task handler; calling push outside of one returns an error.

Fields

inner: &'a ContextInner

Implementations

impl ResultSink<'_>

pub fn push(&self, result: PluginResult) -> Result<()>

Push a single result back to the daemon.

Small results (below the stash threshold) travel inline on the control stream. Large byte/JSON payloads are written to the disk stash and replaced with a reference marker that the daemon pulls via the PullResult RPC (guest plugins only).

Panics

Uses blocking_send internally. Must be called from a blocking context (e.g. spawn_blocking), not from within an async task.

Errors

• Returns SdkError::InvalidContext if called outside an on_task handler (when the context has no result channel).
• Returns SdkError::Channel if the result channel is closed (typically because the daemon disconnected).
• Returns SdkError::Io if the result is a File variant and the file cannot be read.

pub fn push_json(&self, name: &str, data: &[u8]) -> Result<()>

Push a JSON result (raw bytes that are already JSON-encoded).

pub fn push_bytes(&self, name: &str, data: &[u8]) -> Result<()>

Push a raw byte result.

pub fn push_file(&self, name: &str, path: impl AsRef<Path>) -> Result<()>

Push a file result by path.

pub fn push_all(&self, results: Vec<PluginResult>) -> Result<()>

Push a batch of results. Results are sent one at a time in order; if one fails, the remaining results are not sent and the error is returned. Results sent before the failure are not rolled back.

fn classify_and_build(&self, result: PluginResult) -> Result<TaskResultMessage>