sdk-common/dev.restate.sdk.client/Client

Client

interface Client

Inheritors

Types

Link copied to clipboard
interface AwakeableHandle
This class represents a handle to an Awakeable.
Link copied to clipboard
Link copied to clipboard
interface InvocationHandle<Res>
Link copied to clipboard
interface WorkflowHandle<Res>

Functions

Link copied to clipboard
abstract fun awakeableHandle(id: String): Client.AwakeableHandle
Create a new AwakeableHandle for the provided identifier.
Link copied to clipboard
open fun <Req, Res> call(target: Target, reqSerde: Serde<Req>, resSerde: Serde<Res>, req: Req): Res
open fun <Req, Res> call(target: Target, reqSerde: Serde<Req>, resSerde: Serde<Res>, req: Req, options: RequestOptions): Res
Link copied to clipboard
open fun <Req, Res> callAsync(target: Target, reqSerde: Serde<Req>, resSerde: Serde<Res>, req: Req): CompletableFuture<Res>
abstract fun <Req, Res> callAsync(target: Target, reqSerde: Serde<Req>, resSerde: Serde<Res>, req: Req, options: RequestOptions): CompletableFuture<Res>
Link copied to clipboard
open fun connect(baseUri: String): Client
open fun connect(baseUri: String, headers: Map<String, String>): Client
Link copied to clipboard
abstract fun <Res> idempotentInvocationHandle(target: Target, idempotencyKey: String, resSerde: Serde<Res>): Client.IdempotentInvocationHandle<Res>
Link copied to clipboard
abstract fun <Res> invocationHandle(invocationId: String, resSerde: Serde<Res>): Client.InvocationHandle<Res>
Link copied to clipboard
open fun <Req> send(target: Target, reqSerde: Serde<Req>, req: Req): SendResponse
open fun <Req> send(target: Target, reqSerde: Serde<Req>, req: Req, @Nullable delay: @Nullable Duration): SendResponse
open fun <Req> send(target: Target, reqSerde: Serde<Req>, req: Req, @Nullable delay: @Nullable Duration, options: RequestOptions): SendResponse
Link copied to clipboard
open fun <Req> sendAsync(target: Target, reqSerde: Serde<Req>, req: Req): CompletableFuture<SendResponse>
open fun <Req> sendAsync(target: Target, reqSerde: Serde<Req>, req: Req, @Nullable delay: @Nullable Duration): CompletableFuture<SendResponse>
abstract fun <Req> sendAsync(target: Target, reqSerde: Serde<Req>, req: Req, @Nullable delay: @Nullable Duration, options: RequestOptions): CompletableFuture<SendResponse>
Link copied to clipboard
abstract fun <Res> workflowHandle(workflowName: String, workflowId: String, resSerde: Serde<Res>): Client.WorkflowHandle<Res>