Package dev.restate.sdk.client

Interface Client

All Known Implementing Classes:

DefaultClient

public interface Client

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Client.AwakeableHandle	This class represents a handle to an Awakeable.
static interface	Client.InvocationHandle<Res>
static interface	Client.WorkflowHandle<Res>

Method Summary

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

Method Details

callAsync

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

callAsync

default <Req,
Res> CompletableFuture<Res> callAsync(Target target,
 Serde<Req> reqSerde,
 Serde<Res> resSerde,
 Req req)

call

default <Req,
Res> Res call(Target target,
 Serde<Req> reqSerde,
 Serde<Res> resSerde,
 Req req,
 RequestOptions options)
                    throws IngressException

Throws:

IngressException

call

default <Req,
Res> Res call(Target target,
 Serde<Req> reqSerde,
 Serde<Res> resSerde,
 Req req)
                    throws IngressException

Throws:

IngressException

sendAsync

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

sendAsync

default <Req> CompletableFuture<SendResponse> sendAsync(Target target,
 Serde<Req> reqSerde,
 Req req,
 @Nullable Duration delay)

sendAsync

default <Req> CompletableFuture<SendResponse> sendAsync(Target target,
 Serde<Req> reqSerde,
 Req req)

send

default <Req> SendResponse send(Target target,
 Serde<Req> reqSerde,
 Req req,
 @Nullable Duration delay,
 RequestOptions options)
                         throws IngressException

Throws:

IngressException

send

default <Req> SendResponse send(Target target,
 Serde<Req> reqSerde,
 Req req,
 @Nullable Duration delay)
                         throws IngressException

Throws:

IngressException

send

default <Req> SendResponse send(Target target,
 Serde<Req> reqSerde,
 Req req)
                         throws IngressException

Throws:

IngressException

awakeableHandle

Client.AwakeableHandle awakeableHandle(String id)

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.

invocationHandle

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

workflowHandle

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

connect

static Client connect(String baseUri)

connect

static Client connect(String baseUri,
 Map<String,String> headers)