client/dev.restate.client.jdk/JdkClient

JdkClient

open class JdkClient : BaseClient

Functions

awakeableHandle

open fun awakeableHandle(id: String): Client.AwakeableHandle

Create a new AwakeableHandle for the provided identifier.

open fun <Req, Res> call(request: Request<Req, Res>): Response<Res>

open fun <Req, Res> callAsync(request: Request<Req, Res>): CompletableFuture<Response<Res>>

open fun connect(baseUri: String): Client

open fun connect(baseUri: String, options: RequestOptions): Client

open fun connect(baseUri: String, serdeFactory: SerdeFactory): Client

open fun connect(baseUri: String, serdeFactory: SerdeFactory, options: RequestOptions): Client

Create a default JDK client.

idempotentInvocationHandle

abstract fun <Res> idempotentInvocationHandle(target: Target, idempotencyKey: String, resSerde: TypeTag<Res>): Client.IdempotentInvocationHandle<Res>

open fun <Res> idempotentInvocationHandle(target: Target, idempotencyKey: String, clazz: Class<Res>): Client.IdempotentInvocationHandle<Res>

open fun <Res> idempotentInvocationHandle(target: Target, idempotencyKey: String, resTypeTag: TypeTag<Res>): Client.IdempotentInvocationHandle<Res>

invocationHandle

abstract fun <Res> invocationHandle(invocationId: String, resSerde: TypeTag<Res>): Client.InvocationHandle<Res>

open fun <Res> invocationHandle(invocationId: String, clazz: Class<Res>): Client.InvocationHandle<Res>

open fun <Res> invocationHandle(invocationId: String, resTypeTag: TypeTag<Res>): Client.InvocationHandle<Res>

open fun of(baseUri: String, @Nullable serdeFactory: @Nullable SerdeFactory, @Nullable options: @Nullable RequestOptions): JdkClient

open fun of(httpClient: HttpClient, baseUri: String, @Nullable serdeFactory: @Nullable SerdeFactory, @Nullable options: @Nullable RequestOptions): JdkClient

Create a new JDK Client

open fun <Req, Res> send(request: Request<Req, Res>): SendResponse<Res>

open fun <Req, Res> send(request: Request<Req, Res>, @Nullable delay: @Nullable Duration): SendResponse<Res>

open fun <Req, Res> sendAsync(request: Request<Req, Res>): CompletableFuture<SendResponse<Res>>

open fun <Req, Res> sendAsync(request: Request<Req, Res>, @Nullable delay: @Nullable Duration): CompletableFuture<SendResponse<Res>>

open fun <Req, Res> submit(request: WorkflowRequest<Req, Res>): SendResponse<Res>

open fun <Req, Res> submit(request: WorkflowRequest<Req, Res>, @Nullable delay: @Nullable Duration): SendResponse<Res>

open fun <Req, Res> submitAsync(request: WorkflowRequest<Req, Res>): CompletableFuture<SendResponse<Res>>

open fun <Req, Res> submitAsync(request: WorkflowRequest<Req, Res>, @Nullable delay: @Nullable Duration): CompletableFuture<SendResponse<Res>>

abstract fun <Res> workflowHandle(workflowName: String, workflowId: String, resSerde: TypeTag<Res>): Client.WorkflowHandle<Res>

open fun <Res> workflowHandle(workflowName: String, workflowId: String, clazz: Class<Res>): Client.WorkflowHandle<Res>

open fun <Res> workflowHandle(workflowName: String, workflowId: String, resTypeTag: TypeTag<Res>): Client.WorkflowHandle<Res>