Package-level declarations

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

An Awakeable is a special type of Awaitable 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.

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 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.common.syscalls.HandlerRunner to use the Kotlin API.

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 Awaitable.

Like kotlinx.coroutines.awaitAll, but for Awaitable.

Create an Awakeable using KtSerdes.json deserializer, addressable through Awakeable.id.

Complete with success the Awakeable using KtSerdes.json serializer.

Execute a non-deterministic closure, recording the result value in the journal using KtSerdes.json. 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. Use this feature if you want to perform non-deterministic operations.

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