client-kotlin/dev.restate.client.kotlin

Package-level declarations

Properties

val ResponseHead.headers: ResponseHead.Headers

val <Res> Response<Res>.response: Res

val <Res> SendResponse<Res>.sendStatus: SendResponse.SendStatus

val ResponseHead.status: Int

Functions

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

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

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

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

Shorthand for callSuspend

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

Suspend version of Client.callAsync

getOutputSuspend

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

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

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

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

fun requestOptions(init: RequestOptions.Builder.() -> Unit): RequestOptions

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>

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

Shorthand for sendSuspend

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

Suspend version of Client.sendAsync

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

Shorthand for submitSuspend

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

Suspend version of Client.submitAsync