Index

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

A

ACTIVE - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
Actor - Class in com.framed.cdss
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).
Actor(EventBus, String, List<Map<String, String>>, List<String>, List<String>) - Constructor for class com.framed.cdss.Actor
Constructs an Actor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.
addPeer(Peer) - Method in class com.framed.core.remote.SocketEventBus
Adds a remote peer to the event bus.
address() - Method in record class com.framed.core.remote.RemoteMessage
Returns the value of the address record component.
ALARM_RESPONSE_CP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
ALARM_RESPONSE_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
Algorithm Overview - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
ANY - Enum constant in enum class com.framed.cdss.utils.RuleType
 
Assumptions - Search tag in class com.framed.cdss.Actor
Section
AT_LEAST - Enum constant in enum class com.framed.cdss.utils.RuleType
 

B

BOFCOMCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
BOFRESPCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
BOTH - Enum constant in enum class com.framed.cdss.utils.TrendDirection
 
Bounds - Record Class in com.framed.cdss
 
Bounds(float, float) - Constructor for record class com.framed.cdss.Bounds
Creates an instance of a Bounds record class.

C

CDSSUtils - Class in com.framed.cdss.utils
 
channelID() - Method in record class com.framed.streamer.model.DataPoint
Returns the value of the channelID record component.
Characteristics of UDP - Search tag in class com.framed.core.remote.NioUdpTransport
Section
checkLimits(Map<String, Object>) - Method in class com.framed.cdss.actors.LimitClassificationActor
Classifies each channel's input value using its configured list of ascending upper bounds.
className() - Method in record class com.framed.streamer.model.DataPoint
Returns the value of the className record component.
com.framed.cdss - package com.framed.cdss
 
com.framed.cdss.actors - package com.framed.cdss.actors
 
com.framed.cdss.utils - package com.framed.cdss.utils
 
com.framed.communicator.driver.parser - package com.framed.communicator.driver.parser
 
com.framed.communicator.driver.parser.medibus - package com.framed.communicator.driver.parser.medibus
 
com.framed.communicator.driver.parser.viatom - package com.framed.communicator.driver.parser.viatom
 
com.framed.communicator.driver.protocol - package com.framed.communicator.driver.protocol
 
com.framed.communicator.driver.protocol.medibus - package com.framed.communicator.driver.protocol.medibus
 
com.framed.communicator.driver.protocol.medibus.utils - package com.framed.communicator.driver.protocol.medibus.utils
 
com.framed.communicator.io - package com.framed.communicator.io
 
com.framed.communicator.io.parsed - package com.framed.communicator.io.parsed
 
com.framed.communicator.io.raw - package com.framed.communicator.io.raw
 
com.framed.core - package com.framed.core
 
com.framed.core.local - package com.framed.core.local
 
com.framed.core.remote - package com.framed.core.remote
 
com.framed.core.utils - package com.framed.core.utils
 
com.framed.orchestrator - package com.framed.orchestrator
 
com.framed.streamer - package com.framed.streamer
 
com.framed.streamer.dispatcher - package com.framed.streamer.dispatcher
 
com.framed.streamer.model - package com.framed.streamer.model
 
commandEchoResponse(byte[]) - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
computeChecksum(byte[]) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
computeSlope(Deque<SlopeUtils.Sample>) - Static method in class com.framed.cdss.utils.SlopeUtils
Computes the least-squares linear regression slope of the ETCO2 signal over the provided sliding window, using time in seconds relative to the first sample in the window.
concatBuffer(byte[], byte[]) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
ConfigLoader - Class in com.framed.orchestrator
The ConfigLoader class provides utility methods for loading and validating JSON-based configuration files used by the orchestrator.
Configuration Parameters - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
configureRealtimeTransmission() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
CONFIGURING - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
connect() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
connect() - Method in class com.framed.communicator.driver.protocol.Protocol
Establishes a connection using the specific protocol implementation and starts the configured data export.
createDevIDMessage() - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
createFrameListFromByte(byte) - Method in class com.framed.communicator.driver.protocol.medibus.MedibusFramer
 
createWaveFormTypeList(int) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 

D

DATA_RESPONSE_CP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
DATA_RESPONSE_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
DataConstants - Class in com.framed.communicator.driver.protocol.medibus.utils
 
DataPoint<T> - Record Class in com.framed.streamer.model
 
DataPoint(Instant, T, String, String, String) - Constructor for record class com.framed.streamer.model.DataPoint
Creates an instance of a DataPoint record class.
DataUtils - Class in com.framed.communicator.driver.protocol.medibus.utils
 
DEV_ID_REQUEST - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
DEV_ID_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
deviceID() - Method in record class com.framed.streamer.model.DataPoint
Returns the value of the deviceID record component.
DFCN - Class in com.framed.cdss
 
DFCN(List<Actor>) - Constructor for class com.framed.cdss.DFCN
 
Directional warning condition - Search tag in class com.framed.cdss.actors.TrendClassificationActor
Section
DislocationClassificationActor - Class in com.framed.cdss.actors
 
DislocationClassificationActor(EventBus, String, String, String, String, String) - Constructor for class com.framed.cdss.actors.DislocationClassificationActor
Constructs an Actor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.
Dispatcher - Class in com.framed.streamer.dispatcher
 
Dispatcher(EventBus, JSONArray) - Constructor for class com.framed.streamer.dispatcher.Dispatcher
 
DispatchMode - Enum Class in com.framed.core.utils
 
DOWN - Enum constant in enum class com.framed.cdss.utils.TrendDirection
 

E

ENDOFTEXT - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
EOFCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
equals(Object) - Method in record class com.framed.cdss.Bounds
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.cdss.FiringRule
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.core.remote.Peer
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.core.remote.RemoteMessage
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.streamer.model.DataPoint
Indicates whether some other object is "equal to" this one.
eventBus - Variable in class com.framed.core.Service
The event bus used for communication between components.
EventBus - Interface in com.framed.core
Defines a simple event bus mechanism for message-based communication between components and/or services.
Example - Search tag in class com.framed.cdss.Actor
Section
Example usage - Search tag in class com.framed.core.remote.NioUdpTransport
Section
Example usage: - Search tag in class com.framed.core.remote.NioTcpTransport
Section
Example usage: - Search tag in class com.framed.core.remote.TCPTransport
Section
Example usage: - Search tag in class com.framed.core.remote.UDPTransport
Section
Extensibility - Search tag in class com.framed.cdss.Actor
Section

F

Factory - Class in com.framed.orchestrator
The Factory class provides dynamic instantiation of Service implementations based on JSON configuration.
Features: - Search tag in class com.framed.core.local.LocalEventBus
Section
Features: - Search tag in class com.framed.core.remote.MockTransport
Section
Features: - Search tag in class com.framed.core.remote.NioTcpTransport
Section
Features: - Search tag in class com.framed.core.remote.SocketEventBus
Section
Features: - Search tag in class com.framed.core.remote.TCPTransport
Section
Features: - Search tag in class com.framed.core.remote.UDPTransport
Section
Features: - Search tag in class com.framed.core.utils.Timer
Section
Features: - Search tag in class com.framed.orchestrator.ConfigLoader
Section
Features: - Search tag in class com.framed.orchestrator.Factory
Section
Features: - Search tag in class com.framed.orchestrator.Manager
Section
FfillDispatcher - Class in com.framed.streamer.dispatcher
 
FfillDispatcher(EventBus, JSONArray, Long) - Constructor for class com.framed.streamer.dispatcher.FfillDispatcher
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.Actor
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.DislocationClassificationActor
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.HeartrateClassificationActor
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.LimitClassificationActor
Receives a snapshot from the runtime, classifies all channel values via LimitClassificationActor.checkLimits(Map), and publishes one result message per output channel.
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Processes a single incoming ETCO2_WAVE sample, updates the smoothing/filters, maintains the sliding window, estimates the local slope (mmHg/s), and drives the hysteresis-based breath detection state machine.
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.RRMismatchClassificationActor
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.SFComputationActor
 
fireFunction(Map<String, Object>) - Method in class com.framed.cdss.actors.TrendClassificationActor
Updates per-channel windows with the newest snapshot values, computes the regression slope when enough samples exist, and emits warnings for channels exhibiting a persistent decreasing trend.
FiringRule - Record Class in com.framed.cdss
Structured representation of a parsed channel condition.
FiringRule(RuleType, long, String) - Constructor for record class com.framed.cdss.FiringRule
Creates an instance of a FiringRule record class.
Firing Rule Configuration - Search tag in class com.framed.cdss.Actor
Section
formatter - Static variable in class com.framed.core.Service
 
formatter - Static variable in class com.framed.core.utils.Timer
 

G

getDataStreamConfigBuffer(byte, boolean) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
getInputChannels() - Method in class com.framed.cdss.Actor
 
getOutputChannels() - Method in class com.framed.cdss.Actor
 
getRealtimeConfigMessage(List<Byte>, List<Byte>, String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
getSentMessages() - Method in class com.framed.core.remote.MockTransport
Returns the list of sent and published messages for verification.

H

handleEventBus(Object, String) - Method in class com.framed.communicator.io.parsed.MedibusParsedWriter
 
handleEventBus(Object, String) - Method in class com.framed.communicator.io.raw.RawByteWriter
 
hashCode() - Method in record class com.framed.cdss.Bounds
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.cdss.FiringRule
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.core.remote.Peer
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.core.remote.RemoteMessage
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.streamer.model.DataPoint
Returns a hash code value for this object.
HeartrateClassificationActor - Class in com.framed.cdss.actors
 
HeartrateClassificationActor(EventBus, String, String, String, String) - Constructor for class com.framed.cdss.actors.HeartrateClassificationActor
Constructs an Actor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.
hexToBytes(String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.ParsingUtils
 
host() - Method in record class com.framed.core.remote.Peer
Returns the value of the host record component.

I

ICC_COMMAND - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
ICC_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
id - Variable in class com.framed.cdss.Actor
Identifier of the LimitClassifier instance
id - Variable in class com.framed.communicator.driver.protocol.Protocol
Unique identifier for this protocol instance.
IDENTIFYING - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
IDLE - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
InfluxDispatcher - Class in com.framed.streamer.dispatcher
 
InfluxDispatcher(EventBus, JSONArray, String, String, String, String) - Constructor for class com.framed.streamer.dispatcher.InfluxDispatcher
 
INITIALIZING - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
Input - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
inputChannels - Variable in class com.framed.cdss.Actor
Names of input channels that this actor subscribes to and maintains state for.
Inputs and outputs - Search tag in class com.framed.cdss.actors.TrendClassificationActor
Section
instantiate(String) - Method in class com.framed.orchestrator.Manager
Instantiates all services of the specified type from the configuration.
instantiate(JSONObject, EventBus) - Static method in class com.framed.orchestrator.Factory
Instantiates a Service implementation based on the provided configuration and event bus.
Intended Use - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section

J

JsonlDispatcher - Class in com.framed.streamer.dispatcher
 
JsonlDispatcher(EventBus, JSONArray, String, String) - Constructor for class com.framed.streamer.dispatcher.JsonlDispatcher
 

L

LimitClassificationActor - Class in com.framed.cdss.actors
A specialized Actor that classifies numeric input values per channel based on a configured, ascending-sorted list of upper bounds.
LimitClassificationActor(EventBus, String, JSONArray, JSONArray, JSONArray, JSONObject) - Constructor for class com.framed.cdss.actors.LimitClassificationActor
Constructs a LimitClassifier.
loadConfig(String) - Static method in class com.framed.orchestrator.ConfigLoader
Loads a JSON configuration file from the specified path.
LocalEventBus - Class in com.framed.core.local
A local implementation of the EventBus interface for message-based communication between components within the same JVM.
LocalEventBus() - Constructor for class com.framed.core.local.LocalEventBus
 
logger - Variable in class com.framed.core.Service
Logger instance for this service, initialized with the class name.
lower() - Method in record class com.framed.cdss.Bounds
Returns the value of the lower record component.

M

main(String[]) - Static method in class com.framed.orchestrator.Main
 
Main - Class in com.framed.orchestrator
 
Main() - Constructor for class com.framed.orchestrator.Main
 
Manager - Class in com.framed.orchestrator
The Manager class is responsible for orchestrating the lifecycle of Service instances based on a JSON configuration.
Manager(JSONObject, EventBus) - Constructor for class com.framed.orchestrator.Manager
Creates a new Manager with the given configuration and event bus.
MEAN_STEP_DIFF - Enum constant in enum class com.framed.cdss.utils.TrendMode
 
MedibusFramer - Class in com.framed.communicator.driver.protocol.medibus
 
MedibusFramer(Consumer<byte[]>, EventBus, String) - Constructor for class com.framed.communicator.driver.protocol.medibus.MedibusFramer
 
MedibusParsedWriter - Class in com.framed.communicator.io.parsed
 
MedibusParsedWriter(String, EventBus, JSONArray) - Constructor for class com.framed.communicator.io.parsed.MedibusParsedWriter
 
MedibusProtocol - Class in com.framed.communicator.driver.protocol.medibus
 
MedibusProtocol(String, String, int, int, int, int, boolean, boolean, String, EventBus) - Constructor for class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
MedibusRealTimeParser - Class in com.framed.communicator.driver.parser.medibus
 
MedibusRealTimeParser(EventBus, int, JSONArray) - Constructor for class com.framed.communicator.driver.parser.medibus.MedibusRealTimeParser
 
MedibusSlowParser - Class in com.framed.communicator.driver.parser.medibus
 
MedibusSlowParser(EventBus, JSONArray) - Constructor for class com.framed.communicator.driver.parser.medibus.MedibusSlowParser
 
MedibusState - Enum Class in com.framed.communicator.driver.protocol.medibus.utils
 
MedibusXAlarmsCP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXAlarmsCP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXDeviceSettings - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXMeasurementCP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXMeasurementCP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXRealTimeData - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
MedibusXTextMessages - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
Message Format - Search tag in class com.framed.core.remote.NioUdpTransport
Section
Message Format: - Search tag in class com.framed.core.remote.NioTcpTransport
Section
Message Format: - Search tag in class com.framed.core.remote.TCPTransport
Section
Message Format: - Search tag in class com.framed.core.remote.UDPTransport
Section
MockTransport - Class in com.framed.core.remote
A mock implementation of the Transport interface for testing purposes.
MockTransport() - Constructor for class com.framed.core.remote.MockTransport
 

N

n() - Method in record class com.framed.cdss.FiringRule
Returns the value of the n record component.
NioTcpTransport - Class in com.framed.core.remote
A Transport implementation using Java NIO for TCP-based communication.
NioTcpTransport(int) - Constructor for class com.framed.core.remote.NioTcpTransport
Creates a new NIO TCP transport bound to the specified port.
NioUdpTransport - Class in com.framed.core.remote
A Transport implementation using Java NIO over UDP for lightweight, connectionless message delivery between services or devices.
NioUdpTransport(int) - Constructor for class com.framed.core.remote.NioUdpTransport
Creates a new UDP transport bound to the specified local port.
NOP_REQUEST - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
NOP_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 

O

Output - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
outputChannels - Variable in class com.framed.cdss.Actor
Names of output channels this actor may use (not used internally in this base class).

P

PARALLEL - Enum constant in enum class com.framed.core.utils.DispatchMode
 
parse(byte[], String) - Method in class com.framed.communicator.driver.parser.medibus.MedibusSlowParser
 
parse(Byte, String) - Method in class com.framed.communicator.driver.parser.medibus.MedibusRealTimeParser
 
parse(Object, String) - Method in class com.framed.communicator.driver.parser.viatom.ViatomParser
 
parse(JSONObject) - Static method in class com.framed.streamer.Parser
 
parse(T, String) - Method in class com.framed.communicator.driver.parser.Parser
 
parseAndDispatch(String, Map<String, List<Consumer<Object>>>, Map<Consumer<Object>, ExecutorService>) - Static method in class com.framed.core.utils.RemoteUtils
Parses a JSON message and submits it to registered handlers.
parseAndDispatchAsync(String, Map<String, List<Consumer<Object>>>, ExecutorService) - Static method in class com.framed.core.utils.RemoteUtils
Parses a JSON message and submits it to registered handlers, creating a thread per handler.
parseChannelListJson(JSONArray) - Static method in class com.framed.cdss.utils.CDSSUtils
 
parseFiringRulesJson(JSONArray) - Static method in class com.framed.cdss.utils.CDSSUtils
 
parseLimitsJson(JSONObject) - Static method in class com.framed.cdss.utils.CDSSUtils
 
parseMessage(String) - Static method in class com.framed.core.utils.RemoteUtils
 
parsePerChannelIntMap(JSONObject, int) - Static method in class com.framed.cdss.utils.CDSSUtils
 
Parser<T> - Class in com.framed.communicator.driver.parser
 
Parser - Class in com.framed.streamer
 
Parser() - Constructor for class com.framed.streamer.Parser
 
Parser(EventBus) - Constructor for class com.framed.communicator.driver.parser.Parser
 
ParsingUtils - Class in com.framed.communicator.driver.protocol.medibus.utils
 
path - Variable in class com.framed.communicator.io.Writer
The file system path where data will be written.
payload() - Method in record class com.framed.core.remote.RemoteMessage
Returns the value of the payload record component.
Peer - Record Class in com.framed.core.remote
Represents a network peer identified by a host (name or IP address) and a port.
Peer(String, int) - Constructor for record class com.framed.core.remote.Peer
Creates an instance of a Peer record class.
PER_HANDLER - Enum constant in enum class com.framed.core.utils.DispatchMode
 
Persistence / Debouncing - Search tag in class com.framed.cdss.actors.TrendClassificationActor
Section
poll_configure_real_time_transmission - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_config_alarms_codepage1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_config_alarms_codepage2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_config_measured_data_codepage1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_config_measured_data_codepage2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_current_date_time - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_device_settings - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_deviceid - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_icc_msg - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_no_operation - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_real_time_config_changed - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_real_time_data_config - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_stop_com - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
poll_request_text_messages - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
port() - Method in record class com.framed.core.remote.Peer
Returns the value of the port record component.
Protocol - Class in com.framed.communicator.driver.protocol
Represents an abstract communication protocol that extends the Service class.
Protocol(String, EventBus) - Constructor for class com.framed.communicator.driver.protocol.Protocol
Creates a new Protocol instance.
publish(String, int, String, Object) - Method in class com.framed.core.remote.MockTransport
Simulates publishing a message to all subscribers of the specified address.
publish(String, int, String, Object) - Method in class com.framed.core.remote.NioTcpTransport
Publishes a message to all subscribers of the specified address.
publish(String, int, String, Object) - Method in class com.framed.core.remote.NioUdpTransport
Publishes a message intended for broadcast semantics on the receiver side.
publish(String, int, String, Object) - Method in class com.framed.core.remote.TCPTransport
Publishes a message intended for broadcast semantics on the receiver side.
publish(String, int, String, Object) - Method in interface com.framed.core.remote.Transport
Publishes a message to all subscribers of the specified address.
publish(String, int, String, Object) - Method in class com.framed.core.remote.UDPTransport
Publishes a message intended for broadcast semantics on the receiver side.
publish(String, Object) - Method in interface com.framed.core.EventBus
Publishes a message to all handlers registered for the given address.
publish(String, Object) - Method in class com.framed.core.local.LocalEventBus
Publishes a message to all handlers registered for the given address.
publish(String, Object) - Method in class com.framed.core.remote.SocketEventBus
Publishes a message to all registered peers and dispatches locally.
publishResult(EventBus, DateTimeFormatter, Object, String, List<String>) - Static method in class com.framed.cdss.utils.CDSSUtils
 
push(DataPoint<?>) - Method in class com.framed.streamer.dispatcher.Dispatcher
 
push(DataPoint<?>) - Method in class com.framed.streamer.dispatcher.FfillDispatcher
 
push(DataPoint<?>) - Method in class com.framed.streamer.dispatcher.InfluxDispatcher
 
push(DataPoint<?>) - Method in class com.framed.streamer.dispatcher.JsonlDispatcher
 
pushBatch(List<DataPoint<?>>) - Method in class com.framed.streamer.dispatcher.Dispatcher
 
pushBatch(List<DataPoint<?>>) - Method in class com.framed.streamer.dispatcher.FfillDispatcher
 
pushBatch(List<DataPoint<?>>) - Method in class com.framed.streamer.dispatcher.InfluxDispatcher
 
pushBatch(List<DataPoint<?>>) - Method in class com.framed.streamer.dispatcher.JsonlDispatcher
 

R

RawByteWriter - Class in com.framed.communicator.io.raw
 
RawByteWriter(String, EventBus, JSONArray) - Constructor for class com.framed.communicator.io.raw.RawByteWriter
 
readRealtimeConfigResponse(byte[], EventBus, String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.ParsingUtils
 
REALTIME - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
register(String, Consumer<Object>) - Method in interface com.framed.core.EventBus
Registers a handler for messages sent to the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.local.LocalEventBus
Registers a handler for the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.MockTransport
Registers a handler for messages received on the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.NioTcpTransport
Registers a handler for messages received on the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.NioUdpTransport
Registers a handler for messages received on the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.SocketEventBus
Registers a local handler for the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.TCPTransport
Registers a handler for messages received on the specified address.
register(String, Consumer<Object>) - Method in interface com.framed.core.remote.Transport
Registers a handler for messages received on the specified address.
register(String, Consumer<Object>) - Method in class com.framed.core.remote.UDPTransport
Registers a handler for messages received on the specified address.
REGRESSION_SLOPE - Enum constant in enum class com.framed.cdss.utils.TrendMode
 
RemoteMessage - Record Class in com.framed.core.remote
 
RemoteMessage(String, Object, String) - Constructor for record class com.framed.core.remote.RemoteMessage
Creates an instance of a RemoteMessage record class.
RemoteUtils - Class in com.framed.core.utils
 
removePeer(Peer) - Method in class com.framed.core.remote.SocketEventBus
Removes a remote peer from the event bus.
REQUIRE_VALUE - Enum constant in enum class com.framed.cdss.utils.RuleType
 
Respiratory Rate Computation - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
RespiratoryRateEstimationActor - Class in com.framed.cdss.actors
Actor for estimating respiratory rate (RR) from a continuous EtCO₂ waveform using a robust slope‑based breath detection algorithm.
RespiratoryRateEstimationActor(EventBus, String, String, JSONArray, int, double, double, double, int, boolean, double, boolean, int, double) - Constructor for class com.framed.cdss.actors.RespiratoryRateEstimationActor
Creates a respiratory rate estimator actor that detects breaths from an EtCO₂ waveform using a robust slope-based algorithm with optional smoothing and outlier suppression.
RRMismatchClassificationActor - Class in com.framed.cdss.actors
 
RRMismatchClassificationActor(EventBus, String, String, String, JSONArray, int) - Constructor for class com.framed.cdss.actors.RRMismatchClassificationActor
 
RT_BYTE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
RT_BYTE_MASK - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
RT_CONFIG_CHANGED - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
RT_CONFIG_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
RT_TRANSMISSION_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
RuleType - Enum Class in com.framed.cdss.utils
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

S

Sample(Instant, double) - Constructor for record class com.framed.cdss.utils.SlopeUtils.Sample
Creates an instance of a Sample record class.
SC_CORRUPT_DATA - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_DATASTREAM_1_4 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_DATASTREAM_5_8 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_DATASTREAM_9_12 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_END_OF_SEQUENCE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_START_CYCLE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_TX_DATASTREAM_5_8 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SC_TX_DATASTREAM_9_12 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
See Also - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
send(String, int, String, Object) - Method in class com.framed.core.remote.MockTransport
Simulates sending a message to a specific host and port.
send(String, int, String, Object) - Method in class com.framed.core.remote.NioTcpTransport
Sends a message to the first subscriber of the specified address.
send(String, int, String, Object) - Method in class com.framed.core.remote.NioUdpTransport
Sends a point-to-point message to the specified host and port via UDP.
send(String, int, String, Object) - Method in class com.framed.core.remote.TCPTransport
Sends a point-to-point message to the specified host and port via TCP.
send(String, int, String, Object) - Method in interface com.framed.core.remote.Transport
Sends a message to a specific host and port using point-to-point delivery.
send(String, int, String, Object) - Method in class com.framed.core.remote.UDPTransport
Sends a point-to-point message via UDP.
send(String, Object) - Method in interface com.framed.core.EventBus
Sends a message to a single handler registered for the given address.
send(String, Object) - Method in class com.framed.core.local.LocalEventBus
Sends a message to a single handler registered for the given address.
send(String, Object) - Method in class com.framed.core.remote.SocketEventBus
Sends a point-to-point message to all registered peers and dispatches locally.
sendDeviceID() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
SEQUENTIAL - Enum constant in enum class com.framed.core.utils.DispatchMode
 
Service - Class in com.framed.core
An abstract base class for application services that provides access to an EventBus for inter-component communication / services and a Logger for logging.
Service(EventBus) - Constructor for class com.framed.core.Service
Creates a new service instance with the specified event bus.
setConfiguredDataStreams(boolean) - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
setDataStreams(byte, boolean) - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
setPeriodic(long, Runnable) - Method in class com.framed.core.utils.Timer
Schedules a periodic task to execute at a fixed interval.
setTimer(long, Runnable) - Method in class com.framed.core.utils.Timer
Schedules a one-time task to execute after the specified delay.
SETTINGS_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SFComputationActor - Class in com.framed.cdss.actors
 
SFComputationActor(EventBus, String, String, String, String) - Constructor for class com.framed.cdss.actors.SFComputationActor
 
shutdown() - Method in interface com.framed.core.EventBus
Shutdown method of the EventBus.
shutdown() - Method in class com.framed.core.local.LocalEventBus
Stops all executors that were added to the executors map.
shutdown() - Method in class com.framed.core.remote.MockTransport
No-op for mock implementation.
shutdown() - Method in class com.framed.core.remote.NioTcpTransport
Shuts down the transport, closing the selector, server channel, and worker pool.
shutdown() - Method in class com.framed.core.remote.NioUdpTransport
Shuts down the transport and releases resources.
shutdown() - Method in class com.framed.core.remote.SocketEventBus
Shuts down the event bus and releases resources.
shutdown() - Method in class com.framed.core.remote.TCPTransport
Shuts down the transport and releases resources.
shutdown() - Method in interface com.framed.core.remote.Transport
Shuts down the transport mechanism and releases any allocated resources.
shutdown() - Method in class com.framed.core.remote.UDPTransport
Shuts down the transport and releases resources.
shutdown() - Method in class com.framed.core.utils.Timer
Shuts down the scheduler and stops accepting new tasks.
SlopeUtils - Class in com.framed.cdss.utils
 
SlopeUtils() - Constructor for class com.framed.cdss.utils.SlopeUtils
 
SlopeUtils.Sample - Record Class in com.framed.cdss.utils
 
Snapshot Semantics - Search tag in class com.framed.cdss.Actor
Section
SocketEventBus - Class in com.framed.core.remote
A distributed EventBus implementation that uses a Transport for remote communication.
SocketEventBus(Transport, DispatchMode) - Constructor for class com.framed.core.remote.SocketEventBus
Creates a new SocketEventBus using the specified transport and dispatch mode.
SOH - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
start() - Method in class com.framed.core.remote.MockTransport
No-op for mock implementation.
start() - Method in class com.framed.core.remote.NioTcpTransport
Starts the transport event loop in a background thread.
start() - Method in class com.framed.core.remote.NioUdpTransport
Starts the selector loop on a background thread.
start() - Method in class com.framed.core.remote.TCPTransport
Starts the TCP server in a background thread.
start() - Method in interface com.framed.core.remote.Transport
Starts the transport mechanism, initializing resources such as sockets or threads.
start() - Method in class com.framed.core.remote.UDPTransport
Starts the UDP listener in a background thread.
stop() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
stop() - Method in class com.framed.core.Service
Stops the service.
stop() - Method in class com.framed.streamer.dispatcher.FfillDispatcher
 
stop() - Method in class com.framed.streamer.dispatcher.InfluxDispatcher
 
stop(String) - Method in class com.framed.orchestrator.Manager
Stops the service with the specified ID.
stopAll() - Method in class com.framed.orchestrator.Manager
Stops all active services managed by this instance.
stringToHex(String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.ParsingUtils
 
SYNC_BYTE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SYNC_CMD_BYTE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
SYNC_MASK - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 

T

t() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Returns the value of the t record component.
TCPTransport - Class in com.framed.core.remote
A Transport implementation using traditional blocking I/O over TCP sockets.
TCPTransport(int) - Constructor for class com.framed.core.remote.TCPTransport
Creates a new TCP transport bound to the specified port.
TERMINATING - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
 
TEXT_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
Thread Safety - Search tag in class com.framed.cdss.Actor
Section
Thread Safety - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
timeOnStart - Variable in class com.framed.communicator.io.Writer
The timestamp (in milliseconds since epoch) when this writer instance was created.
Timer - Class in com.framed.core.utils
A utility class for scheduling tasks with delays or at fixed intervals using a ScheduledExecutorService.
Timer() - Constructor for class com.framed.core.utils.Timer
 
timestamp() - Method in record class com.framed.streamer.model.DataPoint
Returns the value of the timestamp record component.
toJsonString() - Method in record class com.framed.streamer.model.DataPoint
 
toString() - Method in record class com.framed.cdss.Bounds
Returns a string representation of this record class.
toString() - Method in record class com.framed.cdss.FiringRule
Returns a string representation of this record class.
toString() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Returns a string representation of this record class.
toString() - Method in record class com.framed.core.remote.Peer
Returns a string representation of this record class.
toString() - Method in record class com.framed.core.remote.RemoteMessage
Returns a string representation of this record class.
toString() - Method in record class com.framed.streamer.model.DataPoint
Returns a string representation of this record class.
Transport - Interface in com.framed.core.remote
Defines a transport mechanism for communication between services, JVMs, or devices.
TrendClassificationActor - Class in com.framed.cdss.actors
A specialized Actor that detects a decreasing trend (downward drift) in numeric channel values using a sliding window and a slope-based metric.
TrendClassificationActor(EventBus, String, JSONArray, JSONArray, JSONArray, JSONObject, JSONObject, JSONObject, String) - Constructor for class com.framed.cdss.actors.TrendClassificationActor
Constructs a TrendClassifier that warns on decreasing trends using regression slope, with configurable persistence.
Trend definition (slope-based) - Search tag in class com.framed.cdss.actors.TrendClassificationActor
Section
TrendDirection - Enum Class in com.framed.cdss.utils
Enumerates the directions of trends: TrendDirection.UP: find upwards trends TrendDirection.DOWN: find downwards trends TrendDirection.BOTH: find both up- and downwards trends
TrendMode - Enum Class in com.framed.cdss.utils
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).
Triggering - Search tag in class com.framed.cdss.actors.RespiratoryRateEstimationActor
Section
type() - Method in record class com.framed.cdss.FiringRule
Returns the value of the type record component.
type() - Method in record class com.framed.core.remote.RemoteMessage
Returns the value of the type record component.

U

UDPTransport - Class in com.framed.core.remote
A Transport implementation using UDP datagrams for lightweight, connectionless messaging.
UDPTransport(int) - Constructor for class com.framed.core.remote.UDPTransport
Creates a new UDP transport bound to the specified port.
UP - Enum constant in enum class com.framed.cdss.utils.TrendDirection
 
upper() - Method in record class com.framed.cdss.Bounds
Returns the value of the upper record component.
Usage Example: - Search tag in class com.framed.core.remote.SocketEventBus
Section
Usage Example: - Search tag in class com.framed.orchestrator.Manager
Section

V

v() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Returns the value of the v record component.
validateCommunicationConfigs(JSONObject) - Static method in class com.framed.orchestrator.ConfigLoader
Validates communication configurations.
validateDFCN() - Method in class com.framed.orchestrator.Manager
 
validateServiceConfigs(JSONObject) - Static method in class com.framed.orchestrator.ConfigLoader
Validates service instantiation configurations.
value() - Method in record class com.framed.cdss.FiringRule
Returns the value of the value record component.
value() - Method in record class com.framed.streamer.model.DataPoint
Returns the value of the value record component.
valueMatchesExpected(Object, String) - Method in class com.framed.cdss.Actor
Hook for customizing equality checks used by "r:v" conditions.
valueOf(String) - Static method in enum class com.framed.cdss.utils.RuleType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.framed.cdss.utils.TrendDirection
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.framed.cdss.utils.TrendMode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.framed.core.utils.DispatchMode
Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.framed.cdss.utils.RuleType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.framed.cdss.utils.TrendDirection
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.framed.cdss.utils.TrendMode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.framed.core.utils.DispatchMode
Returns an array containing the constants of this enum class, in the order they are declared.
ViatomParser - Class in com.framed.communicator.driver.parser.viatom
 
ViatomParser(EventBus, JSONArray) - Constructor for class com.framed.communicator.driver.parser.viatom.ViatomParser
 

W

write(byte[], String) - Method in class com.framed.communicator.io.raw.RawByteWriter
 
write(String, List<Map<String, Object>>) - Method in class com.framed.communicator.driver.parser.medibus.MedibusRealTimeParser
 
write(JSONObject, String) - Method in class com.framed.communicator.io.parsed.MedibusParsedWriter
 
write(T, String) - Method in class com.framed.communicator.io.Writer
Writes the given data to the configured path.
Writer<T> - Class in com.framed.communicator.io
An abstract base class for writing data of type T to a specified file path.
Writer(String, EventBus) - Constructor for class com.framed.communicator.io.Writer
Creates a new Writer instance.
A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values