Package-level declarations

An Awakeable is a special type of DurableFuture which can be arbitrarily completed by another service, by addressing it with its id.

This class represents a handle to an Awakeable created in another service.

The DurableFuture returned by a Context.call.

This interface exposes the Restate functionalities to Restate services. It can be used to interact with other Restate services, record non-deterministic closures, execute timers and synchronize with external systems.

A DurableFuture allows to await an asynchronous result. Once await is called, the execution waits until the asynchronous result is available.

A DurablePromise is a durable, distributed version of a Kotlin's Deferred, or more commonly of a future/promise. Restate keeps track of the DurablePromise across restarts/failures.

This class represents a handle to a DurablePromise created in another service.

Adapter class for dev.restate.sdk.endpoint.definition.HandlerRunner to use the Kotlin API.

An invocation handle, that can be used to interact with a running invocation.

This interface can be used only within exclusive handlers of virtual objects. It extends Context adding access to the virtual object instance key-value state storage.

Retry policy configuration.

This interface can be used only within shared handlers of virtual objects. It extends Context adding access to the virtual object instance key-value state storage.

This interface can be used only within shared handlers of workflow. It extends Context adding access to the workflow instance key-value state storage and to the DurablePromise API.

Opt-in annotation to use the preview of new context features.

This interface can be used only within workflow handlers of workflow. It extends Context adding access to the workflow instance key-value state storage and to the DurablePromise API.

Like kotlinx.coroutines.awaitAll, but for DurableFuture.

Like kotlinx.coroutines.awaitAll, but for DurableFuture.

Create an Awakeable, addressable through Awakeable.id.

Shorthand for Context.call

Get an InvocationHandle for an already existing invocation. This will let you interact with a running invocation, for example to cancel it or retrieve its result.

Complete with success the Awakeable.

Execute a closure asynchronously. This is like runBlock, but it returns a DurableFuture that you can combine and select.

Execute a closure, recording the result value in the journal. The result value will be re-played in case of re-invocation (e.g. because of failure recovery or suspension point) without re-executing the closure.

Like kotlinx.coroutines.selects.select, but for DurableFuture

Shorthand for Context.send