Package-level declarations
Types
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.
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.
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.
Properties
Functions
Like kotlinx.coroutines.awaitAll, but for DurableFuture.
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.
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