Package dev.restate.sdk.client

Class DefaultClient

java.lang.Object

dev.restate.sdk.client.DefaultClient

All Implemented Interfaces:

Client

public class DefaultClient
extends Object
implements Client

Nested Class Summary

Nested classes/interfaces inherited from interface dev.restate.sdk.client.Client

Client.AwakeableHandle, Client.InvocationHandle<Res>, Client.WorkflowHandle<Res>

Method Summary

Modifier and Type	Method	Description
Client.AwakeableHandle	awakeableHandle(String id)	Create a new Client.AwakeableHandle for the provided identifier.
<Req, Res> CompletableFuture<Res>	callAsync(Target target, Serde<Req> reqSerde, Serde<Res> resSerde, Req req, RequestOptions requestOptions)
<Res> Client.InvocationHandle<Res>	invocationHandle(String invocationId, Serde<Res> resSerde)
static DefaultClient	of(HttpClient httpClient, String baseUri, Map<String,String> headers)
<Req> CompletableFuture<SendResponse>	sendAsync(Target target, Serde<Req> reqSerde, Req req, Duration delay, RequestOptions options)
<Res> Client.WorkflowHandle<Res>	workflowHandle(String workflowName, String workflowId, Serde<Res> resSerde)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface dev.restate.sdk.client.Client

call, call, callAsync, send, send, send, sendAsync, sendAsync

Method Details

callAsync

public <Req,
Res> CompletableFuture<Res> callAsync(Target target,
 Serde<Req> reqSerde,
 Serde<Res> resSerde,
 Req req,
 RequestOptions requestOptions)

Specified by:

callAsync in interface Client

sendAsync

public <Req> CompletableFuture<SendResponse> sendAsync(Target target,
 Serde<Req> reqSerde,
 Req req,
 Duration delay,
 RequestOptions options)

Specified by:

sendAsync in interface Client

awakeableHandle

public Client.AwakeableHandle awakeableHandle(String id)

Description copied from interface: Client

Create a new Client.AwakeableHandle for the provided identifier. You can use it to Client.AwakeableHandle.resolve(Serde, Object) or Client.AwakeableHandle.reject(String) an Awakeable from the ingress.

Specified by:

awakeableHandle in interface Client

invocationHandle

public <Res> Client.InvocationHandle<Res> invocationHandle(String invocationId,
 Serde<Res> resSerde)

Specified by:

invocationHandle in interface Client

workflowHandle

public <Res> Client.WorkflowHandle<Res> workflowHandle(String workflowName,
 String workflowId,
 Serde<Res> resSerde)

Specified by:

workflowHandle in interface Client

of

public static DefaultClient of(HttpClient httpClient,
 String baseUri,
 Map<String,String> headers)