Index

A B C D E F G H I J K L M N O P Q R S T U V W X Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

accept(long) - Method in class express.mvp.myra.transport.nio.NioBackend

accept(long) - Method in interface express.mvp.myra.transport.TransportBackend

Accepts an incoming connection (server mode).

acquire() - Method in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Acquires a buffer from the pool.

acquire() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Acquires a buffer from the pool, blocking if necessary.

acquire() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

acquire(SocketAddress, ConnectionHandler) - Method in interface express.mvp.myra.transport.ConnectionPool

Acquires a connection to the specified endpoint.

acquire(SocketAddress, ConnectionHandler) - Method in class express.mvp.myra.transport.ConnectionPoolImpl

acquireBuffer() - Method in class express.mvp.myra.transport.TcpTransport

acquireBuffer() - Method in interface express.mvp.myra.transport.Transport

Acquires a registered buffer for zero-copy I/O.

acquireWithTimeout(Duration) - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Acquires a buffer, blocking up to the specified timeout if none are available.

Acquisition Modes - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

activeConnections(int) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Sets the active connection count.

addListener(ConnectionStateListener) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Registers a listener for state change events.

addListener(ShutdownListener) - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Registers a listener for shutdown events.

address() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Returns the raw native address of the segment.

address() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

Advanced Features - Section in class express.mvp.myra.transport.iouring.IoUringBackend

Advanced Features - Section in class express.mvp.myra.transport.iouring.LibUring

AF_INET - Static variable in class express.mvp.myra.transport.iouring.LibUring

AF_INET - IPv4 Internet protocols.

allocate(long) - Method in class express.mvp.myra.transport.memory.TrackedArena

Allocates memory from this arena with tracking.

allocate(long, long) - Method in class express.mvp.myra.transport.memory.TrackedArena

Allocates aligned memory from this arena with tracking.

Architecture - Section in class express.mvp.myra.transport.TcpTransport

Architecture - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

Architecture - Section in class express.mvp.myra.transport.iouring.IoUringBackend

Architecture - Section in class express.mvp.myra.transport.nio.NioBackend

Architecture - Section in interface express.mvp.myra.transport.Transport

arena() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the arena managing this buffer's memory lifecycle.

Arena Types - Section in class express.mvp.myra.transport.memory.TrackedArena

Asynchronous Operation Model - Section in interface express.mvp.myra.transport.Transport

available() - Method in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Returns the number of currently available buffers.

available() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Returns the number of currently available buffers.

available() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Returns the number of buffers currently available for acquisition.

available() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

availableBufferSpace() - Method in class express.mvp.myra.transport.TcpTransport

availableBufferSpace() - Method in interface express.mvp.myra.transport.Transport

Returns the number of buffers currently available in the pool.

avgBatchSize(double) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the average batch size.

avgWaitTimeMillis() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the average wait time in milliseconds.

avgWaitTimeNanos() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the avgWaitTimeNanos record component.

awaitAvailable(Duration) - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Waits for a buffer to become available without acquiring it.

awaitTermination(Duration) - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Waits for shutdown to complete.

B

Backend Selection - Section in class express.mvp.myra.transport.TransportFactory

BackendStats - Class in express.mvp.myra.transport

Statistics for I/O backend operations.

BackendStats.Builder - Class in express.mvp.myra.transport

Builder for constructing BackendStats instances.

backendType() - Method in class express.mvp.myra.transport.TransportConfig

Returns the selected I/O backend type.

backendType(TransportConfig.BackendType) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the I/O backend type.

backoffMultiplier(double) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets the backoff multiplier.

Batch Submission - Section in interface express.mvp.myra.transport.TransportBackend

batchSubmissions(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the batch submission count.

Best Practices - Section in package express.mvp.myra.transport.memory

bind(SocketAddress) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

bind(SocketAddress) - Method in class express.mvp.myra.transport.nio.NioBackend

bind(SocketAddress) - Method in interface express.mvp.myra.transport.TransportBackend

Binds to a local address for accepting connections (server mode).

Buffer Lifecycle - Section in interface express.mvp.myra.transport.RegisteredBuffer

Buffer Lifecycle - Section in interface express.mvp.myra.transport.TransportHandler

BufferPoolMetrics - Record Class in express.mvp.myra.transport.buffer

Immutable snapshot of buffer pool performance metrics.

BufferPoolMetrics(long, long, long, long, long, int, int) - Constructor for record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Creates an instance of a BufferPoolMetrics record class.

BufferRef - Interface in express.mvp.myra.transport.buffer

A reference-counted handle to a shared off-heap memory segment.

BufferRefImpl - Class in express.mvp.myra.transport.buffer

Lock-free implementation of BufferRef with atomic reference counting.

BufferRefImpl(MemorySegment, int, short, IntConsumer) - Constructor for class express.mvp.myra.transport.buffer.BufferRefImpl

Creates a new buffer reference.

bufferRingAdd(MemorySegment, long, int, short, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Add a buffer to the buffer ring.

bufferRingAdvance(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Advance the buffer ring tail to make buffers visible to the kernel.

bufferRingInit(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Initialize a buffer ring header.

bufferSize() - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Returns the size of each buffer in bytes.

bufferSize(int) - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig.Builder

Sets the size of each buffer.

build() - Method in class express.mvp.myra.transport.BackendStats.Builder

Builds the statistics snapshot.

build() - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Builds the retry policy.

build() - Method in class express.mvp.myra.transport.TransportConfig.Builder

Builds the configuration.

build() - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig.Builder

Builds the configuration.

build() - Method in class express.mvp.myra.transport.TransportHealth.Builder

Builds the health snapshot.

build() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool.Builder

Builds the worker pool.

builder() - Static method in class express.mvp.myra.transport.BackendStats

Creates a new builder for constructing stats.

builder() - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a builder for custom policy configuration.

builder() - Static method in class express.mvp.myra.transport.TransportConfig

Creates a new builder for constructing configuration.

builder() - Static method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Creates a new builder for constructing configuration.

builder() - Static method in class express.mvp.myra.transport.TransportHealth

Creates a new builder for constructing health snapshots.

builder() - Static method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Creates a new builder for configuring the worker pool.

Builder() - Constructor for class express.mvp.myra.transport.BackendStats.Builder

Builder() - Constructor for class express.mvp.myra.transport.error.RetryPolicy.Builder

Builder() - Constructor for class express.mvp.myra.transport.TransportConfig.Builder

Builder() - Constructor for class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig.Builder

Builder() - Constructor for class express.mvp.myra.transport.TransportHealth.Builder

Built-in Policies - Section in class express.mvp.myra.transport.error.RetryPolicy

C

calculateDelay(RetryContext) - Method in class express.mvp.myra.transport.error.RetryPolicy

Calculates the delay before the next retry.

canClose() - Method in enum class express.mvp.myra.transport.iouring.ConnectionState

Checks if the close operation can be initiated in this state.

canClose() - Method in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

canConnect() - Method in enum class express.mvp.myra.transport.iouring.ConnectionState

Checks if the connect operation can be initiated in this state.

canConnect() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if a connect operation can be initiated.

canConnect() - Method in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

canDoIO() - Method in enum class express.mvp.myra.transport.iouring.ConnectionState

Checks if I/O operations (send/receive) can be performed in this state.

canDoIO() - Method in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

canReconnect() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if the connection can be reconnected.

capacity() - Method in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Returns the total capacity of the pool.

capacity() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Returns the total capacity of the pool.

capacity() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the total capacity of this buffer in bytes.

capacity() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Returns the total number of buffers in the pool.

capacity() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

Classification Strategy - Section in class express.mvp.myra.transport.error.ErrorClassifier

classify(Throwable) - Static method in class express.mvp.myra.transport.error.ErrorClassifier

Classifies an exception into an error category.

clean() - Method in class express.mvp.myra.transport.memory.NativeMemoryCleaner.TrackedCleanable

Performs explicit cleanup.

clear() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Clears all tracking data.

clear() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Clears the buffer for writing.

clearCustomClassifiers() - Static method in class express.mvp.myra.transport.error.ErrorClassifier

Clears all custom classifiers.

close() - Method in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Closes the pool and releases all memory.

close() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Closes the pool and releases all resources.

close() - Method in interface express.mvp.myra.transport.ConnectionPool

Closes all connections and shuts down the pool.

close() - Method in class express.mvp.myra.transport.ConnectionPoolImpl

close() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

close() - Method in class express.mvp.myra.transport.memory.NativeMemoryCleaner.TrackedCleanable

close() - Method in class express.mvp.myra.transport.memory.TrackedArena

Closes this arena and releases all memory.

close() - Method in class express.mvp.myra.transport.nio.NioBackend

close() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Releases this buffer back to its pool.

close() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Closes the pool and releases all underlying resources.

close() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

close() - Method in class express.mvp.myra.transport.TcpTransport

close() - Method in interface express.mvp.myra.transport.Transport

Closes the transport and releases all resources.

close() - Method in interface express.mvp.myra.transport.TransportBackend

Closes the backend and releases all resources.

close() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

CLOSED - Enum constant in enum class express.mvp.myra.transport.iouring.ConnectionState

Connection closed - terminal state.

CLOSED - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Terminal state - connection fully closed.

CLOSED - Enum constant in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

CLOSING - Enum constant in enum class express.mvp.myra.transport.iouring.ConnectionState

Graceful shutdown in progress.

CLOSING - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Graceful close in progress.

CLOSING - Enum constant in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Closing phase - actively closing connections.

CLOSING - Enum constant in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

Common Causes - Section in exception class express.mvp.myra.transport.TransportException

Common Error Scenarios - Section in class express.mvp.myra.transport.iouring.ErrnoHandler

completed() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the value of the completed record component.

CompletionHandler - Interface in express.mvp.myra.transport

Callback interface for handling completion of asynchronous I/O operations.

Configuration - Section in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Configuration Options - Section in class express.mvp.myra.transport.TransportConfig

connect(SocketAddress) - Method in class express.mvp.myra.transport.TcpTransport

connect(SocketAddress) - Method in interface express.mvp.myra.transport.Transport

Initiates an asynchronous connection to a remote endpoint.

connect(SocketAddress, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

connect(SocketAddress, long) - Method in class express.mvp.myra.transport.nio.NioBackend

connect(SocketAddress, long) - Method in interface express.mvp.myra.transport.TransportBackend

Connects to a remote endpoint asynchronously.

CONNECTED - Enum constant in enum class express.mvp.myra.transport.iouring.ConnectionState

Connection established and ready for I/O operations.

CONNECTED - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Actively connected and ready for I/O operations.

CONNECTED - Enum constant in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

CONNECTING - Enum constant in enum class express.mvp.myra.transport.iouring.ConnectionState

Asynchronous connection attempt in progress.

CONNECTING - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Connection attempt in progress.

CONNECTING - Enum constant in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

ConnectionHandler - Interface in express.mvp.myra.transport

Callback interface for handling connection pool acquisition events.

Connection Lifecycle - Section in interface express.mvp.myra.transport.ConnectionPool

Connection Limits - Section in class express.mvp.myra.transport.ConnectionPoolImpl

ConnectionPool - Interface in express.mvp.myra.transport

Connection pool for managing TCP connections to multiple endpoints.

ConnectionPoolImpl - Class in express.mvp.myra.transport

Thread-safe connection pool implementation.

ConnectionPoolImpl(TransportConfig) - Constructor for class express.mvp.myra.transport.ConnectionPoolImpl

Creates a new connection pool with the specified configuration.

ConnectionState - Enum Class in express.mvp.myra.transport.iouring

Represents the lifecycle state of a transport connection.

ConnectionState - Enum Class in express.mvp.myra.transport.lifecycle

Represents the states of a transport connection.

ConnectionStateListener - Interface in express.mvp.myra.transport.lifecycle

Callback interface for connection state change events.

ConnectionStateMachine - Class in express.mvp.myra.transport.lifecycle

Thread-safe state machine for managing connection lifecycle.

ConnectionStateMachine() - Constructor for class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Creates a new state machine in ConnectionState.NEW state.

ConnectionStateMachine(String) - Constructor for class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Creates a new state machine with an identifier.

connectionTimeout() - Method in class express.mvp.myra.transport.TransportConfig

Returns the TCP connection timeout.

connectionTimeout(Duration) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the TCP connection timeout.

cpuAffinity() - Method in class express.mvp.myra.transport.TransportConfig

Returns the CPU affinity for the I/O thread.

cpuAffinity(int) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the CPU affinity for the I/O thread.

CPU Affinity - Section in class express.mvp.myra.transport.TcpTransport

CPU Affinity - Section in class express.mvp.myra.transport.TransportConfig

CPU Affinity - Section in class express.mvp.myra.transport.util.NativeThread

cqeGetBufferId(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get the buffer ID from a CQE with IORING_CQE_F_BUFFER flag set.

cqeGetFlags(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get CQE flags field.

cqeGetRes(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get CQE res field (result/bytes transferred).

cqeGetUserData(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get CQE user_data field.

cqeHasBuffer(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Check if CQE has buffer ID set (IORING_CQE_F_BUFFER).

cqeSeen(MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Mark a CQE as seen (consumed).

create() - Static method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Creates a worker pool with default settings.

create(TransportConfig, SocketAddress) - Static method in class express.mvp.myra.transport.TransportFactory

Creates a new transport with the given configuration.

create(String) - Static method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Creates a worker pool with the given name prefix.

createBackend(TransportConfig) - Static method in class express.mvp.myra.transport.TransportFactory

Creates an I/O backend based on the configuration.

createBufferPool(TransportConfig) - Static method in class express.mvp.myra.transport.TransportFactory

Creates a registered buffer pool with the configured parameters.

createFromAccepted(int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

createFromAccepted(int) - Method in class express.mvp.myra.transport.nio.NioBackend

createFromAccepted(int) - Method in interface express.mvp.myra.transport.TransportBackend

Creates a new backend instance from an accepted connection handle.

createNonBlockingSocket() - Static method in class express.mvp.myra.transport.iouring.LibUring

Helper: Create and configure a non-blocking TCP socket.

createPool(TransportConfig) - Static method in class express.mvp.myra.transport.TransportFactory

Creates a connection pool for managing multiple connections.

currentAvailable() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the currentAvailable record component.

Custom Classifiers - Section in class express.mvp.myra.transport.error.ErrorClassifier

D

daemon(boolean) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool.Builder

Sets whether worker threads should be daemon threads.

DEFAULT_MAX_PAYLOAD_SIZE - Static variable in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

The default maximum payload size: 16 MB.

defaults() - Static method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Returns a configuration with default values.

deframeMessage(MemorySegment, int, MemorySegment) - Method in interface express.mvp.myra.transport.framing.FramingHandler

Deframes a message by extracting the payload from a framed message.

deframeMessage(MemorySegment, int, MemorySegment) - Method in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Deframes a message by extracting the payload from a framed message.

delegate() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Returns the underlying lock-free buffer pool.

describeError(Throwable) - Static method in class express.mvp.myra.transport.error.ErrorClassifier

Returns a detailed description of the classification result.

description() - Method in enum class express.mvp.myra.transport.error.ErrorCategory

Returns a human-readable description of this category.

Design Goals - Section in class express.mvp.myra.transport.memory.ResourceTracker

Design Principles - Section in class express.mvp.myra.transport.nio.NioBackend

Design Principles - Section in interface express.mvp.myra.transport.CompletionHandler

Design Principles - Section in interface express.mvp.myra.transport.TransportHandler

Design Rationale - Section in class express.mvp.myra.transport.memory.NativeMemoryCleaner

DISCONNECTED - Enum constant in enum class express.mvp.myra.transport.iouring.ConnectionState

Initial state - no connection established.

DISCONNECTED - Enum constant in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

displayName() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Returns a human-readable name for this state.

displayName() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Returns a human-readable name for this phase.

DPDK - Enum constant in enum class express.mvp.myra.transport.TransportConfig.BackendType

DPDK backend (future, experimental).

DRAINING - Enum constant in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Draining phase - graceful shutdown initiated.

E

Efficient Waiting - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

enabled() - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Returns whether registered buffers are enabled.

enabled(boolean) - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig.Builder

Enables or disables registered buffers.

equals(Object) - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Indicates whether some other object is "equal to" this one.

ErrnoHandler - Class in express.mvp.myra.transport.iouring

Utility class for handling Linux errno codes in io_uring operations.

Error Categories - Section in package express.mvp.myra.transport.error

ErrorCategory - Enum Class in express.mvp.myra.transport.error

Categories of transport errors for handling and recovery decisions.

ErrorClassifier - Class in express.mvp.myra.transport.error

Classifies exceptions into error categories for recovery decisions.

Error Recovery - Section in exception class express.mvp.myra.transport.TransportException

Error Recovery - Section in exception class express.mvp.myra.transport.framing.FramingException

Example - Section in exception class express.mvp.myra.transport.framing.FramingException

execute(Runnable) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Executes a task without returning a Future.

exponentialBackoff(int, Duration, Duration) - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a policy with exponential backoff.

exponentialBackoffWithJitter(int, Duration, Duration, double) - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a policy with exponential backoff and jitter.

express.mvp.myra.transport - package express.mvp.myra.transport

express.mvp.myra.transport.buffer - package express.mvp.myra.transport.buffer

express.mvp.myra.transport.error - package express.mvp.myra.transport.error

Error handling and recovery utilities for transport operations.

express.mvp.myra.transport.framing - package express.mvp.myra.transport.framing

Message framing utilities for network protocols.

express.mvp.myra.transport.iouring - package express.mvp.myra.transport.iouring

express.mvp.myra.transport.lifecycle - package express.mvp.myra.transport.lifecycle

Transport lifecycle management including graceful shutdown support.

express.mvp.myra.transport.memory - package express.mvp.myra.transport.memory

Native memory management utilities for the transport layer.

express.mvp.myra.transport.nio - package express.mvp.myra.transport.nio

express.mvp.myra.transport.util - package express.mvp.myra.transport.util

F

F_GETFL - Static variable in class express.mvp.myra.transport.iouring.LibUring

F_GETFL - Get file status flags.

F_SETFL - Static variable in class express.mvp.myra.transport.iouring.LibUring

F_SETFL - Set file status flags.

failed() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the value of the failed record component.

FAILED - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Connection failed or was lost.

failedAcquisitions() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the failedAcquisitions record component.

failedReceives(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the failed receive count.

failedSends(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the failed send count.

failureRate() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the failure rate as a ratio between 0.0 and 1.0.

FATAL - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Fatal errors requiring immediate shutdown.

Features - Section in class express.mvp.myra.transport.memory.TrackedArena

fixedDelay(int, Duration) - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a policy with fixed delay between retries.

flip() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Flips the buffer from writing to reading mode.

forceState(ConnectionState, Throwable) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Forces a transition to a state, bypassing validation.

forceSubmit() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Force a single io_uring_submit syscall after queuing operations.

Frame Format - Section in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

frameMessage(MemorySegment, int, MemorySegment) - Method in interface express.mvp.myra.transport.framing.FramingHandler

Frames a message by adding protocol-specific headers to the payload.

frameMessage(MemorySegment, int, MemorySegment) - Method in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Frames a message by adding protocol-specific headers to the payload.

FramingException - Exception Class in express.mvp.myra.transport.framing

Exception thrown when message framing or deframing fails.

FramingException(String) - Constructor for exception class express.mvp.myra.transport.framing.FramingException

Constructs a new framing exception with the specified detail message.

FramingException(String, Throwable) - Constructor for exception class express.mvp.myra.transport.framing.FramingException

Constructs a new framing exception with the specified detail message and cause.

FramingException(Throwable) - Constructor for exception class express.mvp.myra.transport.framing.FramingException

Constructs a new framing exception with the specified cause.

FramingHandler - Interface in express.mvp.myra.transport.framing

Strategy interface for message framing and deframing in network protocols.

Framing Process - Section in interface express.mvp.myra.transport.framing.FramingHandler

Framing Strategies - Section in package express.mvp.myra.transport.framing

fromErrno(int, String) - Static method in class express.mvp.myra.transport.iouring.ErrnoHandler

Creates a TransportException from an errno code with context.

G

getActiveAllocationBytes() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns the total bytes currently allocated.

getActiveAllocationCount() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns the number of active allocations.

getActiveAllocations() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns all active (unreleased) allocations.

getActiveConnectionCount() - Method in interface express.mvp.myra.transport.ConnectionPool

Returns the total number of active (in-use) connections.

getActiveConnectionCount() - Method in class express.mvp.myra.transport.ConnectionPoolImpl

getActiveConnections() - Method in class express.mvp.myra.transport.TransportHealth

Returns the number of active connections.

getActiveCount() - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Returns the number of active registrations (registered - cleaned).

getActiveTasks() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the approximate number of tasks currently being executed.

getAgeMillis() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns the age of this allocation.

getAllBuffers() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

Returns the array of all buffers for backend registration.

getAllocationCount() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns total allocation count.

getAllocationTime() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns when the allocation occurred.

getAttemptCount() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the current attempt count.

getAvgBatchSize() - Method in class express.mvp.myra.transport.BackendStats

Returns the average number of operations per batch.

getBackendType() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

getBackendType() - Method in class express.mvp.myra.transport.nio.NioBackend

getBackendType() - Method in interface express.mvp.myra.transport.TransportBackend

Returns the backend type identifier.

getBatchSubmissions() - Method in class express.mvp.myra.transport.BackendStats

Returns the number of batch submissions.

getBufferGroupId() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Get buffer group ID for multishot receive operations.

getBufferRingBuffer(int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Get a buffer from the buffer ring by ID.

getBufferSegment(RegisteredBuffer) - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

Returns the raw memory segment backing a buffer.

getCompletedTasks() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the number of tasks that have completed successfully.

getConnectionId() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Returns the connection identifier.

getConnectionPool() - Method in class express.mvp.myra.transport.TcpTransport

getConnectionPool() - Method in interface express.mvp.myra.transport.Transport

Returns the connection pool managing connections for this transport.

getConnectionState() - Method in class express.mvp.myra.transport.nio.NioBackend

Gets the current connection state.

getCurrentThreadId() - Static method in class express.mvp.myra.transport.util.NativeThread

Returns the kernel thread ID of the current thread.

getElapsedTime() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the total elapsed time since start.

getErrorMessage() - Method in class express.mvp.myra.transport.TransportHealth

Returns the message describing the most recent error.

getExplicitCleanupCount() - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Returns the number of explicit cleanups (via clean()).

getFailedReceives() - Method in class express.mvp.myra.transport.BackendStats

Returns the number of failed receive operations.

getFailedSends() - Method in class express.mvp.myra.transport.BackendStats

Returns the number of failed send operations.

getFailedTasks() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the number of tasks that failed with an exception.

getFixedFileIndex() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Get the fixed file index (if using fixed files).

getGcCleanupCount() - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Returns the number of GC-triggered cleanups.

getHeaderSize() - Method in interface express.mvp.myra.transport.framing.FramingHandler

Returns the size of the framing header in bytes.

getHeaderSize() - Method in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Returns the size of the framing header in bytes.

getHealth() - Method in class express.mvp.myra.transport.TcpTransport

getHealth() - Method in interface express.mvp.myra.transport.Transport

Returns health metrics for this transport.

getId() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns the allocation ID.

getIdleConnectionCount() - Method in interface express.mvp.myra.transport.ConnectionPool

Returns the total number of idle (available) connections.

getIdleConnectionCount() - Method in class express.mvp.myra.transport.ConnectionPoolImpl

getInFlightCount() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Returns the number of in-flight operations.

getInstance() - Static method in class express.mvp.myra.transport.memory.ResourceTracker

Returns the singleton instance.

getLastAttemptTime() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the time of the last attempt.

getLastError() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the last error encountered.

getLastError() - Method in class express.mvp.myra.transport.TransportHealth

Returns the timestamp of the most recent error.

getLastErrorCategory() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the category of the last error.

getLocalAddress() - Method in class express.mvp.myra.transport.TcpTransport

getLocalAddress() - Method in interface express.mvp.myra.transport.Transport

Returns the local socket address.

getMaxAttempts() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the maximum number of attempts allowed.

getMaxAttempts() - Method in class express.mvp.myra.transport.error.RetryPolicy

Returns the maximum number of attempts.

getMaxPayloadSize() - Method in interface express.mvp.myra.transport.framing.FramingHandler

Returns the maximum payload size that can be framed.

getMaxPayloadSize() - Method in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Returns the maximum payload size that can be framed.

getNamePrefix() - Method in class express.mvp.myra.transport.VirtualThreadFactory

Returns the name prefix used for thread naming.

getNextDelayMillis() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the configured delay for the next retry.

getOperationId() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the operation identifier.

getPendingOperations() - Method in class express.mvp.myra.transport.TransportHealth

Returns the number of I/O operations pending completion.

getPhase() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Returns the current shutdown phase.

getRegistrationCount() - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Returns the total number of registrations.

getRejectedTasks() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the number of tasks rejected due to shutdown.

getReleaseCount() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns total release count.

getRemoteAddress() - Method in class express.mvp.myra.transport.TcpTransport

getRemoteAddress() - Method in interface express.mvp.myra.transport.Transport

Returns the remote socket address.

getRetryCount() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the number of retries (attempts minus 1).

getSize() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns the allocation size in bytes.

getSource() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns the source identifier.

getSource() - Method in class express.mvp.myra.transport.memory.TrackedArena

Returns the source identifier.

getSqe(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

getStackTrace() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

Returns the stack trace at allocation (may be null).

getStartTime() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the time when retries started.

getState() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Returns the current state.

getStats() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

getStats() - Method in class express.mvp.myra.transport.nio.NioBackend

getStats() - Method in interface express.mvp.myra.transport.TransportBackend

Returns statistics about backend operations.

getStats() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns a snapshot of the pool's statistics.

getSubmittedTasks() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the number of tasks that have been submitted.

getSummary() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns a summary of tracking statistics.

getSyscallReductionRatio() - Method in class express.mvp.myra.transport.BackendStats

Calculates the syscall reduction ratio.

getThreadCount() - Method in class express.mvp.myra.transport.VirtualThreadFactory

Returns the number of threads created by this factory.

getThreadCount() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns the number of virtual threads created by this pool.

getToken() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Gets the user-defined token previously set via RegisteredBuffer.setToken(long).

getTotalAllocated() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns cumulative allocated bytes.

getTotalAllocated() - Method in class express.mvp.myra.transport.memory.TrackedArena

Returns total bytes allocated from this arena.

getTotalBytesReceived() - Method in class express.mvp.myra.transport.BackendStats

Returns the cumulative bytes received.

getTotalBytesReceived() - Method in class express.mvp.myra.transport.TransportHealth

Returns the total bytes received since transport creation.

getTotalBytesSent() - Method in class express.mvp.myra.transport.BackendStats

Returns the cumulative bytes sent.

getTotalBytesSent() - Method in class express.mvp.myra.transport.TransportHealth

Returns the total bytes sent since transport creation.

getTotalDelayMillis() - Method in class express.mvp.myra.transport.error.RetryContext

Returns the total time spent waiting in delays.

getTotalReceives() - Method in class express.mvp.myra.transport.BackendStats

Returns the total number of completed receive operations.

getTotalReleased() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Returns cumulative released bytes.

getTotalSends() - Method in class express.mvp.myra.transport.BackendStats

Returns the total number of completed send operations.

getTotalSyscalls() - Method in class express.mvp.myra.transport.BackendStats

Returns the total number of syscalls made.

getValidTransitions(ConnectionState) - Static method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Returns the set of valid target states from a given state.

H

hasAttemptsRemaining() - Method in class express.mvp.myra.transport.error.RetryContext

Checks if there are attempts remaining.

hashCode() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns a hash code value for this object.

hashCode() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns a hash code value for this object.

hasMoreCompletions(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Check if a multishot receive is still active (more completions coming).

hasRemaining() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Checks if there are bytes remaining between position and limit.

HEADER_SIZE - Static variable in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

The size of the length prefix header in bytes.

Health Metrics - Section in class express.mvp.myra.transport.TransportHealth

healthy(boolean) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Sets the overall health status.

I

immediate(int) - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a policy that retries immediately without delay.

Implementation Details - Section in class express.mvp.myra.transport.ConnectionPoolImpl

Important Constraints - Section in class express.mvp.myra.transport.memory.NativeMemoryCleaner

index() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the registration index of this buffer.

initBufferRing() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Initialize buffer ring with default parameters.

initBufferRing(int, int, short) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Initialize a buffer ring for kernel-managed buffer selection.

initialDelay(Duration) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets the initial delay before first retry.

initialize(TransportConfig) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

initialize(TransportConfig) - Method in class express.mvp.myra.transport.nio.NioBackend

initialize(TransportConfig) - Method in interface express.mvp.myra.transport.TransportBackend

Initializes the backend with the given configuration.

inUse() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Returns the number of buffers currently in use.

inUse() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

IO_URING - Enum constant in enum class express.mvp.myra.transport.TransportConfig.BackendType

Linux io_uring backend (recommended for Linux).

IO_URING_BUF_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_buf (single buffer in a ring).

IO_URING_BUF_REG_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_buf_reg (buffer ring registration).

IO_URING_BUF_RING_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_buf_ring (buffer ring header).

IO_URING_CQ_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_cq (Completion Queue).

IO_URING_CQE_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

struct io_uring_cqe - Completion Queue Entry (16 bytes).

IO_URING_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring structure.

IO_URING_PARAMS_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_params.

IO_URING_SQ_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for io_uring_sq (Submission Queue).

IO_URING_SQE_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

struct io_uring_sqe - Submission Queue Entry (64 bytes).

io_uring Architecture Overview - Section in class express.mvp.myra.transport.iouring.LibUring

IORING_CQE_F_BUFFER - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_CQE_F_MORE - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_CQE_F_NOTIF - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_ACCEPT - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_CONNECT - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_NOP - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_READV - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_RECV - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_RECV_MULTISHOT - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_SEND - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_SEND_ZC - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_OP_WRITEV - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_RECV_MULTISHOT - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_REGISTER_PBUF_RING - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_SETUP_COOP_TASKRUN - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_SETUP_CQSIZE - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_SETUP_SINGLE_ISSUER - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_SETUP_SQ_AFF - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_SETUP_SQPOLL - Static variable in class express.mvp.myra.transport.iouring.LibUring

IORING_UNREGISTER_PBUF_RING - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_BUFFER_SELECT - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_CQE_SKIP_SUCCESS - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_FIXED_FILE - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_IO_DRAIN - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_IO_HARDLINK - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOSQE_IO_LINK - Static variable in class express.mvp.myra.transport.iouring.LibUring

IOU_PBUF_RING_MMAP - Static variable in class express.mvp.myra.transport.iouring.LibUring

IoUringBackend - Class in express.mvp.myra.transport.iouring

io_uring-based transport backend for maximum I/O performance on Linux.

IoUringBackend() - Constructor for class express.mvp.myra.transport.iouring.IoUringBackend

Creates a new io_uring backend with default configuration.

IoUringBackend.ExtendedCompletionHandler - Interface in express.mvp.myra.transport.iouring

Extended completion handler that receives CQE flags.

IOVEC_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for iovec structure (for buffer registration).

IPPROTO_TCP - Static variable in class express.mvp.myra.transport.iouring.LibUring

IPPROTO_TCP - TCP protocol.

isAcceptingOperations() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Checks if the coordinator is accepting new operations.

isAcceptingOperations() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Checks if the transport is accepting new operations.

isActive() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if the connection is active and can perform I/O.

isActive() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Checks if the connection is active.

isAtOrAfter(ShutdownPhase) - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Checks if this phase is at or after the specified phase.

isAvailable() - Static method in class express.mvp.myra.transport.iouring.LibUring

Check if io_uring is available on this system.

isBefore(ShutdownPhase) - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Checks if this phase is before the specified phase.

isBufferRingEnabled() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Check if buffer ring is enabled and active.

isBufferRingSupported() - Static method in class express.mvp.myra.transport.iouring.LibUring

Check if buffer ring registration is supported.

isClosed() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if this is a final state with no possible transitions.

isClosed() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Checks if the connection is fully closed.

isClosedOrClosing() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Checks if the connection is closed or closing.

isConnected() - Method in class express.mvp.myra.transport.TcpTransport

isConnected() - Method in interface express.mvp.myra.transport.Transport

Checks if the transport has an active connection.

isConnecting() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if the connection is in the process of establishing.

isConnectionLost(int) - Static method in class express.mvp.myra.transport.iouring.ErrnoHandler

Checks if the errno indicates the connection was lost.

isConnectionRefused(int) - Static method in class express.mvp.myra.transport.iouring.ErrnoHandler

Checks if the errno indicates the connection was refused.

isDaemon() - Method in class express.mvp.myra.transport.VirtualThreadFactory

Returns whether this factory creates daemon threads.

isEnabled() - Method in class express.mvp.myra.transport.memory.ResourceTracker

Checks if tracking is enabled.

isFatal() - Method in enum class express.mvp.myra.transport.error.ErrorCategory

Checks if this is a fatal error requiring shutdown.

isFirstAttempt() - Method in class express.mvp.myra.transport.error.RetryContext

Checks if this is the first attempt.

isHealthy() - Method in class express.mvp.myra.transport.TransportHealth

Returns whether the transport is healthy.

isInUse() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Checks if this buffer is currently acquired from the pool.

isLastAttempt() - Method in class express.mvp.myra.transport.error.RetryContext

Checks if this is the last allowed attempt.

isOpen() - Method in class express.mvp.myra.transport.memory.TrackedArena

Checks if this arena is still open.

isRetryable() - Method in enum class express.mvp.myra.transport.error.ErrorCategory

Checks if errors in this category are generally retryable.

isRetryable(int) - Static method in class express.mvp.myra.transport.iouring.ErrnoHandler

Checks if the errno indicates a retryable (transient) error.

isShutdown() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns whether this pool has been shut down.

isShuttingDown() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Checks if shutdown has been initiated.

isTerminalOrClosing() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Checks if this is a terminal state (CLOSING or CLOSED).

isTerminated() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Checks if shutdown has completed.

isTerminated() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Checks if shutdown is complete.

isTerminated() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Returns whether all tasks have completed following shutdown.

isUsingFixedFile() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Check if fixed file optimization is active for this backend.

isValidTransition(ConnectionState, ConnectionState) - Static method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Checks if a transition from one state to another is valid.

isZeroCopyNotification(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Check if a CQE is a zero-copy notification (not actual completion).

J

jitterFactor(double) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets the jitter factor.

K

KERNEL_TIMESPEC_LAYOUT - Static variable in class express.mvp.myra.transport.iouring.LibUring

Memory layout for __kernel_timespec (for timeout operations).

Key Components - Section in package express.mvp.myra.transport.error

Key Components - Section in package express.mvp.myra.transport.framing

Key Components - Section in package express.mvp.myra.transport.lifecycle

Key Components - Section in package express.mvp.myra.transport.memory

Key Features - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

Key Metrics - Section in class express.mvp.myra.transport.BackendStats

Key Operations - Section in class express.mvp.myra.transport.iouring.LibUring

L

lastError(Instant, String) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Records an error, which also sets healthy to false.

length() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Returns the current length of valid data in the buffer.

length() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

length(int) - Method in interface express.mvp.myra.transport.buffer.BufferRef

Sets the length of valid data in the buffer.

length(int) - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

LengthPrefixedFramingHandler - Class in express.mvp.myra.transport.framing

A framing handler that uses a 4-byte big-endian length prefix.

LengthPrefixedFramingHandler() - Constructor for class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Creates a new length-prefixed framing handler with the default maximum payload size.

LengthPrefixedFramingHandler(int) - Constructor for class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Creates a new length-prefixed framing handler with the specified maximum payload size.

LibUring - Class in express.mvp.myra.transport.iouring

FFM (Foreign Function & Memory) bindings to the Linux liburing native library.

limit() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the current limit of the buffer.

limit(long) - Method in interface express.mvp.myra.transport.RegisteredBuffer

Sets the limit of the buffer.

LockFreeBufferPool - Class in express.mvp.myra.transport.buffer

Lock-free buffer pool using a ring buffer for index tracking.

LockFreeBufferPool(int, int) - Constructor for class express.mvp.myra.transport.buffer.LockFreeBufferPool

Creates a new lock-free buffer pool.

Lock-Free Design - Section in class express.mvp.myra.transport.buffer.LockFreeBufferPool

M

maxAttempts(int) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets the maximum number of attempts.

maxDelay(Duration) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets the maximum delay cap.

maxTotalDuration(Duration) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets maximum total duration for all retry attempts.

maxWaitTimeMillis() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the maximum wait time in milliseconds.

maxWaitTimeNanos() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the maxWaitTimeNanos record component.

Memory Calculation - Section in express.mvp.myra.transport.RegisteredBufferPoolImpl.RegisteredBufferPoolImpl(int, int)

Memory Layout - Section in class express.mvp.myra.transport.RegisteredBufferPoolImpl

Memory Layout - Section in class express.mvp.myra.transport.buffer.BufferRefImpl

Memory Layout - Section in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Memory Layouts - Section in class express.mvp.myra.transport.iouring.LibUring

Memory Model - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

Memory Safety Strategy - Section in package express.mvp.myra.transport.memory

Memory Usage - Section in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Metric Categories - Section in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

metrics() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Returns a snapshot of current pool metrics.

Metrics - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

N

namePrefix(String) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool.Builder

Sets the name prefix for worker threads.

nativeAccept(int, MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Accept a connection on a socket.

nativeBind(int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Bind a socket to a local address.

nativeClose(int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Close a file descriptor.

nativeConnect(int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Connect a socket to a remote address.

nativeFcntl(int, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Manipulate file descriptor.

nativeHtons(short) - Static method in class express.mvp.myra.transport.iouring.LibUring

Convert values between host and network byte order (16-bit).

nativeInetPton(int, MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Convert IPv4/IPv6 address from text to binary form.

nativeListen(int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Listen for connections on a socket.

NativeMemoryCleaner - Class in express.mvp.myra.transport.memory

Provides automatic native memory cleanup using the Cleaner API.

NativeMemoryCleaner.TrackedCleanable - Class in express.mvp.myra.transport.memory

Cleanable wrapper that properly tracks explicit cleanup.

nativeSetsockopt(int, int, int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set socket options.

nativeSocket(int, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Create a socket.

NativeThread - Class in express.mvp.myra.transport.util

Utility for native thread management using the Foreign Function & Memory API.

NETWORK - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Network connectivity errors requiring reconnection.

NEW - Enum constant in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Initial state before any connection attempt.

newThread(Runnable) - Method in class express.mvp.myra.transport.VirtualThreadFactory

Creates a new virtual thread that will execute the given runnable.

NIO - Enum constant in enum class express.mvp.myra.transport.TransportConfig.BackendType

Java NIO backend (portable fallback).

NioBackend - Class in express.mvp.myra.transport.nio

NIO-based transport backend for portable, cross-platform I/O.

NioBackend() - Constructor for class express.mvp.myra.transport.nio.NioBackend

NioBackend.ConnectionState - Enum Class in express.mvp.myra.transport.nio

Connection state for NIO backend.

noRetry() - Static method in class express.mvp.myra.transport.error.RetryPolicy

Returns a policy that never retries.

numBuffers() - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Returns the number of buffers in the pool.

numBuffers(int) - Method in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig.Builder

Sets the number of buffers in the pool.

O

O_NONBLOCK - Static variable in class express.mvp.myra.transport.iouring.LibUring

O_NONBLOCK - Non-blocking I/O mode.

ofConfined(String) - Static method in class express.mvp.myra.transport.memory.TrackedArena

Creates a tracked confined arena.

ofShared(String) - Static method in class express.mvp.myra.transport.memory.TrackedArena

Creates a tracked shared arena.

onClosed() - Method in interface express.mvp.myra.transport.TransportHandler

Called when the transport is closed.

onClosed() - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when the transport is closed.

onComplete(long, int) - Method in interface express.mvp.myra.transport.CompletionHandler

Called when an asynchronous I/O operation completes.

onComplete(long, int) - Method in interface express.mvp.myra.transport.iouring.IoUringBackend.ExtendedCompletionHandler

onComplete(long, int, int) - Method in interface express.mvp.myra.transport.iouring.IoUringBackend.ExtendedCompletionHandler

Called when an operation completes with flags.

onConnected(long) - Method in interface express.mvp.myra.transport.TransportHandler

Called when a connection is successfully established.

onConnected(long) - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when a connection is successfully established.

onConnectionAcquired(Transport, long) - Method in interface express.mvp.myra.transport.ConnectionHandler

Called when a connection is successfully acquired from the pool.

onConnectionFailed(long, Throwable) - Method in interface express.mvp.myra.transport.TransportHandler

Called when a connection attempt fails.

onConnectionFailed(long, Throwable) - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when a connection attempt fails.

onConnectionFailed(Throwable, long) - Method in interface express.mvp.myra.transport.ConnectionHandler

Called when connection acquisition fails.

onDataReceived(MemorySegment) - Method in interface express.mvp.myra.transport.TransportHandler

Called when data is received from the remote peer.

onDataReceived(MemorySegment) - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when data is received from the remote peer.

onDrainProgress(int, int) - Method in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Called periodically during drain phase to report progress.

onPhaseChange(ShutdownPhase, ShutdownPhase) - Method in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Called when the shutdown phase changes.

onSendComplete(long) - Method in interface express.mvp.myra.transport.TransportHandler

Called when a send operation completes successfully.

onSendComplete(long) - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when a send operation completes successfully.

onSendFailed(long, Throwable) - Method in interface express.mvp.myra.transport.TransportHandler

Called when a send operation fails.

onSendFailed(long, Throwable) - Method in class express.mvp.myra.transport.TransportHandlerAdapter

Called when a send operation fails.

onShutdownComplete(boolean, long) - Method in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Called when shutdown is complete.

onShutdownError(ShutdownPhase, Throwable) - Method in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Called if an error occurs during shutdown.

onStateChanged(ConnectionState, ConnectionState) - Method in interface express.mvp.myra.transport.lifecycle.ConnectionStateListener

Called when the connection state changes (without cause information).

onStateChanged(ConnectionState, ConnectionState, Throwable) - Method in interface express.mvp.myra.transport.lifecycle.ConnectionStateListener

Called when the connection state changes.

operationCompleted() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Records that an operation has completed.

Operation Flow - Section in interface express.mvp.myra.transport.TransportBackend

operationStarted() - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Records that an operation has started.

order() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Returns the numeric order of this state.

order() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Returns the numeric order of this phase for comparison.

P

Page Alignment - Section in class express.mvp.myra.transport.RegisteredBufferPoolImpl

peekCqe(MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Peek for a completion without blocking.

pendingOperations(int) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Sets the pending operation count.

Performance Benefits - Section in interface express.mvp.myra.transport.RegisteredBufferPool

Performance Characteristics - Section in class express.mvp.myra.transport.iouring.IoUringBackend

Performance Characteristics - Section in class express.mvp.myra.transport.iouring.LibUring

Performance Comparison with io_uring - Section in class express.mvp.myra.transport.nio.NioBackend

Performance Considerations - Section in class express.mvp.myra.transport.memory.ResourceTracker

Phase Descriptions - Section in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Phase Transitions - Section in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

pin(int) - Static method in class express.mvp.myra.transport.util.NativeThread

Pins the current thread to the specified CPU core.

Platform Requirements - Section in class express.mvp.myra.transport.util.NativeThread

poll(CompletionHandler) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

poll(CompletionHandler) - Method in class express.mvp.myra.transport.nio.NioBackend

poll(CompletionHandler) - Method in interface express.mvp.myra.transport.TransportBackend

Polls for completions without blocking.

poolIndex() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Returns the unique index of this buffer in the global pool.

poolIndex() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

Pooling Benefits - Section in interface express.mvp.myra.transport.ConnectionPool

poolSize() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the poolSize record component.

Pool Sizing Guidelines - Section in interface express.mvp.myra.transport.RegisteredBufferPool

position() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the current position in the buffer.

position(long) - Method in interface express.mvp.myra.transport.RegisteredBuffer

Sets the current position in the buffer.

Position and Limit - Section in interface express.mvp.myra.transport.RegisteredBuffer

Power of 2 Requirement - Section in class express.mvp.myra.transport.buffer.LockFreeBufferPool

prepAccept(MemorySegment, int, MemorySegment, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare an accept operation.

prepConnect(MemorySegment, int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a connect operation.

prepRecv(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a recv operation.

prepRecvFixed(MemorySegment, int, short, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a recv operation with fixed buffer.

prepRecvFixedFile(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a recv operation using a registered file index.

prepRecvMultishot(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a multi-shot receive operation.

prepRecvMultishotBufferSelect(MemorySegment, int, short, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a multishot receive with buffer ring selection.

prepSend(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a send operation.

prepSendFixed(MemorySegment, int, short, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a send operation with fixed buffer.

prepSendFixedFile(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a send operation using a registered file index.

prepSendZc(MemorySegment, int, MemorySegment, long, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a zero-copy send operation.

prepSendZcFixed(MemorySegment, int, short, int, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Prepare a zero-copy send operation with fixed buffer.

PROTOCOL - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Protocol-level errors indicating invalid communication.

Q

queueExit(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Tear down an io_uring instance.

queueInit(int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Initialize an io_uring instance.

queueInitParams(int, MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Initialize io_uring with parameters.

R

receive(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

receive(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.nio.NioBackend

receive(RegisteredBuffer, long) - Method in interface express.mvp.myra.transport.TransportBackend

Receives data into a registered buffer (zero-copy).

receive(MemorySegment, int, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

receive(MemorySegment, int, long) - Method in class express.mvp.myra.transport.nio.NioBackend

receive(MemorySegment, int, long) - Method in interface express.mvp.myra.transport.TransportBackend

Receives data into a raw memory segment.

receiveMultishot(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Start a persistent multi-shot receive operation.

receiveMultishot(MemorySegment, int, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Start a persistent multi-shot receive operation.

recordDelay(long) - Method in class express.mvp.myra.transport.error.RetryContext

Records that a delay was executed.

recordFailure(Throwable) - Method in class express.mvp.myra.transport.error.RetryContext

Records a failed attempt.

recordFailure(Throwable, ErrorCategory) - Method in class express.mvp.myra.transport.error.RetryContext

Records a failed attempt with explicit category.

recycleBufferRingBuffer(int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Recycle a buffer back to the buffer ring after processing.

Reference Counting - Section in interface express.mvp.myra.transport.buffer.BufferRef

Reference Count States - Section in class express.mvp.myra.transport.buffer.BufferRefImpl

register(Object, Runnable) - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Registers an object for cleanup when it becomes phantom reachable.

registerBufferPool(RegisteredBufferPool) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

registerBufferPool(RegisteredBufferPool) - Method in class express.mvp.myra.transport.nio.NioBackend

registerBufferPool(RegisteredBufferPool) - Method in interface express.mvp.myra.transport.TransportBackend

Registers a buffer pool with this backend for zero-copy I/O.

registerBufferRing(MemorySegment, MemorySegment, int, short) - Static method in class express.mvp.myra.transport.iouring.LibUring

Register a provided buffer ring with io_uring.

registerBuffers(MemorySegment, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Register buffers for zero-copy I/O.

registerClassifier(Class, Predicate) - Static method in class express.mvp.myra.transport.error.ErrorClassifier

Registers a custom classifier for a specific exception type.

RegisteredBuffer - Interface in express.mvp.myra.transport

A pre-registered off-heap buffer for zero-copy I/O operations.

RegisteredBufferPool - Interface in express.mvp.myra.transport

Thread-safe pool for managing pre-registered I/O buffers.

RegisteredBufferPoolImpl - Class in express.mvp.myra.transport

Thread-safe pool implementation of pre-registered buffers for zero-copy I/O.

RegisteredBufferPoolImpl(int, int) - Constructor for class express.mvp.myra.transport.RegisteredBufferPoolImpl

Creates a new buffer pool with the specified number of buffers and size.

registeredBuffers(TransportConfig.RegisteredBuffersConfig) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the registered buffer pool configuration.

Registered Buffers - Section in interface express.mvp.myra.transport.TransportBackend

registeredBuffersConfig() - Method in class express.mvp.myra.transport.TransportConfig

Returns the registered buffer pool configuration.

registerFiles(MemorySegment, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get a submission queue entry.

registerFilesUpdate(MemorySegment, int, MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

registerTracked(Object, Runnable) - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Creates a tracked cleanable that properly distinguishes explicit vs GC cleanup.

registrationId() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Returns the io_uring registration ID if registered.

registrationId() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

rejected() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the value of the rejected record component.

release() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Decrements the reference count.

release() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

release(RegisteredBuffer) - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Releases a buffer back to the pool for reuse.

release(RegisteredBuffer) - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

release(Transport) - Method in interface express.mvp.myra.transport.ConnectionPool

Releases a connection back to the pool.

release(Transport) - Method in class express.mvp.myra.transport.ConnectionPoolImpl

releaseAndSignal(BufferRef) - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Releases a buffer and signals waiting threads.

Release Signaling - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

remaining() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the number of bytes between position and limit.

removeClassifier(Class) - Static method in class express.mvp.myra.transport.error.ErrorClassifier

Removes a previously registered custom classifier.

removeListener(ConnectionStateListener) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Removes a previously registered listener.

removeListener(ShutdownListener) - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Removes a previously registered listener.

Requirements - Section in class express.mvp.myra.transport.iouring.IoUringBackend

Requirements - Section in class express.mvp.myra.transport.iouring.LibUring

requiresReconnect() - Method in enum class express.mvp.myra.transport.error.ErrorCategory

Checks if this error requires connection closure/reconnection.

reset() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

Resets the buffer for reuse after acquisition from pool.

reset() - Method in class express.mvp.myra.transport.error.RetryContext

Resets the context for reuse.

resetMetrics() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Resets all metrics counters to zero.

resetStatistics() - Static method in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Resets all statistics (for testing).

RESOURCE - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Resource exhaustion errors.

ResourceTracker - Class in express.mvp.myra.transport.memory

Tracks native memory allocations for debugging and leak detection.

ResourceTracker.AllocationRecord - Class in express.mvp.myra.transport.memory

Record of a tracked allocation.

Result Interpretation - Section in interface express.mvp.myra.transport.CompletionHandler

retain() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Increments the reference count.

retain() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

RetryContext - Class in express.mvp.myra.transport.error

Tracks the state of retry attempts for an operation.

RetryContext(int) - Constructor for class express.mvp.myra.transport.error.RetryContext

Creates a context with default operation ID.

RetryContext(String, int) - Constructor for class express.mvp.myra.transport.error.RetryContext

Creates a new retry context.

retryNetwork(boolean) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets whether to retry network errors.

RetryPolicy - Class in express.mvp.myra.transport.error

Defines retry behavior for failed operations.

RetryPolicy.Builder - Class in express.mvp.myra.transport.error

Builder for RetryPolicy.

retryResource(boolean) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets whether to retry resource errors.

retryTransient(boolean) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets whether to retry transient errors.

retryUnknown(boolean) - Method in class express.mvp.myra.transport.error.RetryPolicy.Builder

Sets whether to retry unknown errors.

Return Values - Section in express.mvp.myra.transport.framing.FramingHandler.deframeMessage(MemorySegment, int, MemorySegment)

Return Values - Section in express.mvp.myra.transport.framing.FramingHandler.deframeMessage(MemorySegment, int, MemorySegment)

RUNNING - Enum constant in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Normal operation phase.

S

scope() - Method in class express.mvp.myra.transport.memory.TrackedArena

Returns the underlying arena's scope.

Security Considerations - Section in exception class express.mvp.myra.transport.framing.FramingException

segment() - Method in interface express.mvp.myra.transport.buffer.BufferRef

Returns the underlying FFM MemorySegment.

segment() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

segment() - Method in interface express.mvp.myra.transport.RegisteredBuffer

Returns the underlying memory segment for direct data access.

send(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

send(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.nio.NioBackend

send(RegisteredBuffer, long) - Method in interface express.mvp.myra.transport.TransportBackend

Sends data using a registered buffer (zero-copy).

send(MemorySegment) - Method in class express.mvp.myra.transport.TcpTransport

send(MemorySegment) - Method in interface express.mvp.myra.transport.Transport

Sends data asynchronously.

send(MemorySegment, int, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

send(MemorySegment, int, long) - Method in class express.mvp.myra.transport.nio.NioBackend

send(MemorySegment, int, long) - Method in interface express.mvp.myra.transport.TransportBackend

Sends data using a raw memory segment.

sendZeroCopy(RegisteredBuffer, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Send data using zero-copy mechanism (SEND_ZC).

sendZeroCopy(MemorySegment, int, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Send data using zero-copy mechanism (SEND_ZC).

setCaptureStackTraces(boolean) - Method in class express.mvp.myra.transport.memory.ResourceTracker

Enables or disables stack trace capture.

setConnectionId(String) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Sets the connection identifier.

setEnabled(boolean) - Method in class express.mvp.myra.transport.memory.ResourceTracker

Enables or disables tracking.

setNextDelay(long) - Method in class express.mvp.myra.transport.error.RetryContext

Sets the delay for the next retry.

setSqeFlags(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set flags for the SQE (e.g.

setToken(long) - Method in interface express.mvp.myra.transport.RegisteredBuffer

Sets a user-defined token for tracking this buffer through I/O operations.

shouldRetry(RetryContext) - Method in class express.mvp.myra.transport.error.RetryPolicy

Determines if a retry should be attempted.

shutdown(Duration) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Initiates an orderly shutdown where previously submitted tasks are executed, but no new tasks will be accepted.

shutdown(Duration, Runnable, Runnable) - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Initiates graceful shutdown.

ShutdownCoordinator - Class in express.mvp.myra.transport.lifecycle

Coordinates graceful shutdown of transport resources.

ShutdownCoordinator() - Constructor for class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Creates a new shutdown coordinator in RUNNING state.

Shutdown Flow - Section in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

ShutdownListener - Interface in express.mvp.myra.transport.lifecycle

Callback interface for shutdown lifecycle events.

shutdownNow() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Attempts to stop all actively executing tasks and halts processing of waiting tasks.

shutdownNow(Runnable, Runnable) - Method in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Initiates immediate (non-graceful) shutdown.

ShutdownPhase - Enum Class in express.mvp.myra.transport.lifecycle

Represents the phases of transport shutdown.

Shutdown Phases - Section in package express.mvp.myra.transport.lifecycle

signalRelease() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Signals waiting threads that a buffer may be available.

Sizing Guidelines - Section in class express.mvp.myra.transport.TransportConfig.RegisteredBuffersConfig

Sizing Recommendations - Section in class express.mvp.myra.transport.RegisteredBufferPoolImpl

SO_REUSEADDR - Static variable in class express.mvp.myra.transport.iouring.LibUring

SO_REUSEADDR - Allow reuse of local addresses.

SO_REUSEPORT - Static variable in class express.mvp.myra.transport.iouring.LibUring

SO_REUSEPORT - Allow reuse of local port.

SOCK_NONBLOCK - Static variable in class express.mvp.myra.transport.iouring.LibUring

SOCK_NONBLOCK - Set O_NONBLOCK on the new socket.

SOCK_STREAM - Static variable in class express.mvp.myra.transport.iouring.LibUring

SOCK_STREAM - Sequenced, reliable, connection-based byte streams.

SOL_SOCKET - Static variable in class express.mvp.myra.transport.iouring.LibUring

SOL_SOCKET - Socket level for setsockopt.

sqeGetFlags(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Get SQE flags field.

sqeSetAddr(MemorySegment, long) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE addr field (buffer address).

sqeSetBufIndex(MemorySegment, short) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE buf_index field (for fixed buffers).

sqeSetCqeSkipSuccess(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set CQE_SKIP_SUCCESS flag - don't generate CQE if operation succeeds.

sqeSetFd(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE fd field.

sqeSetFlags(MemorySegment, byte) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE flags field.

sqeSetHardLink(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set the IO_HARDLINK flag on an SQE.

sqeSetLen(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE len field (buffer length).

sqeSetLink(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set the IO_LINK flag on an SQE to link it to the next SQE.

sqeSetOpcode(MemorySegment, byte) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE opcode field.

sqeSetOpFlags(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE op_flags field (operation-specific flags like msg_flags).

sqeSetUserData(MemorySegment, long) - Static method in class express.mvp.myra.transport.iouring.LibUring

Set SQE user_data field (for request tracking).

sqPollCpuAffinity() - Method in class express.mvp.myra.transport.TransportConfig

Returns the CPU affinity for the SQPOLL kernel thread.

sqPollCpuAffinity(int) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the CPU affinity for the SQPOLL kernel thread.

sqPollEnabled() - Method in class express.mvp.myra.transport.TransportConfig

Returns whether SQPOLL mode is enabled.

sqPollEnabled(boolean) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Enables or disables SQPOLL mode.

sqPollIdleTimeout() - Method in class express.mvp.myra.transport.TransportConfig

Returns the SQPOLL idle timeout in milliseconds.

sqPollIdleTimeout(int) - Method in class express.mvp.myra.transport.TransportConfig.Builder

Sets the SQPOLL idle timeout.

SQPOLL Mode - Section in class express.mvp.myra.transport.TransportConfig

start(TransportHandler) - Method in class express.mvp.myra.transport.TcpTransport

start(TransportHandler) - Method in interface express.mvp.myra.transport.Transport

Starts the transport with the specified handler for receiving callbacks.

startAttempt() - Method in class express.mvp.myra.transport.error.RetryContext

Records that an attempt is starting.

State Descriptions - Section in enum class express.mvp.myra.transport.lifecycle.ConnectionState

State Diagram - Section in enum class express.mvp.myra.transport.lifecycle.ConnectionState

State Machine - Section in enum class express.mvp.myra.transport.iouring.ConnectionState

Statistics - Section in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Stats(long, long, long, long, long) - Constructor for record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Creates an instance of a Stats record class.

Structure of Arrays (SoA) Pattern - Section in interface express.mvp.myra.transport.buffer.BufferRef

submit(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Submit queued operations to the kernel.

submit(Runnable) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Submits a task for execution on a virtual thread.

submit(Callable) - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

Submits a callable task for execution on a virtual thread.

submitBatch() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

submitBatch() - Method in class express.mvp.myra.transport.nio.NioBackend

submitBatch() - Method in interface express.mvp.myra.transport.TransportBackend

Submits all queued operations in a batch.

submitBatchRecv(MemorySegment[], int[], long[], int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit a batch of receive operations for maximum throughput.

submitBatchRecvRegistered(short[], int[], long[], int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit a batch of recv operations using registered buffers.

submitBatchSend(MemorySegment[], int[], long[], int) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit a batch of send operations for maximum throughput.

submitLinkedEcho(MemorySegment, int, long, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit a linked recv+send echo pattern.

submitLinkedEchoSkipRecvCqe(MemorySegment, int, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit linked recv+send with skip on success for efficient echo.

submitLinkedRequestResponse(MemorySegment, int, MemorySegment, int, long, long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit linked send+recv for request-response pattern.

submitMultishotRecvWithBufferRing(long) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

Submit a multishot receive with buffer ring selection.

submitted() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the value of the submitted record component.

successfulAcquisitions() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the successfulAcquisitions record component.

successRate() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the success rate as a ratio between 0.0 and 1.0.

successRate() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the success rate as a percentage (0-100).

Supported Backends - Section in interface express.mvp.myra.transport.TransportBackend

supportsBatchSubmission() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

supportsBatchSubmission() - Method in class express.mvp.myra.transport.nio.NioBackend

supportsBatchSubmission() - Method in interface express.mvp.myra.transport.TransportBackend

Returns whether this backend supports batch submission.

supportsRegisteredBuffers() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

supportsRegisteredBuffers() - Method in class express.mvp.myra.transport.nio.NioBackend

supportsRegisteredBuffers() - Method in interface express.mvp.myra.transport.TransportBackend

Returns whether this backend supports registered buffers.

supportsTLS() - Method in class express.mvp.myra.transport.iouring.IoUringBackend

supportsTLS() - Method in class express.mvp.myra.transport.nio.NioBackend

supportsTLS() - Method in interface express.mvp.myra.transport.TransportBackend

Returns whether this backend supports TLS/SSL.

Syscall Reduction - Section in class express.mvp.myra.transport.BackendStats

T

TcpTransport - Class in express.mvp.myra.transport

TCP-based implementation of Transport using a pluggable I/O backend.

TcpTransport(TransportBackend, RegisteredBufferPool, SocketAddress, int) - Constructor for class express.mvp.myra.transport.TcpTransport

Creates a new TCP transport with the specified backend and configuration.

TERMINATED - Enum constant in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Terminal phase - shutdown complete.

Thread Model - Section in class express.mvp.myra.transport.TcpTransport

threads() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns the value of the threads record component.

Thread Safety - Section in class express.mvp.myra.transport.RegisteredBufferPoolImpl

Thread Safety - Section in class express.mvp.myra.transport.TransportFactory

Thread Safety - Section in class express.mvp.myra.transport.TransportHandlerAdapter

Thread Safety - Section in class express.mvp.myra.transport.VirtualThreadFactory

Thread Safety - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

Thread Safety - Section in class express.mvp.myra.transport.buffer.BufferRefImpl

Thread Safety - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

Thread Safety - Section in class express.mvp.myra.transport.error.RetryContext

Thread Safety - Section in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Thread Safety - Section in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Thread Safety - Section in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Thread Safety - Section in class express.mvp.myra.transport.util.NativeThread

Thread Safety - Section in enum class express.mvp.myra.transport.iouring.ConnectionState

Thread Safety - Section in interface express.mvp.myra.transport.ConnectionHandler

Thread Safety - Section in interface express.mvp.myra.transport.RegisteredBuffer

Thread Safety - Section in interface express.mvp.myra.transport.RegisteredBufferPool

Thread Safety - Section in interface express.mvp.myra.transport.Transport

Thread Safety - Section in interface express.mvp.myra.transport.buffer.BufferRef

Thread Safety - Section in interface express.mvp.myra.transport.framing.FramingHandler

Thread Safety - Section in interface express.mvp.myra.transport.lifecycle.ConnectionStateListener

Thread Safety - Section in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Thread Safety - Section in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

TimedBufferPool - Class in express.mvp.myra.transport.buffer

Buffer pool wrapper providing timeout-based acquisition and metrics tracking.

TimedBufferPool(int, int) - Constructor for class express.mvp.myra.transport.buffer.TimedBufferPool

Creates a new timed buffer pool with the specified capacity.

TimedBufferPool(LockFreeBufferPool) - Constructor for class express.mvp.myra.transport.buffer.TimedBufferPool

Creates a new timed buffer pool wrapping an existing pool.

Token-Based Correlation - Section in class express.mvp.myra.transport.TcpTransport

Token-Based Correlation - Section in interface express.mvp.myra.transport.TransportBackend

Token Usage - Section in express.mvp.myra.transport.Transport.connect(SocketAddress)

Token Usage - Section in express.mvp.myra.transport.Transport.connect(SocketAddress)

toString() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns a string representation of this record class.

toString() - Method in class express.mvp.myra.transport.buffer.BufferRefImpl

toString() - Method in enum class express.mvp.myra.transport.error.ErrorCategory

toString() - Method in class express.mvp.myra.transport.error.RetryContext

toString() - Method in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Returns a string representation of this framing handler.

toString() - Method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

toString() - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

toString() - Method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

toString() - Method in class express.mvp.myra.transport.memory.ResourceTracker.AllocationRecord

toString() - Method in class express.mvp.myra.transport.memory.TrackedArena

toString() - Method in class express.mvp.myra.transport.VirtualThreadFactory

toString() - Method in record class express.mvp.myra.transport.VirtualThreadWorkerPool.Stats

Returns a string representation of this record class.

toString() - Method in class express.mvp.myra.transport.VirtualThreadWorkerPool

totalAcquisitions() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the value of the totalAcquisitions record component.

totalBytesReceived(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the total bytes received.

totalBytesReceived(long) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Sets the total bytes received counter.

totalBytesSent(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the total bytes sent.

totalBytesSent(long) - Method in class express.mvp.myra.transport.TransportHealth.Builder

Sets the total bytes sent counter.

totalReceives(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the total receive count.

totalSends(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the total send count.

totalSyscalls(long) - Method in class express.mvp.myra.transport.BackendStats.Builder

Sets the total syscall count.

trackAllocation(String, long) - Method in class express.mvp.myra.transport.memory.ResourceTracker

Tracks a new allocation.

TrackedArena - Class in express.mvp.myra.transport.memory

Arena wrapper that integrates with ResourceTracker and NativeMemoryCleaner.

trackRelease(long) - Method in class express.mvp.myra.transport.memory.ResourceTracker

Tracks release of an allocation.

TRANSIENT - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Transient errors that may succeed on immediate or short-delay retry.

transitionFrom(ConnectionState, ConnectionState) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Attempts to transition from a specific expected state.

transitionFrom(ConnectionState, ConnectionState, Throwable) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Attempts to transition from a specific expected state with a cause.

transitionTo(ConnectionState) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Attempts to transition to a new state.

transitionTo(ConnectionState, Throwable) - Method in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Attempts to transition to a new state with a cause.

Transport - Interface in express.mvp.myra.transport

Core transport abstraction for bidirectional byte streaming.

TransportBackend - Interface in express.mvp.myra.transport

Backend abstraction for pluggable I/O implementations.

TransportConfig - Class in express.mvp.myra.transport

Configuration for transport creation and runtime behavior.

TransportConfig.BackendType - Enum Class in express.mvp.myra.transport

Available I/O backend implementations.

TransportConfig.Builder - Class in express.mvp.myra.transport

Builder for constructing TransportConfig instances.

TransportConfig.RegisteredBuffersConfig - Class in express.mvp.myra.transport

Configuration for the registered buffer pool.

TransportConfig.RegisteredBuffersConfig.Builder - Class in express.mvp.myra.transport

Builder for constructing TransportConfig.RegisteredBuffersConfig instances.

TransportException - Exception Class in express.mvp.myra.transport

Unchecked exception thrown when transport operations fail.

TransportException(String) - Constructor for exception class express.mvp.myra.transport.TransportException

Constructs a new transport exception with the specified message.

TransportException(String, Throwable) - Constructor for exception class express.mvp.myra.transport.TransportException

Constructs a new transport exception with the specified message and cause.

TransportException(Throwable) - Constructor for exception class express.mvp.myra.transport.TransportException

Constructs a new transport exception with the specified cause.

TransportFactory - Class in express.mvp.myra.transport

Factory for creating transport instances and related components.

TransportHandler - Interface in express.mvp.myra.transport

Callback interface for handling transport lifecycle and I/O events.

TransportHandlerAdapter - Class in express.mvp.myra.transport

Abstract adapter class for TransportHandler with empty default implementations.

TransportHandlerAdapter() - Constructor for class express.mvp.myra.transport.TransportHandlerAdapter

TransportHealth - Class in express.mvp.myra.transport

Health status and metrics for a transport instance.

TransportHealth.Builder - Class in express.mvp.myra.transport

Builder for constructing TransportHealth instances.

tryAcquire() - Method in class express.mvp.myra.transport.buffer.TimedBufferPool

Attempts to acquire a buffer without blocking.

tryAcquire() - Method in interface express.mvp.myra.transport.RegisteredBufferPool

Attempts to acquire a buffer without blocking.

tryAcquire() - Method in class express.mvp.myra.transport.RegisteredBufferPoolImpl

U

UNKNOWN - Enum constant in enum class express.mvp.myra.transport.error.ErrorCategory

Unknown or unclassified errors.

unregisterBufferRing(MemorySegment, int) - Static method in class express.mvp.myra.transport.iouring.LibUring

Unregister a buffer ring.

unregisterBuffers(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Unregister previously registered buffers.

unregisterFiles(MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Usage Example - Section in class express.mvp.myra.transport.BackendStats

Usage Example - Section in class express.mvp.myra.transport.TransportConfig

Usage Example - Section in class express.mvp.myra.transport.TransportFactory

Usage Example - Section in class express.mvp.myra.transport.TransportHandlerAdapter

Usage Example - Section in class express.mvp.myra.transport.TransportHealth

Usage Example - Section in class express.mvp.myra.transport.VirtualThreadFactory

Usage Example - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

Usage Example - Section in class express.mvp.myra.transport.buffer.LockFreeBufferPool

Usage Example - Section in class express.mvp.myra.transport.buffer.TimedBufferPool

Usage Example - Section in class express.mvp.myra.transport.error.ErrorClassifier

Usage Example - Section in class express.mvp.myra.transport.error.RetryContext

Usage Example - Section in class express.mvp.myra.transport.error.RetryPolicy

Usage Example - Section in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

Usage Example - Section in class express.mvp.myra.transport.iouring.ErrnoHandler

Usage Example - Section in class express.mvp.myra.transport.iouring.IoUringBackend

Usage Example - Section in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

Usage Example - Section in class express.mvp.myra.transport.lifecycle.ShutdownCoordinator

Usage Example - Section in class express.mvp.myra.transport.memory.NativeMemoryCleaner

Usage Example - Section in class express.mvp.myra.transport.memory.ResourceTracker

Usage Example - Section in class express.mvp.myra.transport.memory.TrackedArena

Usage Example - Section in class express.mvp.myra.transport.util.NativeThread

Usage Example - Section in enum class express.mvp.myra.transport.error.ErrorCategory

Usage Example - Section in interface express.mvp.myra.transport.CompletionHandler

Usage Example - Section in interface express.mvp.myra.transport.ConnectionPool

Usage Example - Section in interface express.mvp.myra.transport.RegisteredBuffer

Usage Example - Section in interface express.mvp.myra.transport.Transport

Usage Example - Section in interface express.mvp.myra.transport.TransportHandler

Usage Example - Section in interface express.mvp.myra.transport.framing.FramingHandler

Usage Example - Section in interface express.mvp.myra.transport.lifecycle.ConnectionStateListener

Usage Example - Section in interface express.mvp.myra.transport.lifecycle.ShutdownListener

Usage Example - Section in package express.mvp.myra.transport.framing

Usage Example - Section in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Usage Pattern - Section in interface express.mvp.myra.transport.RegisteredBufferPool

Usage Pattern - Section in interface express.mvp.myra.transport.buffer.BufferRef

Usage with Connection Pool - Section in interface express.mvp.myra.transport.ConnectionHandler

Use Cases - Section in class express.mvp.myra.transport.VirtualThreadFactory

utilization() - Method in record class express.mvp.myra.transport.buffer.BufferPoolMetrics

Returns the pool utilization as a ratio between 0.0 and 1.0.

V

Valid Transitions - Section in class express.mvp.myra.transport.lifecycle.ConnectionStateMachine

valueOf(String) - Static method in enum class express.mvp.myra.transport.error.ErrorCategory

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class express.mvp.myra.transport.iouring.ConnectionState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class express.mvp.myra.transport.TransportConfig.BackendType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class express.mvp.myra.transport.error.ErrorCategory

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class express.mvp.myra.transport.iouring.ConnectionState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class express.mvp.myra.transport.lifecycle.ConnectionState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class express.mvp.myra.transport.lifecycle.ShutdownPhase

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class express.mvp.myra.transport.nio.NioBackend.ConnectionState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class express.mvp.myra.transport.TransportConfig.BackendType

Returns an array containing the constants of this enum class, in the order they are declared.

VirtualThreadFactory - Class in express.mvp.myra.transport

Thread factory that creates virtual threads with configurable naming and properties.

VirtualThreadFactory(String) - Constructor for class express.mvp.myra.transport.VirtualThreadFactory

Creates a virtual thread factory with the given name prefix.

VirtualThreadFactory(String, boolean) - Constructor for class express.mvp.myra.transport.VirtualThreadFactory

Creates a virtual thread factory with configurable daemon status.

Virtual Threads vs Platform Threads - Section in class express.mvp.myra.transport.VirtualThreadFactory

VirtualThreadWorkerPool - Class in express.mvp.myra.transport

High-performance worker pool using Java 21+ virtual threads for I/O event processing.

VirtualThreadWorkerPool.Builder - Class in express.mvp.myra.transport

Builder for creating VirtualThreadWorkerPool instances.

VirtualThreadWorkerPool.Stats - Record Class in express.mvp.myra.transport

Immutable snapshot of worker pool statistics.

W

waitCqe(MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Wait for a completion queue entry.

waitCqeTimeout(MemorySegment, MemorySegment, MemorySegment) - Static method in class express.mvp.myra.transport.iouring.LibUring

Wait for a completion (with timeout).

waitForCompletion(long, CompletionHandler) - Method in class express.mvp.myra.transport.iouring.IoUringBackend

waitForCompletion(long, CompletionHandler) - Method in class express.mvp.myra.transport.nio.NioBackend

waitForCompletion(long, CompletionHandler) - Method in interface express.mvp.myra.transport.TransportBackend

Waits for at least one operation to complete.

When to Use NIO - Section in class express.mvp.myra.transport.nio.NioBackend

When to Use Virtual Threads - Section in class express.mvp.myra.transport.VirtualThreadWorkerPool

wrap(Arena, String) - Static method in class express.mvp.myra.transport.memory.TrackedArena

Wraps an existing arena with tracking.

X

XDP - Enum constant in enum class express.mvp.myra.transport.TransportConfig.BackendType

Linux XDP backend (future, experimental).

Z

Zero-Copy Design - Section in interface express.mvp.myra.transport.framing.FramingHandler

Zero-Copy I/O - Section in interface express.mvp.myra.transport.Transport

Zero-Copy Operation - Section in class express.mvp.myra.transport.framing.LengthPrefixedFramingHandler

A B C D E F G H I J K L M N O P Q R S T U V W X Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form