class DisplayDataResponse(val data: JsonElement? = null, val metadata: JsonElement? = null, val transient: JsonElement? = null) : AbstractMessageContent

ErrorJupyterResponse

class ErrorJupyterResponse(val stdErr: String?, val exception: ReplException? = null, val metadata: EvaluatedSnippetMetadata? = null) : JupyterResponse

ExecuteAbortReply

@Serializable

class ExecuteAbortReply : MessageReplyContent, ExecuteReply

ExecuteErrorReply

@Serializable

class ExecuteErrorReply(val executionCount: ExecutionCount, val name: String, val value: String, val traceback: List<String>, val additionalInfo: JsonObject) : MessageReplyContent, ExecuteReply

ExecuteReply

@Serializable(with = ExecuteReplySerializer::class)

sealed interface ExecuteReply : MessageContent

ExecuteReplyMetadata

@Serializable

data class ExecuteReplyMetadata(val dependenciesMet: Boolean = true, val engine: String, val status: MessageStatus, val startedTime: String, val evalMetadata: EvaluatedSnippetMetadata?)

ExecuteReplySerializer

object ExecuteReplySerializer : KSerializer<ExecuteReply>

ExecuteRequest

@Serializable

data class ExecuteRequest(val code: String, val silent: Boolean = false, val storeHistory: Boolean = true, val userExpressions: Map<String, String> = mapOf(), val userVariables: List<String> = listOf(), val allowStdin: Boolean = true, val stopOnError: Boolean = true) : AbstractMessageContent

ExecuteSuccessReply

@Serializable

class ExecuteSuccessReply(val executionCount: ExecutionCount, val payload: List<Payload> = listOf(), val userExpressions: Map<String, JsonElement> = mapOf(), val additionalInfo: JsonObject? = null) : MessageReplyContent, ExecuteReply

ExecutionCount

@JvmInline

@Serializable

value class ExecutionCount(val value: Int)

Typesafe wrapper for execution counts created by ExecutionCounter.

ExecutionCounter

class ExecutionCounter(initialValue: Int)

Class responsible for tracking the execution count that is sent from the kernel to the client for all execution requests. It should be sent back to the client in execute_reply and execute_input messages.

ExecutionInputReply

@Serializable

class ExecutionInputReply(val code: String, val executionCount: ExecutionCount) : AbstractMessageContent

ExecutionResultMessage

@Serializable

class ExecutionResultMessage(val data: JsonElement, val metadata: JsonElement, val executionCount: ExecutionCount) : AbstractMessageContent

HelpLink

@Serializable

class HelpLink(val text: String, val url: String)

HistoryReply

@Serializable

class HistoryReply(val history: List<String>) : AbstractMessageContent

HistoryRequest

@Serializable

class HistoryRequest(val output: Boolean, val raw: Boolean, val hist_access_type: String, val session: Int? = null, val start: Int? = null, val stop: Int? = null, val n: Int? = null, val pattern: String? = null, val unique: Boolean? = null) : AbstractMessageContent

IdeCompatibleMessageRequestProcessor

open class IdeCompatibleMessageRequestProcessor(rawIncomingMessage: RawMessage, messageFactoryProvider: MessageFactoryProvider, val socketManager: JupyterBaseSockets, commManager: CommManagerInternal, executor: JupyterExecutor, executionCounter: ExecutionCounter, loggerFactory: KernelLoggerFactory, repl: ReplForJupyter) : AbstractMessageRequestProcessor, JupyterCommunicationFacility

InputReply

@Serializable

class InputReply(val value: String) : AbstractMessageContent

InputRequest

@Serializable

class InputRequest(val prompt: String, val password: Boolean = false) : AbstractMessageContent

InspectReply

@Serializable

class InspectReply(val found: Boolean, val data: JsonObject = Json.EMPTY, val metadata: JsonObject = Json.EMPTY) : OkReply

InspectRequest

@Serializable

class InspectRequest(val code: String, val cursorPos: Int, val detailLevel: DetailLevel) : AbstractMessageContent

InterruptRequest

@Serializable

class InterruptRequest : AbstractMessageContent

InterruptResponse

@Serializable

class InterruptResponse : AbstractMessageContent

IsCompleteReply

@Serializable

class IsCompleteReply(val status: String, val indent: String? = null) : AbstractMessageContent

IsCompleteRequest

@Serializable

class IsCompleteRequest(val code: String) : AbstractMessageContent

JupyterBaseSockets

interface JupyterBaseSockets

Interface describing the sockets available in a Jupyter Kernel.

JupyterCommunicationFacility

interface JupyterCommunicationFacility

JupyterCommunicationFacilityImpl

class JupyterCommunicationFacilityImpl(val socketManager: JupyterBaseSockets, messageFactoryProvider: Provider<MessageFactory>) : JupyterCommunicationFacility

JupyterConnectionInternal

interface JupyterConnectionInternal : JupyterConnection

JupyterOutType

enum JupyterOutType : Enum<JupyterOutType>

JupyterResponse

sealed interface JupyterResponse

JupyterSocketManager

interface JupyterSocketManager : JupyterBaseSockets, JupyterSocketManagerBase, Closeable

Interface responsible for controlling the lifecycle of kernel sockets.

KernelInfoReply

@Serializable

class KernelInfoReply(val protocolVersion: String, val implementation: String, val implementationVersion: String, val banner: String, val languageInfo: LanguageInfo, val helpLinks: List<HelpLink>) : OkReply

KernelInfoReplyMetadata

@Serializable

class KernelInfoReplyMetadata(val state: EvaluatedSnippetMetadata)

KernelInfoRequest

@Serializable

class KernelInfoRequest : AbstractMessageContent

KernelStatus

@Serializable

enum KernelStatus : Enum<KernelStatus>

ListErrorsReply

@Serializable

class ListErrorsReply(val code: String, val errors: List<ScriptDiagnostic>) : AbstractMessageContent

ListErrorsRequest

@Serializable

class ListErrorsRequest(val code: String) : AbstractMessageContent

Message

data class Message(val id: List<ByteArray> = listOf(), val data: MessageData = MessageData())

MessageContent

interface MessageContent

MessageData

@Serializable(with = MessageDataSerializer::class)

data class MessageData(val header: MessageHeader? = null, val parentHeader: MessageHeader? = null, val metadata: JsonElement? = null, val content: MessageContent? = null)

MessageDataSerializer

object MessageDataSerializer : KSerializer<MessageData>

MessageFactory

interface MessageFactory

MessageFactoryImpl

class MessageFactoryImpl : MessageFactory

MessageFactoryProvider

interface MessageFactoryProvider : UpdatableProvider<MessageFactory>

MessageFactoryProviderImpl

class MessageFactoryProviderImpl : UpdatableProviderImpl<MessageFactory> , MessageFactoryProvider

MessageHandler

interface MessageHandler

MessageHeader

@Serializable

data class MessageHeader(val id: String, val type: MessageType, val session: String? = null, val username: String? = null, val version: String? = null, val date: String? = null)

MessageMetadata

@Serializable

class MessageMetadata

MessageReplyContent

@Serializable

abstract class MessageReplyContent(val status: MessageStatus) : AbstractMessageContent

MessageRequestProcessor

interface MessageRequestProcessor

MessageStatus

@Serializable

enum MessageStatus : Enum<MessageStatus>

MessageType

@Serializable(with = MessageTypeSerializer::class)

enum MessageType : Enum<MessageType>

MessageTypeSerializer

object MessageTypeSerializer : KSerializer<MessageType>

NoOpDisplayHandler

object NoOpDisplayHandler : DisplayHandler

OkJupyterResponse

class OkJupyterResponse(val displayResult: DisplayResult?, val metadata: EvaluatedSnippetMetadata? = null) : JupyterResponse

OkReply

@Serializable

abstract class OkReply : MessageReplyContent

OpenDebugPortReply

@Serializable

class OpenDebugPortReply(val port: Int?) : OkReply

Paragraph

@Serializable

class Paragraph(val cursor: Int, val text: String)

Payload

@Serializable

class Payload(val source: String)

ProvidedCommMessages

object ProvidedCommMessages

ScriptDiagnosticSerializer

object ScriptDiagnosticSerializer : KSerializer<ScriptDiagnostic>

ShutdownRequest

@Serializable

class ShutdownRequest(val restart: Boolean) : AbstractMessageContent

ShutdownResponse

@Serializable

class ShutdownResponse(val restart: Boolean) : AbstractMessageContent

SocketDisplayHandler

class SocketDisplayHandler(communicationFacility: JupyterCommunicationFacility, notebook: MutableNotebook) : DisplayHandler

StatusReply

@Serializable

class StatusReply(val status: KernelStatus) : AbstractMessageContent

StreamResponse

@Serializable

class StreamResponse(val name: String, val text: String) : AbstractMessageContent

Properties

EXECUTION_INTERRUPTED_MESSAGE

const val EXECUTION_INTERRUPTED_MESSAGE: String

ISO8601DateNow

val ISO8601DateNow: String

Functions

doWrappedInBusyIdle

fun JupyterCommunicationFacility.doWrappedInBusyIdle(action: () -> Unit)

getInput

fun JupyterCommunicationFacility.getInput(prompt: String = DefaultPromptOptions.PROMPT, password: Boolean = DefaultPromptOptions.IS_PASSWORD): String

makeDefaultHeader

fun MessageFactory.makeDefaultHeader(msgType: MessageType): MessageHeader

makeHeader

fun makeHeader(type: MessageType, sessionId: String?, username: String?): MessageHeader

fun makeHeader(msgType: MessageType? = null, incomingMsg: RawMessage? = null, sessionId: String? = null): MessageHeader

makeReplyMessage

fun makeReplyMessage(msg: RawMessage, msgType: MessageType? = null, sessionId: String? = null, header: MessageHeader? = null, parentHeader: MessageHeader? = null, metadata: JsonElement? = null, content: MessageContent? = null): Message

makeReplyMessage