Package dev.restate.client.jdk

Class JdkClient

java.lang.Object

dev.restate.client.base.BaseClient

dev.restate.client.jdk.JdkClient

All Implemented Interfaces:

Client

public class JdkClient
extends BaseClient

Nested Class Summary

Nested classes/interfaces inherited from class dev.restate.client.base.BaseClient

BaseClient.DefaultSerdeFactory, BaseClient.ResponseMapper<R>

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

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

Method Summary

Modifier and Type	Method	Description
protected <R> CompletableFuture<R>	doGetRequest(URI target, Stream<Map.Entry<String,String>> headers, BaseClient.ResponseMapper<R> responseMapper)
protected <R> CompletableFuture<R>	doPostRequest(URI target, Stream<Map.Entry<String,String>> headers, Slice payload, BaseClient.ResponseMapper<R> responseMapper)
static JdkClient	of(String baseUri, @Nullable SerdeFactory serdeFactory, @Nullable RequestOptions options)	Create a new JDK Client
static JdkClient	of(HttpClient httpClient, String baseUri, @Nullable SerdeFactory serdeFactory, @Nullable RequestOptions options)	Create a new JDK Client

Methods inherited from class dev.restate.client.base.BaseClient

awakeableHandle, callAsync, idempotentInvocationHandle, invocationHandle, sendAsync, workflowHandle

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

Method Details

doPostRequest

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

Specified by:

doPostRequest in class BaseClient

doGetRequest

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

Specified by:

doGetRequest in class BaseClient

of

public static JdkClient of(HttpClient httpClient,
 String baseUri,
 @Nullable SerdeFactory serdeFactory,
 @Nullable RequestOptions options)

Create a new JDK Client

of

public static JdkClient of(String baseUri,
 @Nullable SerdeFactory serdeFactory,
 @Nullable RequestOptions options)

Create a new JDK Client