client-kotlin/dev.restate.client.kotlin

Package-level declarations

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
suspend fun <T> Client.IdempotentInvocationHandle<T>.attachSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<T>

Suspend version of Client.IdempotentInvocationHandle.attach.

suspend fun <T> Client.InvocationHandle<T>.attachSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<T>

Suspend version of Client.InvocationHandle.attach.

suspend fun <T> Client.WorkflowHandle<T>.attachSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<T>

Suspend version of Client.WorkflowHandle.attach.

Link copied to clipboard
suspend fun <Req, Res> Request<Req, Res>.call(client: Client): Response<Res>

Shorthand for callSuspend

Link copied to clipboard
suspend fun <Req, Res> Client.callSuspend(request: Request<Req, Res>): Response<Res>

Call a service and wait for the response.

Link copied to clipboard
suspend fun <T> Client.IdempotentInvocationHandle<T>.getOutputSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<Output<T>>

Suspend version of Client.IdempotentInvocationHandle.getOutput.

suspend fun <T> Client.InvocationHandle<T>.getOutputSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<Output<T>>

Suspend version of Client.InvocationHandle.getOutput.

suspend fun <T> Client.WorkflowHandle<T>.getOutputSuspend(options: RequestOptions = RequestOptions.DEFAULT): Response<Output<T>>

Suspend version of Client.WorkflowHandle.getOutput.

Link copied to clipboard
inline fun <Res> Client.idempotentInvocationHandle(target: Target, idempotencyKey: String): Client.IdempotentInvocationHandle<Res>

Create a new Client.IdempotentInvocationHandle for the provided target and idempotency key.

Link copied to clipboard
inline fun <Res> Client.invocationHandle(invocationId: String): Client.InvocationHandle<Res>

Create a new Client.InvocationHandle for the provided invocation identifier.

Link copied to clipboard
suspend fun Client.AwakeableHandle.rejectSuspend(reason: String, options: RequestOptions = RequestOptions.DEFAULT): Response<Void>

Complete with failure the Awakeable.

Link copied to clipboard
fun requestOptions(init: RequestOptions.Builder.() -> Unit): RequestOptions

Request options builder function

Link copied to clipboard
inline suspend fun <T : Any> Client.AwakeableHandle.resolveSuspend(payload: T, options: RequestOptions = RequestOptions.DEFAULT): Response<Void>
suspend fun <T : Any> Client.AwakeableHandle.resolveSuspend(typeTag: TypeTag<T>, payload: T, options: RequestOptions = RequestOptions.DEFAULT): Response<Void>

Complete with success the Awakeable.

Link copied to clipboard
suspend fun <Req, Res> Request<Req, Res>.send(client: Client, delay: Duration? = null): SendResponse<Res>

Shorthand for sendSuspend

Link copied to clipboard
suspend fun <Req, Res> Client.sendSuspend(request: Request<Req, Res>, delay: Duration? = null): SendResponse<Res>

Send a request to a service without waiting for the response, optionally providing an execution delay to wait for.

Link copied to clipboard
suspend fun <Req, Res> WorkflowRequest<Req, Res>.submit(client: Client, delay: Duration? = null): SendResponse<Res>

Shorthand for submitSuspend

Link copied to clipboard
suspend fun <Req, Res> Client.submitSuspend(request: WorkflowRequest<Req, Res>, delay: Duration? = null): SendResponse<Res>

Submit a workflow, optionally providing an execution delay to wait for.

Link copied to clipboard
inline fun <Res> Client.workflowHandle(workflowName: String, workflowId: String): Client.WorkflowHandle<Res>

Create a new Client.WorkflowHandle for the provided workflow name and identifier.