keel-core/com.keel.kernel.isolation/PluginProcessSupervisor

PluginProcessSupervisor

class PluginProcessSupervisor(descriptor: PluginDescriptor, pluginClassName: String, config: PluginConfig, expectedRoutes: List<PluginRouteDefinition>, classpath: String, runtimeDir: Path, generation: PluginGeneration, onStateChange: (PluginProcessState) -> Unit, onHealthChange: (PluginHealthState) -> Unit, onFailure: (PluginFailureRecord) -> Unit = {}, onTerminalFailure: (reason: String, suggestTcpFallback: Boolean) -> Unit = { _, _ -> }, forcedCommunicationMode: JvmCommunicationMode? = null, observabilityHub: ObservabilityHub? = null)(source)

Constructors

PluginProcessSupervisor

constructor(descriptor: PluginDescriptor, pluginClassName: String, config: PluginConfig, expectedRoutes: List<PluginRouteDefinition>, classpath: String, runtimeDir: Path, generation: PluginGeneration, onStateChange: (PluginProcessState) -> Unit, onHealthChange: (PluginHealthState) -> Unit, onFailure: (PluginFailureRecord) -> Unit = {}, onTerminalFailure: (reason: String, suggestTcpFallback: Boolean) -> Unit = { _, _ -> }, forcedCommunicationMode: JvmCommunicationMode? = null, observabilityHub: ObservabilityHub? = null)

Functions

suspend fun closeSseStream(streamId: String): SseCloseResponse

diagnosticsSnapshot

fun diagnosticsSnapshot(): PluginRuntimeDiagnostics

fetchStaticResource

suspend fun fetchStaticResource(routePath: String, resourcePath: String, requestHeaders: Map<String, List<String>>): StaticFetchResponse

fun forceKill(): Boolean

suspend fun invoke(endpoint: PluginEndpointDefinition<*, *>, call: ApplicationCall, bodyJson: String?): InvokeResponse

suspend fun openSseStream(streamId: String, routePath: String, requestId: String, rawPath: String, pathParameters: Map<String, String>, queryParameters: Map<String, List<String>>, headers: Map<String, List<String>>): SseOpenResponse

fun processHandle(): ProcessHandle?

fun processId(): Long?

registerSseStreamListener

fun registerSseStreamListener(streamId: String, onData: (PluginSseDataEvent) -> Unit, onClosed: () -> Unit)

suspend fun start()

suspend fun stop()

unregisterSseStreamListener

fun unregisterSseStreamListener(streamId: String)