socket/io.devconsole.socket/InMemorySocketStore

InMemorySocketStore

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.

One small function per SocketStore operation plus the byte/connection-capacity helpers this class alone owns; splitting further would fragment one cohesive bounded-storage boundary.

Constructors

InMemorySocketStore

constructor(maxConnections: Int = DEFAULT_MAX_CONNECTIONS, maxMessagesPerConnection: Int = DEFAULT_MAX_MESSAGES_PER_CONNECTION)

Types

Companion

object Companion

Functions

append

open override fun append(message: SocketMessage)

appendLifecycle

open override fun appendLifecycle(event: SocketLifecycleEvent)

clear

fun clear()

open override fun close(connectionId: String, state: SocketConnectionState, timestampEpochMs: Long, error: String? = null)

connection

open override fun connection(id: String): SocketConnection?

connections

open override fun connections(): List<SocketConnection>

lifecycleEvents

open override fun lifecycleEvents(connectionId: String? = null): List<SocketLifecycleEvent>

messages

open override fun messages(query: SocketMessageQuery): List<SocketMessage>

open override fun messages(connectionId: String? = null): List<SocketMessage>

open

open override fun open(connection: SocketConnection)

transition

open override fun transition(connectionId: String, state: SocketConnectionState, timestampEpochMs: Long, code: Int? = null, reason: String? = null, error: String? = null)

withByteCapacity

fun withByteCapacity(maxBytes: Long): InMemorySocketStore