All Classes and Interfaces

Class	Description
ARN	Acyclic Deterministic Reactor Network validator.
Bounds
CDSSUtils
ConfigLoader	The ConfigLoader class provides utility methods for loading and validating JSON-based configuration files used by the orchestrator.
DataConstants
DataPoint<T>	An immutable, timestamped value sample produced by a device channel.
DataPointParser	Utility for converting a JSON bus message into a DataPoint.
DataUtils
DeploymentValidator	Extension point invoked once after all services have been instantiated, allowing domain modules to validate the deployed topology (e.g. checking that a network of services satisfies structural constraints) without the orchestrator depending on any domain type.
DislocationClassificationReactor
Dispatcher	Drop-in replacement: - Never blocks EventBus handler on IO
DispatchMode	Strategy for how an event bus invokes the handlers registered for an address.
EventBus	Defines a simple event bus mechanism for message-based communication between components and/or services.
Factory	The Factory class provides dynamic instantiation of Service implementations based on JSON configuration.
FfillDispatcher
FiringRule	Structured representation of a parsed channel condition.
HemodynamicRhythmClassificationReactor
InfluxDispatcher
InterpretationReactor
InterpreterUtils
JsonlDispatcher
LimitClassificationReactor	A specialized Reactor that classifies numeric input values per channel based on a configured, ascending-sorted list of upper bounds.
LocalEventBus	A local implementation of the EventBus interface for message-based communication between components within the same JVM.
Main	Config-driven launcher for a FRAMED deployment.
Manager	The Manager class is responsible for orchestrating the lifecycle of Service instances based on a JSON configuration.
MedibusFramer
MedibusParsedWriter
MedibusProtocol
MedibusRealTimeParser
MedibusSlowParser
MedibusState
NamedThreadFactory	A ThreadFactory that produces daemon threads named <base>-<n>, where n is an incrementing counter.
NioTcpTransport	A Transport implementation using Java NIO for TCP-based communication.
NioUdpTransport	A Transport implementation using Java NIO over UDP for lightweight, connectionless message delivery between services or devices.
Parser<T>	Abstract base for services that turn raw input into events published on the event bus.
ParsingUtils
Peer	Represents a network peer identified by a host (name or IP address) and a port.
Protocol	Represents an abstract communication protocol that extends the Service class.
PythonParser
RawByteWriter
Reactor	A reactive multi-input Service that evaluates a set of firing rules on incoming messages, constructs exactly one consistent snapshot per evaluation cycle, and triggers a user-defined Reactor.reactionFunction(Map) once whenever at least one rule is satisfied.
Reactor.Snapshot	An immutable evaluation snapshot handed to Reactor.reactionFunction(Map).
RemoteMessage	A decoded message exchanged over a remote transport between event bus instances.
RemoteUtils	Utility methods for parsing and dispatching JSON-encoded remote messages to registered handlers.
ReplayProtocol	A replay protocol that reads either CSV (test_ph.csv) or JSONL files and replays all datapoints in real time into the FRAMED EventBus, using the same publish mechanism as the real PC60FW / Oxylog drivers.
RespiratoryRateEstimationReactor	Reactor for estimating respiratory rate (RR) from a continuous EtCO₂ waveform using a robust slope‑based breath detection algorithm.
RRMismatchClassificationReactor
RuleType	Enumerates the types of channel conditions supported: RuleType.ANY: at least one new message RuleType.AT_LEAST: at least n new messages RuleType.REQUIRE_VALUE: at least one new message and latest value equals value
RuleUtils	Runtime helpers shared by Reactor and its concrete implementations: extracting a logical timestamp from an incoming message and publishing a result envelope to a reactor's output channels.
Service	An abstract base class for application services that provides access to an EventBus for inter-component communication / services and a Logger for logging.
SFComputationReactor
SlopeUtils
SlopeUtils.Sample
SocketEventBus	A distributed EventBus implementation backed by a Transport for remote communication.
TCPTransport	A Transport implementation using traditional blocking I/O over TCP sockets.
Timer	A utility class for scheduling tasks with delays or at fixed intervals using a ScheduledExecutorService.
Transport	Defines a transport mechanism for communication between services, JVMs, or devices.
TrendClassificationReactor	A specialized Reactor that detects a decreasing trend (downward drift) in numeric channel values using a sliding window and a slope-based metric.
TrendDirection	Enumerates the directions of trends: TrendDirection.UP: find upwards trends TrendDirection.DOWN: find downwards trends TrendDirection.BOTH: find both up- and downwards trends
TrendMode	Enumerates the mode of tends conditions supported: TrendMode.MEAN_STEP_DIFF: The trend is measured by the mean difference between observed data points. TrendMode.REGRESSION_SLOPE: The trend is measured by the best fitting slope (regression).
UDPTransport	A Transport implementation using UDP datagrams for lightweight, connectionless messaging.
Writer<T>	An abstract base class for writing data of type T to a specified file path.