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

DefaultClient

open class DefaultClient : Client

Functions

Link copied to clipboard
open 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>
open fun <Req, Res> callAsync(    target: Target,     reqSerde: Serde<Req>,     resSerde: Serde<Res>,     req: Req,     requestOptions: 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
open fun <Res> idempotentInvocationHandle(    target: Target,     idempotencyKey: String,     resSerde: Serde<Res>): Client.IdempotentInvocationHandle<Res>
Link copied to clipboard
open fun <Res> invocationHandle(invocationId: String, resSerde: Serde<Res>): Client.InvocationHandle<Res>
Link copied to clipboard
open fun of(httpClient: HttpClient, baseUri: String, headers: Map<String, String>): DefaultClient
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>
open fun <Req> sendAsync(    target: Target,     reqSerde: Serde<Req>,     req: Req,     delay: Duration,     options: RequestOptions): CompletableFuture<SendResponse>
Link copied to clipboard
open fun <Res> workflowHandle(workflowName: String, workflowId: String, resSerde: Serde<Res>): Client.WorkflowHandle<Res>