Struct Client 

pub struct Client<E> { /* private fields */ }

A transport-neutral Restate ingress client.

Implementations

impl<E: RequestExecutor> Client<E>

pub fn new(base_uri: Uri, executor: E) -> Result<Self, ClientBuildError>

Creates a client with no default headers.

pub fn builder(base_uri: Uri, executor: E) -> ClientBuilder<E>

Creates a client builder.

pub fn with_restate_auth_token( self, token: impl AsRef<str>, ) -> Result<Self, ClientBuildError>

Adds a raw Restate Cloud authentication token to every request.

This method prepends Bearer and installs the resulting Authorization header as a default. An Authorization header set on an individual request overrides it.

Errors

Returns ClientBuildError::InvalidAuthToken when the token cannot be represented in an HTTP header.

pub fn request<Req, Res>( &self, target: RequestTarget, input: Req, ) -> Request<E, Req, Res>

Creates a typed request for a service handler.

pub fn invocation_handle<Res>( &self, invocation_id: impl Into<InvocationId>, ) -> InvocationHandle<E, Res>

Creates a typed handle for a persisted or externally obtained invocation ID.

pub async fn lookup_workflow<Res>( &self, workflow_name: impl Into<String>, workflow_key: impl Into<String>, scope: Option<String>, ) -> Result<InvocationHandle<E, Res>, ClientError>

Looks up the invocation handle for a workflow by name and key.

scope optionally restricts the lookup to a Restate Cloud scope; pass None outside Cloud.

Trait Implementations

impl<E> Clone for Client<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.