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>