Struct GrpcWorkerSession 

pub struct GrpcWorkerSession { /* private fields */ }

gRPC-backed WorkerSession using aion-proto generated tonic stubs.

Implementations

impl GrpcWorkerSession

pub async fn connect(config: WorkerConfig) -> Result<Self, WorkerError>

Connects to the configured worker endpoint.

Opaque credentials are accepted by WorkerConfig but the current AW worker proto does not define a credential metadata convention, so no authentication scheme is interpreted here.

Errors

Returns WorkerError::Connect if tonic cannot create the channel.

pub fn from_channel(config: WorkerConfig, channel: Channel) -> Self

Creates a session from an existing tonic channel.

pub const fn registered_info(&self) -> Option<&RegisteredSessionInfo>

Server-assigned registration facts from the RegisterAck, available once WorkerSession::register has succeeded.

Trait Implementations

impl WorkerSession for GrpcWorkerSession

fn handshake<'life0, 'life1, 'async_trait>( &'life0 mut self, config: &'life1 WorkerConfig, ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Performs the worker handshake for the configured task queue and identity.

fn register<'life0, 'life1, 'async_trait>( &'life0 mut self, activity_types: Vec<String>, available_handlers: &'life1 BTreeSet<String>, ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Registers activity-type names implemented by this worker.

fn receive_tasks(&mut self) -> WorkerTaskStream

Opens the receive side of AW’s StreamWorker RPC and yields pushed tasks.

fn report_result<'life0, 'async_trait>( &'life0 mut self, workflow_id: WorkflowId, activity_id: ActivityId, result: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reports successful activity output via WorkerToServer.result.

fn report_failure<'life0, 'async_trait>( &'life0 mut self, workflow_id: WorkflowId, activity_id: ActivityId, failure: ActivityError, ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reports explicit activity failure via WorkerToServer.result.

fn send_heartbeat<'life0, 'async_trait>( &'life0 mut self, workflow_id: WorkflowId, activity_id: ActivityId, progress: Option<Payload>, ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends cooperative progress via WorkerToServer.heartbeat.