All Classes and Interfaces

Class	Description
Actor	An abstract reactive Actor that listens to a set of input channels on an EventBus, buffers their latest messages, and evaluates configurable firing rules to decide when to invoke a user-defined Actor.fireFunction(Map).
Bounds
CDSSUtils
ConfigLoader	The ConfigLoader class provides utility methods for loading and validating JSON-based configuration files used by the orchestrator.
DataConstants
DataPoint<T>
DataUtils
DFCN
DislocationClassificationActor
Dispatcher
DispatchMode
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.
HeartrateClassificationActor
InfluxDispatcher
JsonlDispatcher
LimitClassificationActor	A specialized Actor 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
Manager	The Manager class is responsible for orchestrating the lifecycle of Service instances based on a JSON configuration.
MedibusFramer
MedibusParsedWriter
MedibusProtocol
MedibusRealTimeParser
MedibusSlowParser
MedibusState
MockTransport	A mock implementation of the Transport interface for testing purposes.
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>
Parser
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.
RawByteWriter
RemoteMessage
RemoteUtils
RespiratoryRateEstimationActor	Actor for estimating respiratory rate (RR) from a continuous EtCO₂ waveform using a robust slope‑based breath detection algorithm.
RRMismatchClassificationActor
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
Service	An abstract base class for application services that provides access to an EventBus for inter-component communication / services and a Logger for logging.
SFComputationActor
SlopeUtils
SlopeUtils.Sample
SocketEventBus	A distributed EventBus implementation that uses 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.
TrendClassificationActor	A specialized Actor 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.
ViatomParser
Writer<T>	An abstract base class for writing data of type T to a specified file path.