client/dev.restate.client.base/BaseClient

BaseClient

abstract class BaseClient : Client

Base client. This can be used to build Client implementations on top with the HTTP client of your choice.

Inheritors

Types

DefaultSerdeFactory

class DefaultSerdeFactory

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

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

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 <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>>

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>