Struct Service 

pub struct Service<T> { /* private fields */ }

Concrete Restate service implementation over a transport resolver.

Most applications construct this once at worker startup, register one or more transports in a StaticTransportRegistry, and bind it to a Restate endpoint through IntoServiceDefinition.

Implementations

impl<T> Service<T>

where T: TransportResolver + Send + Sync + 'static,

pub fn new(transports: T) -> Self

Build a service around an owned transport resolver.

pub fn from_shared(transports: Arc<T>) -> Self

Build a service around a shared transport resolver.

pub fn with_transport_options( self, transport_options: TransportOptionRegistry, ) -> Self

Override the provider-option registry used to hydrate queued transport_options.

The default registry is email_kit::transport::transport_option_registry(); use this method when a worker has additional provider-specific option types outside email-kit.

pub async fn send_request( &self, request: &SendRequest, ) -> Result<SendResponse, HandlerError>

Send one email request through the configured worker dependencies.

Errors

Returns HandlerError when the requested transport key is unknown or sending fails. Unknown transport keys and non-retryable transport failures become Restate terminal errors; retryable transport failures remain retryable handler errors.

Trait Implementations

impl<T> Clone for Service<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Discoverable for Service<T>

where T: TransportResolver + Send + Sync + 'static,

fn discover() -> Service

impl<T> IntoServiceDefinition for Service<T>

where T: TransportResolver + Send + Sync + 'static,

fn into_service_definition(self) -> ServiceDefinition