sdk-api-kotlin/dev.restate.sdk.kotlin/KRequest

KRequest

interface KRequest<Req, Res> : Request<Req, Res>

Kotlin-idiomatic request for invoking Restate services from within a handler.

Example usage:

toService<CounterKt>()
    .request { add(1) }
    .options { idempotencyKey = "123" }
    .call()

Type Parameters

Req

the request type

Res

the response type

Properties

headers

abstract override val headers: Map<String?, String?>??

idempotencyKey

abstract override val idempotencyKey: String?

limitKey

@get:ApiStatus.Experimental

abstract override val limitKey: String?

request

abstract override val request: Req?

requestTypeTag

abstract override val requestTypeTag: TypeTag<Req?>?

responseTypeTag

abstract override val responseTypeTag: TypeTag<Res?>?

target

abstract override val target: Target?

Functions

call

abstract suspend fun call(): CallDurableFuture<Res>

Call the target handler and return a CallDurableFuture for the result.

call

suspend fun <Req, Res> Request<Req, Res>.call(context: Context): CallDurableFuture<Res>

Shorthand for Context.call

getRequest

abstract fun getRequest(): Req?

getRequestTypeTag

abstract fun getRequestTypeTag(): TypeTag<Req?>?

getResponseTypeTag

abstract fun getResponseTypeTag(): TypeTag<Res?>?

options

abstract fun options(block: InvocationOptions.Builder.() -> Unit): KRequest<Req, Res>

Configure invocation options using a DSL.

send

abstract suspend fun send(delay: Duration? = null): InvocationHandle<Res>

Send the request without waiting for the response.

send

suspend fun <Req, Res> Request<Req, Res>.send(context: Context, delay: Duration? = null): InvocationHandle<Res>

Shorthand for Context.send

toBuilder

abstract fun toBuilder(): RequestBuilder<Req?, Res?>?