All Classes and Interfaces
Class
Description
Abstract base implementation of
CommunicationMessage for external protocol codecs.Base implementation for grouping simulated client input commands by command region.
Post-action processor responsible for handling the action method result,
typically encoding and sending the response.
ActionCommand command object, also known as action.
Action command document, stores source code information.
Utility for scanning Java source files and building a map of
JavaClassDocInfo
from the Javadoc comments found in @ActionController classes.Parse
@ActionController annotated classes and build the corresponding
ActionCommandRegions routing table.A command region holding all
ActionCommand entries for a single cmd value, keyed by subCmd.Global duplicate route detection tool
Registry of all
ActionCommandRegion instances, indexed by cmd.Marks a class as an action controller that handles requests for a specific command module.
Documentation model for a single
@ActionController, grouping all
ActionCommandDoc entries that share the same primary command ID.Aggregated documentation model for a single
ActionDoc, containing the
generated member-constant documents and method-level documents used for
client SDK code generation.Built-in error codes used by the framework's action processing pipeline.
Factory interface for creating or retrieving action controller instances.
Spring-backed
ActionFactoryBean implementation that resolves action controllers from the
ApplicationContext and enables the framework's component-based injection integration.Document model for a route member constant generated from an action method,
carrying the command pair, a generated member name, and the Javadoc comment.
Marks a method within an
ActionController as a request handler for a specific sub-command.Documentation model for a single action method, capturing parameter types, return types,
comments, and type-mapping information used for client SDK code generation.
Exception handling for ActionMethod
Interceptor interface for pre/post processing of action method invocations.
Strategy interface for invoking action methods via
MethodHandle.Metadata about an action method parameter, including generic type resolution
and JSR-380 validation group configuration.
Metadata about an action method's return type, including generic type resolution
for
List return types.Enum describing the parameter layout of an action method.
Mutable context passed to
ActionParserListener callbacks during action parsing.Listener (hook) during action construction
ActionParserListeners
Common interface for types that expose the actual (possibly generic) class of an
action method parameter or return value.
Shared Aeron channel names, stream ids, and default ports used by net-common.
Array manipulation utilities.
Handles template requests that update a user's session attachment.
Type-safe attribute key for use with
AttrOptionDynamic.Interface for objects that support dynamic, type-safe attributes.
Thread-safe attribute storage container.
Aggregates load-balancing strategies for logic servers and external servers.
Message field copying utilities for transferring common fields between request and response messages.
Central execution engine of the ionet business framework.
Builder for constructing a
BarSkeleton instance.SPI extension point for enhancing a
BarSkeletonBuilder before the skeleton is built.Registry and executor for
BarSkeletonBuilderEnhance extensions.Global registry that maps logic-server IDs to their
BarSkeleton instances.Configuration settings for the business framework skeleton (
BarSkeleton).Enumeration of dynamic binding operations for logic server assignment.
Message that requests a dynamic binding change between users and logic servers.
Fluent builder for constructing
BindingLogicServerMessage instances.BindingLogicServerMessage
BindingLogicServerMessage
bool - Property has listening feature.
Protocol wrapper for a single boolean value.
Protocol wrapper for a list of boolean values.
Aggregate broadcast communication interface combining multicast, unicast, and user-list broadcast capabilities.
Documentation model for a single broadcast (server-push) route, describing the
command info, data type, method name, and associated metadata used for client
SDK code generation.
Builder for constructing
BroadcastDocument instances that describe
server-push routes, their data types, and method metadata.Sealed base class for all broadcast message types sent from logic servers to external servers.
Decorator providing multicast broadcast methods to send messages to all connected users.
Broadcast message targeting all connected users (multicast / global broadcast).
BroadcastMulticastMessage
BroadcastMulticastMessage
Aeron fragment consumer that broadcasts a decoded message to all connected users.
SBE encoder for multicast broadcast messages emitted by logic servers.
Trace BroadcastMessage
Decorator providing unicast broadcast methods to send messages to a specific user by ID.
Decorator providing broadcast methods to send messages to a list of users by their IDs.
Broadcast message targeting an explicit list of users.
BroadcastUserListMessage
BroadcastUserListMessage
Aeron fragment consumer that broadcasts a decoded message to a specified user list.
SBE encoder for user-list broadcast messages.
Broadcast message targeting a single user (unicast).
BroadcastUserMessage
BroadcastUserMessage
Aeron fragment consumer that routes a decoded message to one target user session.
SBE encoder for user-targeted broadcast messages.
Locale-aware resource bundle accessor for framework i18n messages.
Byte array conversion utilities for primitive types using big-endian byte order.
Protocol wrapper for a list of byte array values.
Connection metadata for a net-server registered with the center server.
Center-server connection manager for registered net-server publications and polling.
Factory for creating center-server connection managers.
Parameters required to create a center-server connection manager.
Registers center-server SBE encoders and fragment handlers into shared registries.
Center-server runtime entry point.
Builder for assembling center-server runtime dependencies.
Factory for creating center-server runtime instances.
Immutable runtime settings for the center server.
Contract for components that require injected
CenterServerSetting.Transport callback used to send a communication message through the active client channel.
Classpath scanner that discovers classes matching a predicate filter.
Factory helpers for client communication and idle messages.
Convenience bootstrap for starting a single simulated client instance.
Client communication channel facade for sending requests and receiving server responses.
Configuration flags for simulated client behavior and logging.
Simulated command manager.
CmdCacheHandler, externalServer data cache
External server cache configuration.
Check for route existence.
Constants for command code types used in the external protocol layer.
Command routing information composed of a cmd (module) and subCmd (action) pair.
Factory that produces cached
CmdInfo instances using the flyweight pattern.Strategy options for the
CmdInfo flyweight cache used by CmdInfoFlyweightFactory.Command ID manipulation utilities.
Command-region routing bucket that tracks logic-server ids for one command merge.
Registry of command-region routing buckets used for logic-server dispatch.
Keeps command-region routing tables in sync with server online/offline events.
Strategy interface for inspecting action commands and emitting code-improvement suggestions.
Collection manipulation utilities.
Callback result wrapper with lazy response payload decoding helpers.
Manages Aeron publications and fragment polling for common network connections.
Common shared constants.
Base decorator interface providing access to the communication aggregation, trace ID, and current executor.
Event subscription sends
CommonEvent to RingBufferPublishes domain events into the configured disruptor pipeline.
Common illegal argument exception used throughout the ionet framework.
Base class for internal messages exchanged between logic servers via Aeron.
Common null pointer exception used throughout the ionet framework.
Common response contract providing error code and message accessors.
Common runtime exception used throughout the ionet framework.
Aggregate communication interface combining broadcast, logic call, external, and send capabilities.
Framework network communication aggregation interface.
Factory for creating the
CommunicationAggregation used by net-server.Shared fallback responses and error constants for communication aggregation flows.
Utility class providing static access to the global communication infrastructure.
Contract for external communication messages exchanged between clients and the external server.
Strategy for creating and serializing external communication messages.
Static facade for the configured
CommunicationMessageCodec.SBE encoder for outbound
CommunicationMessage instances sent to the net server.Enum representing the type of communication for a request flow.
CompletableFuture Kit.
see CompletableFuture
Manage all client connections
Net-server connection manager for peer publications and inbound fragment polling.
Factory for creating net-server connection managers.
Parameters required to construct a net-server
ConnectionManager.ConnectRequestMessage ServerMessage
map payload
ConnectRequestMessage ServerMessage
map payload
Handles center-side connect-request fragments and synchronizes peer server discovery.
SBE encoder for
ServerRequestMessage registration messages.Response message sent when a server successfully connects (joins) the cluster.
ConnectResponseMessage ServerMessage
map payload
ConnectResponseMessage ServerMessage
map payload
Handles center connect-response fragments and registers newly discovered server connections.
SBE encoder for center-server connect-response messages.
Convenience wrapper that resolves a target server and publishes request messages.
SPI interface for loading framework configuration at startup.
Global configuration constants for the ionet core framework.
Generate C# code, such as broadcast, error code, action
A
ThreadFactory that creates daemon threads with auto-incrementing names.Strategy interface for encoding and decoding business data.
Central manager for the active
DataCodec instances.Debug plugin that logs detailed request/response information for each action method invocation.
Development listener that logs net-server peer lifecycle events.
Default in-memory access control implementation for external route checks.
Default
ActionAfter implementation that encodes
the action method result into the response message.Default exception processor that wraps exceptions into
MessageException.Default action method invoker using
MethodHandle for high-performance
method dispatch.Default holder for logic and external load-balancing implementations.
Default client-side user model.
Default
CmdRegion implementation backed by a compact int array.Default command-region registry that maps command merges to candidate logic servers.
Default
CodeSuggest implementation that recommends replacing wrapper types
(e.g.Default implementation of
Communication that delegates to the global CommunicationAggregation.Default communication aggregation implementation for routing, broadcasting, and RPC-like calls.
Default codec implementation that creates
ExternalMessage instances.Default Aeron-based
ConnectionManager implementation for net-server peers.Default
ExternalServer implementation backed by a Netty MicroBootstrap.Default implementation of
FlowContext with Lombok-generated getters and setters.Default implementation of
FutureManager backed by a concurrent map.PipelineContext is mainly used to wrap the SocketChannel channel, aiming to enhance the Handler aware capability
Default single-threaded
Publisher implementation backed by per-publication queues.Default
SbeCodec that maps framework message fields to SBE generated codecs.Default
SkeletonThreadPipeline that dispatches a FlowContext to the
appropriate thread executor based on the request's hop count.TCP/WebSocket heartbeat hook
Optional Aeron image availability callback that currently keeps logging disabled.
Default logging implementation of
UserHook.Lightweight controllable delayed task utility class
Lightweight controllable delayed task region interface, responsible for operations such as creation, retrieval, cancellation, and counting of lightweight controllable delayed tasks.
Singleton bridge for third-party dependency injection frameworks (e.g.
Development and performance monitoring utilities for measuring IPC latency and request
processing times.
No-op
RangeBroadcast implementation used to disable range broadcasting.Interface for building Disruptor
Responsible for managing the Disruptor
Document-related information, such as action-related, broadcast-related, and error code-related details.
Document access permission generation
Utility for analysing action documents, error code enums, and Java source files
to produce structured documentation models.
Interface for connecting to the document generation service, allowing for different implementations to be extended.
Central helper for collecting action documentation, broadcast documents, error codes,
and triggering document generation.
Generates the document action method name.
Boots and manages the lifecycle of domain-event disruptor pipelines.
Interface for domain event consumption, receives a domain event
Static facade for publishing domain events through the configured producer.
Configuration holder for domain-event disruptor creation and handler registration.
Domain event interface - source event source
Strategy interface for selecting the next element from a candidate set.
Lightweight external response that carries only error information and no payload.
EmptyExternalResponseMessage
EmptyExternalResponseMessage
Handles empty external-response messages and completes pending futures.
SBE encoder for
EmptyExternalResponseMessage.Marker annotation indicating that the annotated element requires the Enterprise Edition.
Exception thrown when attempting to use a feature that requires the Enterprise Edition.
Business interface for domain events (Event Object)
Documentation model for a single error code entry, carrying the enum constant name,
numeric value, and human-readable description.
Contract for error information that can be used to throw
MessageExceptions
with assertion-style convenience methods.EventBus, the relationship between EventBus, the business framework, and the logic server is 1:1:1.
The type triggered when an event is published
Event listener, triggered conditions: 1. when a subscriber throws an uncaught exception, 2. when an event message has no corresponding subscriber.
Event message carrying the event source data, topic, routing info, and fire type flags
for the EventBus system.
Communication interface for dispatching
EventBusMessage events to remote logic servers.Factory interface for creating
EventBusMessage instances from event source objects.EventBusMessage
EventBusMessage
Handles cross-server event-bus fragments and dispatches them to local event buses.
SBE encoder for cross-server event-bus messages.
Event Bus Management Domain
Configuration interface for the EventBus subsystem, providing factory methods
for creating EventBus instances and accessing the EventBus region.
Utility class providing static access to the global
EventBusSetting and EventBusRegion.Lifecycle status of an EventBus instance.
Marker annotation for event subscriber classes.
Holds event topic information and server metadata for a logic server participating in the EventBus system.
Subscriber annotation, marks a method as an event subscriber (receives events, processes events),
configurable with thread executor strategy and execution priority.
Thread executor factory utilities.
Executor region, managing implementations of
ThreadExecutorRegion (Thread Executor Region).The ExecutorRegion utility class functions like a proxy.
Subscriber thread executor selection strategy.
Handles template requests that check whether a user session exists.
Interfaces for external server cache data query and addition.
External server cache configuration interface.
Communication interface for collecting aggregated responses from multiple external (client-facing) servers.
Interface for communicating with external (client-facing) servers.
Decorator interface providing convenience methods for communicating with external (client-facing) servers.
Registers external-core SBE decoders and Aeron fragment handlers.
Global defaults shared by external server implementations.
External client transport types supported by the gateway.
Transport-type strategy used to apply connection-specific bootstrap defaults.
Registry of
ExternalJoinSelector implementations keyed by transport type.Registry of external server settings and their user session containers.
Convenience factory for creating Netty-based external server builders.
Default external transport message used between clients and the external server.
Request message sent from an external (Netty) server to a logic server.
ExternalRequestMessage
ExternalRequestMessage
Aeron fragment consumer that dispatches internal external-operation requests by template id.
SBE encoder for external request messages.
Response returned from an external (Netty) server.
Concrete response message returned from an external (Netty) server to a logic server.
ExternalResponseMessage
ExternalResponseMessage
Handles external-response fragments and completes the corresponding future.
SBE encoder for
ExternalResponseMessage returned to internal request senders.External-facing transport server (WebSocket/TCP/UDP/custom) bootstrap contract.
Builder for assembling an external server and its runtime dependencies.
Mutable state used while building an external server.
Factory for creating transport-specific external server instances.
Parameter bundle passed to
ExternalServerCreator.Load-balancing view for external servers.
Shared holder for the active external server user session container.
Immutable runtime settings for one external server instance.
Callback contract for components that need the resolved
ExternalSetting.Writes outbound messages to a user session resolved from
UserSessions.Mutable context passed to the configurable proto field-name generator function.
File I/O utilities.
Resolves the target logic server for a request.
Factory for creating request-routing
FindServer instances.A
ThreadFactory that creates daemon threads with a fixed (non-incrementing) name.Flow-level attachment communication for reading and writing request-scoped attachment data.
Flow-level communication for binding or unbinding a user session to specific logic servers.
Flow-level broadcast communication providing methods to broadcast messages to the requesting
user (broadcastMe) with various data type overloads.
Base interface for flow communication, providing access to the server, request, executor,
and communication infrastructure.
FlowCommunicationEventBus
The FlowContext's lifecycle is limited to the duration of a single request flow.
FlowContextFactory, used to create FlowContext
Holder for the
ScopedValue key used to propagate FlowContext
through the execution thread.Command flow executor
Flow execution pipeline utility.
Flow-level communication for sending requests to external servers.
Flow-level communication for writing response data back to the external client, supporting
various data types and list encodings.
Flow-level cross-logic-server collect call communication for broadcasting requests
to all logic servers.
Flow-level cross-logic-server call communication.
Flow-level fire-and-forget message sending to other logic servers.
Handles template requests that forcibly disconnect a user session.
Manage the lifecycle of
CompletableFuture instances used for asynchronous request-response
communication between servers.Message that carries a future correlation id for asynchronous request/response matching.
Convenience utilities for generating `.proto` files from annotated Java classes.
Selects Netty event-loop/channel implementations based on the current operating system.
Provides OS-specific Netty event-loop groups and server channel class selection.
Repeating group dimensions.
Repeating group dimensions.
Closes non-WebSocket HTTP requests after the WebSocket upgrade path handlers are installed.
HttpRealIpHandler
Marker interface for transport-specific idle handlers.
Heartbeat/idle event callback hook for external user sessions.
Immutable heartbeat/idle processing configuration for an external server.
Builder for
IdleProcessSetting heartbeat/idle configuration.Simulated client input command configuration.
example:
Helper for creating simulated input commands within a module command region.
命令域
int - Property has listening feature.
Scheduled task listener, using HashedWheelTimer to simulate ScheduledExecutorService scheduling.
Protocol wrapper for a single int value.
Protocol wrapper for a list of int values.
Startup banner renderer for the ionet framework.
Log topic name constants used with
@Slf4j(topic = ...).Provides the current version string of the ionet framework.
Aeron IPC latency monitor using bucket-based histogram for percentile calculations.
Wrapper around a QDox
JavaClass that indexes its methods by signature
and provides factory methods for creating ActionCommandDoc from reflection
Method objects.广播监听
A thread-safe multimap that associates each key with a
List of values, allowing duplicates.Locale detection utilities.
Decorator providing cross-logic-server collect-style calls that aggregate responses from multiple logic servers.
Decorator providing cross-logic-server synchronous and asynchronous call methods with various data type overloads.
Communication interface for collecting aggregated responses from multiple logic servers.
Interface for inter-logic-server communication.
Decorator interface that provides convenience factory methods for creating
RequestMessage
instances with various data types.Decorator providing fire-and-forget message sending to other logic servers.
Bootstraps a
LogicServer into a Server definition for net-server startup.Registers logic-server SBE encoders and fragment handlers into shared registries.
LogicServer LoadBalanced
Temporary registry for logic-server callbacks that are completed after server registration.
long - Property has listening feature.
Protocol wrapper for a single long value.
Protocol wrapper for a list of long values.
Exception carrying an error code and message, thrown during action method processing
to signal business errors to the client.
Message identifiers and length of message root
Message identifiers and length of message root
i18n message key, see iohao.properties
Encodes a specific message type into an SBE buffer.
Meta attribute enum for selecting a particular meta attribute value.
Action method parsing: parses method parameters, parses method return value
Registry of
MethodParser implementations, mapping parameter types to their parsers.Bootstrap contract for starting the external transport server.
The startup process for a server that connects with real players.
Interface for a lightweight room entity identified by a long ID.
Thread-safe room registry that manages
MicroRoom instances by ID.General-purpose utility methods.
Global configuration entry for net-common components.
Net-server runtime entry point used to register servers and start the agent loop.
Builder for assembling
NetServer runtime dependencies and defaults.Registers net-server specific SBE encoders and fragment handlers into shared registries.
Factory for creating
NetServer runtime instances from a built setting.Immutable runtime setting assembled by
NetServerBuilder.Contract for components that require injected
NetServerSetting.Hook invoked after
NetServerBuilder finishes creating NetServerSetting.Network utilities for local IP address detection.
object - Property has listening feature.
Timer listener callback, executed only 1 time.
Handler for template-based internal external operations.
Execution context for an
OnExternal template handler.Registry of
OnExternal handlers indexed by template id sign and value.Reserved template id constants used by the external server for internal operations.
Handles a decoded Aeron fragment for a specific SBE template id.
Registry for
OnFragment handlers keyed by SBE template id.Interface for types that carry a unique operation code identifier.
Room gameplay operation execution context and domain-event payload.
Domain-event handler that executes room operation contexts and reports user-facing exceptions.
Gameplay Operation Factory
Gameplay operation business interface, separating validation from operation.
Gameplay operation related service.
Operating system detection utilities.
Strategy interface for validating action method parameters,
typically backed by Jakarta Bean Validation.
Transport-agnostic adapter for adding/removing handlers in a connection pipeline.
Player abstraction used by the room extension.
Context - Interface for Player Gameplay Operation Context
Null-presence conditional execution utilities.
Pressure-test helper utilities for coordinating multiple client users.
Listener interface for property value change events.
Observable property value that notifies registered listeners on value changes.
Protobuf-based implementation of
DataCodec.Type mapping table from Java field types to proto scalar types.
Declares the target proto file and package used when grouping generated definitions.
Provides proto file name/package metadata for grouped generated output.
Generates grouped `.proto` files by scanning annotated Java classes.
Global settings for proto file generation behavior and field-name formatting.
Parsed Java class metadata used to render a proto message/enum block.
Analyzes annotated Java classes and converts them into proto generation metadata.
Parsed Java field metadata used to render a proto field line.
Group of proto message/enum definitions that will be emitted into one `.proto` file.
Composite key for grouping proto definitions by file name and package.
JProtobuf serialization utilities for encoding and decoding objects.
Queues and publishes encoded messages to Aeron publications.
Interface for publishing messages to other servers in the cluster.
Marker interface for publisher worker runnables.
Random number generation utilities.
Broadcast message delivery scoped to a specific set of users.
Contract for messages transmitted between servers in the ionet cluster.
Represent an inbound request message carrying routing, identity, and attachment metadata.
Executable client request command sent to the server.
Internal request message used for logic-to-logic server communication via Aeron.
InternalRequestMessage
InternalRequestMessage
Internal RequestMessageOnFragment
Base SBE encoder for internal request messages.
Represent an outbound response message with typed data extraction capabilities.
Aggregated response collected from multiple logic servers.
Aggregated response collected from multiple external (Netty) servers.
Default implementation of
ResponseCollectExternal that stores
aggregated responses collected from multiple external (Netty) servers.Default implementation of
ResponseCollect that stores aggregated
responses from multiple logic servers.Internal response message used for logic-to-logic server communication via Aeron.
InternalResponseMessage
InternalResponseMessage
Internal ResponseMessageOnFragment
SBE encoder for internal response messages.
Round-robin selector backed by an array snapshot.
Core room abstraction for player lifecycle, seating, and room-level game operations.
Room related utilities
Extension interface for room management related operations
Runner mechanism, which triggers once before and once after the network connection is established on the logic server.
Manages the lifecycle of
Runner instances registered with a BarSkeleton.Coordinates startup for a combined deployment that can host the external server, multiple logic
servers, and an optional center server in one process.
Runtime environment utilities.
Null-safe value retrieval utilities.
Abstraction for encoding and decoding framework message models with SBE generated codecs.
Static facade for the active
SbeCodec implementation.Registry for message-class to
MessageSbe encoder mappings.Console input helper utilities for simulated clients.
Fire-and-forget request message for one-way logic-to-logic server communication.
InternalSendMessage
InternalSendMessage
Internal SendMessageOnFragment
Base SBE encoder for internal send messages.
Immutable record representing a registered server instance in the ionet cluster.
Builder for constructing
Server instances with sensible defaults.Shared online/offline processing helpers for peer state transitions.
Listener for net-server peer lifecycle events (before connect, online, offline).
Base contract for registering and removing servers from a load-balancer.
Global registry for server metadata known to the current net-server process.
Sealed base class for server registration and connection messages exchanged with the center server.
Encodes and decodes
ServerMessage common fields with SBE generated codecs.Notification record indicating that a server has gone offline.
ServerOfflineMessage
ServerOfflineMessage
Handles server-offline notifications and triggers peer offline cleanup.
SBE encoder for server-offline notifications.
Shutdown hook that broadcasts local server-offline messages to remote net-server groups.
Group of logic servers that share the same routing region/tag.
Request message sent from one server to another within the cluster.
Hook executed during net-server JVM shutdown.
Enumeration of server types within the ionet cluster.
A thread-safe multimap that associates each key with a
Set of values, ensuring uniqueness.Handles template requests that bind a business userId to a user channel.
Result of a user id binding (setting) operation on the external server.
Simple log printing, typically for inactive or exception-triggered connections.
Executes the task
Runnable.Basic mutable
Player implementation for room-based games.Default in-memory
Room implementation.Strategy for dispatching a
FlowContext to a thread executor within a BarSkeleton.Netty handler that enforces external route access control and login requirements.
Filters out heartbeat messages when no idle handler is configured.
Netty idle handler that processes heartbeat frames and idle timeout events.
TCP/WebSocket heartbeat hook
Server for connecting with real players, handling netty servers for tcp and websocket.
Netty channel-backed implementation of an external user session.
Creates and removes
SocketUserSession instances on Netty channel lifecycle events.Netty session manager for TCP and WebSocket external transports.
PluginInOut - StatActionInOut - Action Call Statistics Plugin
PluginInOut - StatActionInOut - Action Call Statistics Plugin - StatAction Update Listener
PluginInOut - StatActionInOut - Action Call Statistics Plugin - Time Range Record
String with a max length of 255 bytes
String with a max length of 255 bytes
String - Property has listening feature.
Protocol wrapper for a single String value.
Protocol wrapper for a list of String values.
String manipulation utilities.
Strategy interface for selecting the thread executor used to run a subscriber method.
Represents a single event subscriber method bound to an
EventBusSubscriber instance.Strategy interface for invoking a subscriber method when an event is dispatched.
Factory interface for creating
SubscriberInvoke instances from Subscriber metadata.Collects contextual information about an
ActionCommand and formats
code-improvement suggestions for display on the console.Internal utility class for task consumption; developers should NOT use it for time-consuming I/O tasks.
Task listener callback, used in scenarios such as: one-time delayed tasks, scheduled tasks, lightweight controllable delayed tasks, lightweight periodic persistence helper functions, and other extended scenarios.
Netty codec that converts length-prefixed TCP frames to/from
CommunicationMessage.Transport selector that configures TCP defaults for Netty external servers.
Netty bootstrap flow for TCP-based external client connections.
One-time guard that validates the first TCP length-prefixed frame header before normal decoding.
DocumentGenerate implementation that produces a plain-text documentation file
containing action routes, broadcast routes, and error codes.Base class for creating threads with configurable name prefix, priority, daemon flag, and thread group.
Thread executor information
Interface for a region of thread executors that distributes tasks by index.
PluginInOut - ThreadMonitorInOut - Business Thread Monitoring Plugin
Per-thread monitoring record holding execution count, total time, and remaining queue size.
Region that manages
ThreadMonitorInOut.ThreadMonitor instances, one per business thread.Exception throwing utilities for internal use.
Date/time formatting utilities with cached
DateTimeFormatter instances.Time utilities providing cached or real-time date/time access.
PluginInOut - TimeRangeInOut - Call Statistics Plugin for Each Time Period
Listener interface for
TimeRangeInOut change notifications and customization.Daily call statistics record holding the date, total count, and per-hour breakdowns.
Hourly call statistics record holding the hour, total count, and per-minute breakdowns.
Minute-range statistics record within an hour.
Domain message topic
Strategy interface for generating trace IDs.
Distributed tracing utilities using SLF4J MDC for trace ID propagation.
Strategy interface for mapping Java/protobuf types to their client-side type names
used during document and SDK code generation.
Record describing how a Java/protobuf type maps to client-side type names,
SDK method names, and result accessor names used during code generation.
Generate TypeScript code, such as broadcast, error code, action
User session lifecycle callbacks for online/offline events.
Contract for messages that carry user identity and authentication state.
Hook for enriching inbound user requests before business routing.
Forwards validated user requests to the selected logic server.
User-facing request message received from the external Netty pipeline.
UserRequestMessage
UserRequestMessage
Handles user request fragments and dispatches them to the logic execution pipeline.
User-facing response message sent back through the external Netty pipeline to the client.
UserResponseMessage
UserResponseMessage
Aeron fragment consumer that sends user response messages back to external clients.
SBE encoder for user response messages.
External user session abstraction for one connected client.
Dynamic attribute names for UserSession
UserSession manager
Lifecycle state of an external user session.
Specifies validation groups for Jakarta Bean Validation on action method parameters.
Jakarta Bean Validation utilities for validating action method parameters.
Record that pairs a single-value wrapper class with its corresponding list wrapper class.
Netty codec that converts between
BinaryWebSocketFrame and CommunicationMessage.Transport selector that configures WebSocket defaults for Netty external servers.
Netty bootstrap flow for WebSocket-based external client connections.
Optional WebSocket handshake verification handler executed before protocol upgrade completion.
Exposes selection logic that can use a network id as routing input.
Utility class for protocol wrapper type resolution.