Struct CooperativeDrainAdapter 

pub struct CooperativeDrainAdapter { /* private fields */ }

Cooperative drain adapter: supports Submit, safe-boundary Steer, Pause (via drain to safe boundary), Stop, and Observe. It truthfully exposes that in-flight pause and steer are not supported without killing processes.

Implementations

impl CooperativeDrainAdapter

pub fn new(identity: impl Into<String>) -> CooperativeDrainAdapter

pub fn set_completion(&self, invocation_id: &str, output: Value)

Trait Implementations

impl NodeCapabilityAdapter for CooperativeDrainAdapter

fn adapter_identity(&self) -> &str

Unique identity of this adapter.

fn declared_capabilities(&self) -> BTreeSet<NodeCapability>

Truthful set of declared capabilities.

fn supports_inflight_steer(&self) -> bool

Whether native in-flight steering is supported (without killing process).

fn supports_inflight_pause(&self) -> bool

Whether native in-flight suspension is supported (without killing process).

fn supports_cooperative_cancel(&self) -> bool

Whether cooperative cancellation is acknowledged.

fn start_invocation( &self, invocation: &NodeInvocation, ) -> Result<(), AdapterError>

Start a new invocation.

fn steer_invocation( &self, invocation_id: &str, instruction: &str, ) -> Result<SteerOutcome, AdapterError>

Deliver steer intervention to an active invocation.

fn pause_invocation( &self, invocation_id: &str, ) -> Result<PauseOutcome, AdapterError>

Request pause of an active invocation.

fn resume_invocation( &self, invocation_id: &str, ) -> Result<ResumeOutcome, AdapterError>

Request resume of a paused invocation.

fn cancel_invocation( &self, invocation_id: &str, ) -> Result<CancelOutcome, AdapterError>

Cooperatively cancel an invocation.

fn poll_status( &self, invocation_id: &str, ) -> Result<AdapterExecutionStatus, AdapterError>

Poll execution status.