Package dev.restate.sdk

Class PreviewContext

java.lang.Object

dev.restate.sdk.PreviewContext

public class PreviewContext
extends Object

Preview of new context features. Please note that the methods in this class may break between minor releases, use with caution!

In order to use these methods, you MUST enable the preview context, through the endpoint builders using enablePreviewContext().

Constructor Summary

Constructors

Constructor	Description
PreviewContext()

Method Summary

Modifier and Type	Method	Description
static void	run(Context ctx, RetryPolicy retryPolicy, ThrowingRunnable runnable)	Like Context.run(ThrowingRunnable), but using a custom retry policy.
static <T> T	run(Context ctx, Serde<T> serde, RetryPolicy retryPolicy, ThrowingSupplier<T> action)	Like Context.run(Serde, ThrowingSupplier), but using a custom retry policy.
static void	run(Context ctx, String name, RetryPolicy retryPolicy, ThrowingRunnable runnable)	Like Context.run(String, ThrowingRunnable), but using a custom retry policy.
static <T> T	run(Context ctx, String name, Serde<T> serde, RetryPolicy retryPolicy, ThrowingSupplier<T> action)	Like Context.run(String, Serde, ThrowingSupplier), but using a custom retry policy.

Methods inherited from class java.lang.Object

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

Constructor Details

PreviewContext

public PreviewContext()

Method Details

run

public static <T> T run(Context ctx,
 String name,
 Serde<T> serde,
 RetryPolicy retryPolicy,
 ThrowingSupplier<T> action)
                 throws TerminalException

Like Context.run(String, Serde, ThrowingSupplier), but using a custom retry policy.

When a retry policy is not specified, the run will be retried using the Restate invoker retry policy, which by default retries indefinitely.

Throws:

TerminalException

run

public static void run(Context ctx,
 String name,
 RetryPolicy retryPolicy,
 ThrowingRunnable runnable)
                throws TerminalException

Like Context.run(String, ThrowingRunnable), but using a custom retry policy.

When a retry policy is not specified, the run will be retried using the Restate invoker retry policy, which by default retries indefinitely.

Throws:

TerminalException

run

public static <T> T run(Context ctx,
 Serde<T> serde,
 RetryPolicy retryPolicy,
 ThrowingSupplier<T> action)
                 throws TerminalException

Like Context.run(Serde, ThrowingSupplier), but using a custom retry policy.

When a retry policy is not specified, the run will be retried using the Restate invoker retry policy, which by default retries indefinitely.

Throws:

TerminalException

run

public static void run(Context ctx,
 RetryPolicy retryPolicy,
 ThrowingRunnable runnable)
                throws TerminalException

Like Context.run(ThrowingRunnable), but using a custom retry policy.

When a retry policy is not specified, the run will be retried using the Restate invoker retry policy, which by default retries indefinitely.

Throws:

TerminalException