Package dev.restate.client.base

Class BaseClient

java.lang.Object

dev.restate.client.base.BaseClient

All Implemented Interfaces:

Client

Direct Known Subclasses:

JdkClient

public abstract class BaseClient
extends Object
implements Client

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	BaseClient.DefaultSerdeFactory
protected static interface	BaseClient.ResponseMapper<R>

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

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseClient(URI baseUri, @Nullable SerdeFactory serdeFactory, @Nullable RequestOptions baseOptions)

Method Summary

Modifier and Type	Method	Description
Client.AwakeableHandle	awakeableHandle(String id)	Create a new Client.AwakeableHandle for the provided identifier.
<Req, Res> CompletableFuture<Response<Res>>	callAsync(Request<Req,Res> request)	Future version of Client.call(Request)
protected abstract <Res> CompletableFuture<Res>	doGetRequest(URI target, Stream<Map.Entry<String,String>> headers, BaseClient.ResponseMapper<Res> responseMapper)
protected abstract <Res> CompletableFuture<Res>	doPostRequest(URI target, Stream<Map.Entry<String,String>> headers, Slice payload, BaseClient.ResponseMapper<Res> responseMapper)
<Res> Client.IdempotentInvocationHandle<Res>	idempotentInvocationHandle(Target target, String idempotencyKey, TypeTag<Res> resTypeTag)	Create a new Client.IdempotentInvocationHandle for the provided target and idempotency key.
<Res> Client.InvocationHandle<Res>	invocationHandle(String invocationId, TypeTag<Res> resTypeTag)	Create a new Client.InvocationHandle for the provided invocation identifier.
<Req, Res> CompletableFuture<SendResponse<Res>>	sendAsync(Request<Req,Res> request, @Nullable Duration delay)	Future version of Client.send(Request, Duration)
<Res> Client.WorkflowHandle<Res>	workflowHandle(String workflowName, String workflowId, TypeTag<Res> resTypeTag)	Create a new Client.WorkflowHandle for the provided workflow name and identifier.

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.restate.client.Client

call, idempotentInvocationHandle, invocationHandle, send, send, sendAsync, submit, submit, submitAsync, submitAsync, workflowHandle

Constructor Details

BaseClient

protected BaseClient(URI baseUri,
 @Nullable SerdeFactory serdeFactory,
 @Nullable RequestOptions baseOptions)

Method Details

callAsync

public <Req,
Res> CompletableFuture<Response<Res>> callAsync(Request<Req,Res> request)

Description copied from interface: Client

Future version of Client.call(Request)

Specified by:

callAsync in interface Client

See Also:

• Client.call(Request)

sendAsync

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

Description copied from interface: Client

Future version of Client.send(Request, Duration)

Specified by:

sendAsync in interface Client

See Also:

• Client.send(Request, Duration)

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(TypeTag, 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,
 TypeTag<Res> resTypeTag)

Description copied from interface: Client

Create a new Client.InvocationHandle for the provided invocation identifier.

Specified by:

invocationHandle in interface Client

Parameters:

invocationId - the invocation identifier

resTypeTag - type tag used to deserialize the invocation result

Returns:

the invocation handle

idempotentInvocationHandle

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

Description copied from interface: Client

Create a new Client.IdempotentInvocationHandle for the provided target and idempotency key.

Specified by:

idempotentInvocationHandle in interface Client

Parameters:

target - the target service/method

idempotencyKey - the idempotency key

resTypeTag - type tag used to deserialize the invocation result

Returns:

the idempotent invocation handle

workflowHandle

public <Res> Client.WorkflowHandle<Res> workflowHandle(String workflowName,
 String workflowId,
 TypeTag<Res> resTypeTag)

Description copied from interface: Client

Create a new Client.WorkflowHandle for the provided workflow name and identifier.

Specified by:

workflowHandle in interface Client

Parameters:

workflowName - the workflow name

workflowId - the workflow identifier

resTypeTag - type tag used to deserialize the invocation result

Returns:

the workflow handle

doPostRequest

protected abstract <Res> CompletableFuture<Res> doPostRequest(URI target,
 Stream<Map.Entry<String,String>> headers,
 Slice payload,
 BaseClient.ResponseMapper<Res> responseMapper)

doGetRequest

protected abstract <Res> CompletableFuture<Res> doGetRequest(URI target,
 Stream<Map.Entry<String,String>> headers,
 BaseClient.ResponseMapper<Res> responseMapper)