socket/io.devconsole.socket

Package-level declarations

Types

enum BinaryPreviewEncoding : Enum<BinaryPreviewEncoding>

enum BinaryPreviewPolicy : Enum<BinaryPreviewPolicy>

class InMemorySocketStore(maxConnections: Int = DEFAULT_MAX_CONNECTIONS, maxMessagesPerConnection: Int = DEFAULT_MAX_MESSAGES_PER_CONNECTION) : SocketStore

Bounded, thread-safe in-memory store for socket lifecycle and redacted frame previews.

MqttFrameMetadata

object MqttFrameMetadata

MQTT topic/qos/retained metadata carried in SocketMessage.contentType rather than as new fields on SocketMessage -- see the design spec's "MQTT capture reuses the socket pipeline" section. The encoding is hand-rolled and dependency-free (no JSON/URL-encoding library pulled into sdk:socket just for this): "application/mqtt; topic=<enc>; qos=<n>; retained=<bool>", where <enc> escapes only the three characters that would otherwise break this format's own delimiters.

SocketConnection

data class SocketConnection(val id: String, val url: String, val openedAtEpochMs: Long, val closedAtEpochMs: Long? = null, val state: SocketConnectionState = SocketConnectionState.OPEN, val error: String? = null, val reconnectAttempt: Int = 0, val messages: List<SocketMessage> = emptyList(), val protocol: SocketProtocol = SocketProtocol.WEBSOCKET)

SocketConnectionState

enum SocketConnectionState : Enum<SocketConnectionState>

SocketDirection

enum SocketDirection : Enum<SocketDirection>

SocketFrameType

enum SocketFrameType : Enum<SocketFrameType>

SocketLifecycleEvent

data class SocketLifecycleEvent(val connectionId: String, val type: SocketLifecycleType, val timestampEpochMs: Long, val code: Int? = null, val reason: String? = null, val error: String? = null)

SocketLifecycleType

enum SocketLifecycleType : Enum<SocketLifecycleType>

SocketMessage

data class SocketMessage(val connectionId: String, val direction: SocketDirection, val timestampEpochMs: Long, val payload: SocketPayload, val contentType: String? = null)

SocketMessageMetadata

data class SocketMessageMetadata(val frameType: SocketFrameType = SocketFrameType.TEXT, val textFormat: SocketTextFormat = SocketTextFormat.TEXT)

SocketMessageQuery

data class SocketMessageQuery(val connectionIds: Set<String> = emptySet(), val directions: Set<SocketDirection> = emptySet(), val frameTypes: Set<SocketFrameType> = emptySet(), val fromEpochMs: Long? = null, val toEpochMs: Long? = null, val query: String? = null, val hasError: Boolean? = null)

SocketPayload

sealed interface SocketPayload

SocketProtocol

enum SocketProtocol : Enum<SocketProtocol>

Discriminates the wire protocol a SocketConnection carries -- plain WebSocket vs MQTT.

SocketRecorder

class SocketRecorder(redaction: RedactionEngine, store: SocketStore, enabled: Boolean = true, clock: () -> Long = System::currentTimeMillis)

Manual socket capture API. Every method is fail-open so host socket behavior remains isolated. When enabled is false, every method returns immediately without redacting or touching store.

SocketStore

interface SocketStore

SocketTextFormat

enum SocketTextFormat : Enum<SocketTextFormat>