keel-jvm-runtime/com.keel.jvm.runtime

Package-level declarations

Types

@Serializable

data class HandshakeRequest(val kind: String = "handshake-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val runtimeMode: String) : PluginJvmMessage

HandshakeResponse

@Serializable

data class HandshakeResponse(val kind: String = "handshake-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val descriptorVersion: String, val runtimeMode: String, val supportedServices: List<String> = emptyList(), val endpointInventory: List<PluginEndpointInventoryItem>, val routeInventory: List<PluginRouteInventoryItem> = emptyList(), val accepted: Boolean, val reason: String? = null) : PluginJvmControlResponse

HealthRequest

@Serializable

data class HealthRequest(val kind: String = "health-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String) : PluginJvmMessage

HealthResponse

@Serializable

data class HealthResponse(val kind: String = "health-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val lifecycleState: String, val healthState: String, val startedAtEpochMs: Long, val eventQueueDepth: Int, val droppedLogCount: Long) : PluginJvmControlResponse

InvokeRequest

@Serializable

data class InvokeRequest(val kind: String = "invoke-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val requestId: String, val endpointId: String, val method: String, val rawPath: String, val pathParameters: Map<String, String>, val queryParameters: Map<String, List<String>>, val headers: Map<String, List<String>>, val traceparent: String? = null, val tracestate: String? = null, val bodyJson: String?, val maxPayloadBytes: Long?, val allowChunkedTransfer: Boolean) : PluginJvmMessage

InvokeResponse

@Serializable

data class InvokeResponse(val kind: String = "invoke-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val requestId: String, val status: Int, val headers: Map<String, List<String>> = emptyMap(), val bodyJson: String? = null, val errorMessage: String? = null) : PluginJvmControlResponse

PluginBackpressureEvent

@Serializable

data class PluginBackpressureEvent(val kind: String = "plugin-backpressure-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val eventQueueDepth: Int) : PluginRuntimeEvent

PluginDisposedEvent

@Serializable

data class PluginDisposedEvent(val kind: String = "plugin-disposed-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String) : PluginRuntimeEvent

PluginDrainCompleteEvent

@Serializable

data class PluginDrainCompleteEvent(val kind: String = "plugin-drain-complete-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val remainingInvokes: Int) : PluginRuntimeEvent

PluginEndpointInventoryItem

@Serializable

data class PluginEndpointInventoryItem(val endpointId: String, val method: String, val path: String)

PluginEventQueueOverflowEvent

@Serializable

data class PluginEventQueueOverflowEvent(val kind: String = "plugin-event-queue-overflow-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val queueType: String, val capacity: Int) : PluginRuntimeEvent

PluginFailureEvent

@Serializable

data class PluginFailureEvent(val kind: String = "plugin-failure-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val errorType: String, val errorMessage: String) : PluginRuntimeEvent

PluginJvmControlResponse

sealed interface PluginJvmControlResponse : PluginJvmMessage

PluginJvmFrameCodec

object PluginJvmFrameCodec

PluginJvmJson

object PluginJvmJson

PluginJvmLimits

object PluginJvmLimits

PluginJvmMessage

sealed interface PluginJvmMessage

PluginLogEvent

@Serializable

data class PluginLogEvent(val kind: String = "plugin-log-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val level: String, val message: String, val droppedCount: Long = 0) : PluginRuntimeEvent

PluginProcessExitedEvent

@Serializable

data class PluginProcessExitedEvent(val kind: String = "plugin-process-exited-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val exitCode: Int) : PluginJvmMessage

PluginReadyEvent

@Serializable

data class PluginReadyEvent(val kind: String = "plugin-ready-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val runtimeMode: String) : PluginRuntimeEvent

PluginRouteInventoryItem

@Serializable

data class PluginRouteInventoryItem(val routeType: String, val path: String, val method: String? = null, val endpointId: String? = null)

PluginRuntimeEvent

sealed interface PluginRuntimeEvent : PluginJvmMessage

PluginSseClosedEvent

@Serializable

data class PluginSseClosedEvent(val kind: String = "plugin-sse-closed-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val streamId: String) : PluginRuntimeEvent

PluginSseDataEvent

@Serializable

data class PluginSseDataEvent(val kind: String = "plugin-sse-data-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val streamId: String, val event: String? = null, val data: String? = null, val id: String? = null, val retry: Long? = null) : PluginRuntimeEvent

PluginStoppingEvent

@Serializable

data class PluginStoppingEvent(val kind: String = "plugin-stopping-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val reason: String) : PluginRuntimeEvent

PluginTraceEvent

@Serializable

data class PluginTraceEvent(val kind: String = "plugin-trace-event", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val traceId: String, val spanId: String, val parentSpanId: String? = null, val service: String, val name: String, val startEpochMs: Long, val endEpochMs: Long? = null, val status: String, val attributes: Map<String, String> = emptyMap(), val edgeFrom: String? = null, val edgeTo: String? = null) : PluginRuntimeEvent

ReloadPrepareRequest

@Serializable

data class ReloadPrepareRequest(val kind: String = "reload-prepare-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String) : PluginJvmMessage

ReloadPrepareResponse

@Serializable

data class ReloadPrepareResponse(val kind: String = "reload-prepare-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val accepted: Boolean) : PluginJvmControlResponse

ShutdownRequest

@Serializable

data class ShutdownRequest(val kind: String = "shutdown-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val reason: String = "kernel-stop") : PluginJvmMessage

ShutdownResponse

@Serializable

data class ShutdownResponse(val kind: String = "shutdown-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val accepted: Boolean, val inflightInvokes: Int) : PluginJvmControlResponse

SseCloseRequest

@Serializable

data class SseCloseRequest(val kind: String = "sse-close-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val streamId: String) : PluginJvmMessage

SseCloseResponse

@Serializable

data class SseCloseResponse(val kind: String = "sse-close-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val accepted: Boolean) : PluginJvmControlResponse

SseOpenRequest

@Serializable

data class SseOpenRequest(val kind: String = "sse-open-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val streamId: String, val routePath: String, val requestId: String, val rawPath: String, val pathParameters: Map<String, String>, val queryParameters: Map<String, List<String>>, val headers: Map<String, List<String>>) : PluginJvmMessage

SseOpenResponse

@Serializable

data class SseOpenResponse(val kind: String = "sse-open-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val accepted: Boolean, val errorMessage: String? = null) : PluginJvmControlResponse

StaticFetchRequest

@Serializable

data class StaticFetchRequest(val kind: String = "static-fetch-request", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val authToken: String, val routePath: String, val resourcePath: String, val requestHeaders: Map<String, List<String>> = emptyMap()) : PluginJvmMessage

StaticFetchResponse

@Serializable

data class StaticFetchResponse(val kind: String = "static-fetch-response", val protocolVersion: Int = PLUGIN_JVM_PROTOCOL_VERSION, val pluginId: String, val generation: Long, val timestamp: Long, val messageId: String, val correlationId: String, val status: Int, val headers: Map<String, List<String>> = emptyMap(), val bodyBase64: String? = null, val errorMessage: String? = null) : PluginJvmControlResponse

Properties

PLUGIN_JVM_PROTOCOL_VERSION

const val PLUGIN_JVM_PROTOCOL_VERSION: Int = 2