Index
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
Actorthat listens to a set of input channels on anEventBus, buffers their latest messages, and evaluates configurable firing rules to decide when to invoke a user-definedActor.fireFunction(Map). - Actor(EventBus, String, List<Map<String, String>>, List<String>, List<String>) - Constructor for class com.framed.cdss.Actor
-
Constructs an
Actorthat subscribes to the giveninputChannels, evaluates the providedfiringRules, and optionally exposesoutputChannels. - 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
addressrecord 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
Boundsrecord class.
C
- CDSSUtils - Class in com.framed.cdss.utils
- channelID() - Method in record class com.framed.streamer.model.DataPoint
-
Returns the value of the
channelIDrecord 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
classNamerecord 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
ConfigLoaderclass 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
DataPointrecord 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
deviceIDrecord 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
Actorthat subscribes to the giveninputChannels, evaluates the providedfiringRules, and optionally exposesoutputChannels. - 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
Factoryclass provides dynamic instantiation ofServiceimplementations 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
FiringRulerecord 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
Actorthat subscribes to the giveninputChannels, evaluates the providedfiringRules, and optionally exposesoutputChannels. - 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
hostrecord 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
Serviceimplementation 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
Actorthat 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
EventBusinterface 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
lowerrecord 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
Managerclass is responsible for orchestrating the lifecycle ofServiceinstances based on a JSON configuration. - Manager(JSONObject, EventBus) - Constructor for class com.framed.orchestrator.Manager
-
Creates a new
Managerwith 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
Transportinterface 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
nrecord component. - NioTcpTransport - Class in com.framed.core.remote
-
A
Transportimplementation 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
Transportimplementation 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
payloadrecord 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
Peerrecord 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
portrecord component. - Protocol - Class in com.framed.communicator.driver.protocol
-
Represents an abstract communication protocol that extends the
Serviceclass. - 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
RemoteMessagerecord 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 messageRuleType.AT_LEAST: at leastnnew messagesRuleType.REQUIRE_VALUE: at least one new message and latest value equalsvalue
S
- Sample(Instant, double) - Constructor for record class com.framed.cdss.utils.SlopeUtils.Sample
-
Creates an instance of a
Samplerecord 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
- 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
executorsmap. - 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
- SocketEventBus(Transport, DispatchMode) - Constructor for class com.framed.core.remote.SocketEventBus
-
Creates a new
SocketEventBususing 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
trecord component. - TCPTransport - Class in com.framed.core.remote
-
A
Transportimplementation 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
timestamprecord 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
Actorthat 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
TrendClassifierthat 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 trendsTrendDirection.DOWN: find downwards trendsTrendDirection.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
typerecord component. - type() - Method in record class com.framed.core.remote.RemoteMessage
-
Returns the value of the
typerecord component.
U
- UDPTransport - Class in com.framed.core.remote
-
A
Transportimplementation 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
upperrecord 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
vrecord 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
valuerecord component. - value() - Method in record class com.framed.streamer.model.DataPoint
-
Returns the value of the
valuerecord 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
Tto a specified file path. - Writer(String, EventBus) - Constructor for class com.framed.communicator.io.Writer
-
Creates a new Writer instance.
All Classes and Interfaces|All Packages|Constant Field Values