client/dev.restate.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(request: Request<Req, Res>): Response<Res>
Link copied to clipboard
abstract fun <Req, Res> callAsync(request: Request<Req, Res>): CompletableFuture<Response<Res>>
Link copied to clipboard
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.
Link copied to clipboard
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>
Link copied to clipboard
abstract fun <Res> invocationHandle(invocationId: String, resSerde: TypeTag<Res>): Client.InvocationHandle<Res>
open fun <Res> invocationHandle(invocationId: String, clazz: Class<Res>): Client.InvocationHandle<Res>
Link copied to clipboard
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>
Link copied to clipboard
open fun <Req, Res> sendAsync(request: Request<Req, Res>): CompletableFuture<SendResponse<Res>>
abstract fun <Req, Res> sendAsync(request: Request<Req, Res>, @Nullable delay: @Nullable Duration): CompletableFuture<SendResponse<Res>>
Link copied to clipboard
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>
Link copied to clipboard
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>>
Link copied to clipboard
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>