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
 
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.
ADDRESS_REGISTRY_SUFFIX - Static variable in class com.framed.core.Service
Topic suffix for the producer→sink address-discovery protocol.
addressGroup - Variable in class com.framed.arn.Reactor
Producer group under which this reactor announces its output channels (see Service.announceAddress(String, String)).
addressRegistry(String) - Static method in class com.framed.core.Service
Returns the address-discovery topic for the given producer group.
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.reactors.RespiratoryRateEstimationReactor
Section
announceAddress(String, String) - Method in class com.framed.core.Service
Announces that address is an output channel of the producer group, so that sinks subscribed to Service.addressRegistry(String) can discover and bind it.
ANY - Enum constant in enum class com.framed.arn.RuleType
Satisfied when at least one new message has arrived on the channel.
ARN - Class in com.framed.arn
Acyclic Deterministic Reactor Network validator.
ARN() - Constructor for class com.framed.arn.ARN
No-argument constructor used by ServiceLoader.
ARN(List<Reactor>) - Constructor for class com.framed.arn.ARN
Creates a validator over the given reactors and immediately checks that they form an acyclic network.
AT_LEAST - Enum constant in enum class com.framed.arn.RuleType
Satisfied when at least n new messages have arrived on the channel.

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.io.dispatch.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.reactors.LimitClassificationReactor
Classifies each input value using its configured list of ascending upper bounds.
className() - Method in record class com.framed.io.dispatch.DataPoint
Returns the value of the className record component.
com.framed.arn - package com.framed.arn
 
com.framed.cdss - package com.framed.cdss
 
com.framed.cdss.reactors - package com.framed.cdss.reactors
 
com.framed.cdss.utils - package com.framed.cdss.utils
 
com.framed.communicator.driver.parser.medibus - package com.framed.communicator.driver.parser.medibus
 
com.framed.communicator.driver.parser.python - package com.framed.communicator.driver.parser.python
 
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.driver.protocol.replay - package com.framed.communicator.driver.protocol.replay
 
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.spi - package com.framed.core.spi
 
com.framed.core.utils - package com.framed.core.utils
 
com.framed.io.dispatch - package com.framed.io.dispatch
 
com.framed.io.parser - package com.framed.io.parser
 
com.framed.io.protocol - package com.framed.io.protocol
 
com.framed.io.writer - package com.framed.io.writer
 
com.framed.orchestrator - package com.framed.orchestrator
 
com.framed.streamer.dispatcher - package com.framed.streamer.dispatcher
 
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.reactors.RespiratoryRateEstimationReactor
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.replay.ReplayProtocol
 
connect() - Method in class com.framed.io.protocol.Protocol
Establishes a connection using the specific protocol implementation and starts the configured data export.
Core semantics - Search tag in class com.framed.arn.Reactor
Section
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.io.dispatch
An immutable, timestamped value sample produced by a device channel.
DataPoint(Instant, T, String, String, String) - Constructor for record class com.framed.io.dispatch.DataPoint
Creates an instance of a DataPoint record class.
DataPointParser - Class in com.framed.io.dispatch
Utility for converting a JSON bus message into a DataPoint.
DataUtils - Class in com.framed.communicator.driver.protocol.medibus.utils
 
DeploymentValidator - Interface in com.framed.core.spi
Extension point invoked once after all services have been instantiated, allowing domain modules to validate the deployed topology (e.g. checking that a network of services satisfies structural constraints) without the orchestrator depending on any domain type.
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.io.dispatch.DataPoint
Returns the value of the deviceID record component.
Directional warning condition - Search tag in class com.framed.cdss.reactors.TrendClassificationReactor
Section
DislocationClassificationReactor - Class in com.framed.cdss.reactors
 
DislocationClassificationReactor(EventBus, String, String, String, String, String, boolean) - Constructor for class com.framed.cdss.reactors.DislocationClassificationReactor
Constructs an Reactor that subscribes to the given inputChannels, evaluates the provided firingRules, and optionally exposes outputChannels.
Dispatcher - Class in com.framed.io.dispatch
Drop-in replacement: - Never blocks EventBus handler on IO
Dispatcher(EventBus, JSONArray) - Constructor for class com.framed.io.dispatch.Dispatcher
Creates a dispatcher bound to the given event bus and set of devices.
DispatchMode - Enum Class in com.framed.core.utils
Strategy for how an event bus invokes the handlers registered for an address.
Dispatch modes - Search tag in class com.framed.core.local.LocalEventBus
Section
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.arn.FiringRule
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.arn.Reactor.Snapshot
Indicates whether some other object is "equal to" this one.
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.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.io.dispatch.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 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
extractTimestamp(Object) - Static method in class com.framed.arn.RuleUtils
Parses the logical timestamp from an incoming message, if present.

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.remote.NioTcpTransport
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
 
FiringRule - Record Class in com.framed.arn
Structured representation of a parsed channel condition.
FiringRule(RuleType, long, String) - Constructor for record class com.framed.arn.FiringRule
Creates an instance of a FiringRule record class.
formatter - Static variable in class com.framed.core.Service
Shared timestamp formatter (see Timer.formatter) available to all services for consistent serialization and parsing of timestamps.
formatter - Static variable in class com.framed.core.utils.Timer
Shared formatter for timestamps in the pattern yyyy-MM-dd'T'HH:mm:ss.SSSSSS (ISO-like, microsecond precision), used across the framework for serializing and parsing datapoint timestamps.

G

getDataStreamConfigBuffer(byte, boolean) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 
getInputChannels() - Method in class com.framed.arn.Reactor
Returns the input channels this reactor listens to.
getInterpreterInputChannelsList(String, String, String, String, String, String, String, String, String) - Static method in class com.framed.cdss.utils.InterpreterUtils
 
getInterpreterInputFiringRules(String, String, String, String, String, String, String, String, String) - Static method in class com.framed.cdss.utils.InterpreterUtils
 
getOutputChannels() - Method in class com.framed.arn.Reactor
Returns the output channels this reactor may publish to.
getRealtimeConfigMessage(List<Byte>, List<Byte>, String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils
 

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.arn.FiringRule
Returns a hash code value for this object.
hashCode() - Method in record class com.framed.arn.Reactor.Snapshot
Returns a hash code value for this object.
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.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.io.dispatch.DataPoint
Returns a hash code value for this object.
HemodynamicRhythmClassificationReactor - Class in com.framed.cdss.reactors
 
HemodynamicRhythmClassificationReactor(EventBus, String, String, String, String, boolean) - Constructor for class com.framed.cdss.reactors.HemodynamicRhythmClassificationReactor
Constructs an Reactor 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.arn.Reactor
Actor instance identifier (used in latency tags, classification IDs, etc.).
id - Variable in class com.framed.io.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.reactors.RespiratoryRateEstimationReactor
Section
inputChannels - Variable in class com.framed.arn.Reactor
Input channels this reactor listens to.
Inputs and outputs - Search tag in class com.framed.cdss.reactors.TrendClassificationReactor
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.reactors.RespiratoryRateEstimationReactor
Section
InterpretationReactor - Class in com.framed.cdss.reactors
 
InterpretationReactor(EventBus, String, String, String, String, String, String, String, String, String, String, boolean) - Constructor for class com.framed.cdss.reactors.InterpretationReactor
 
InterpreterUtils - Class in com.framed.cdss.utils
 
InterpreterUtils() - Constructor for class com.framed.cdss.utils.InterpreterUtils
 

J

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

L

lastLogicalFireTs - Variable in class com.framed.arn.Reactor
Last logical timestamp at which this reactor fired.
Latency publishing modes - Search tag in class com.framed.arn.Reactor
Section
Lifecycle - Search tag in class com.framed.core.remote.SocketEventBus
Section
LimitClassificationReactor - Class in com.framed.cdss.reactors
A specialized Reactor that classifies numeric input values per channel based on a configured, ascending-sorted list of upper bounds.
LimitClassificationReactor(EventBus, String, JSONArray, String, JSONArray, JSONArray, boolean) - Constructor for class com.framed.cdss.reactors.LimitClassificationReactor
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
Creates a LocalEventBus with DispatchMode.PER_HANDLER as default.
LocalEventBus(DispatchMode) - Constructor for class com.framed.core.local.LocalEventBus
Creates a LocalEventBus using the given default dispatch mode.
logger - Variable in class com.framed.core.Service
Logger instance for this service, initialized with the class name.
logicalTs() - Method in record class com.framed.arn.Reactor.Snapshot
Returns the value of the logicalTs record component.
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
Loads the configuration, builds the runtime, instantiates services and blocks until shutdown.
Main - Class in com.framed.orchestrator
Config-driven launcher for a FRAMED deployment.
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

N

n() - Method in record class com.framed.arn.FiringRule
Returns the value of the n record component.
NamedThreadFactory - Class in com.framed.io.dispatch
A ThreadFactory that produces daemon threads named <base>-<n>, where n is an incrementing counter.
newThread(Runnable) - Method in class com.framed.io.dispatch.NamedThreadFactory
 
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

onDrop(DataPoint<?>, Throwable) - Method in class com.framed.io.dispatch.Dispatcher
Called when datapoint cannot be queued or pushed.
onDrop(DataPoint<?>, Throwable) - Method in class com.framed.streamer.dispatcher.JsonlDispatcher
 
onHandlerError(String, String, Object, Exception) - Method in class com.framed.io.dispatch.Dispatcher
Called when handler fails before enqueueing (e.g., parse error).
onHandlerError(String, String, Object, Exception) - Method in class com.framed.streamer.dispatcher.JsonlDispatcher
 
Output - Search tag in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor
Section
outputChannels - Variable in class com.framed.arn.Reactor
Output channels this reactor may publish to.

P

PARALLEL - Enum constant in enum class com.framed.core.utils.DispatchMode
Each handler invocation is submitted to a shared thread pool and runs concurrently.
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.python.PythonParser
 
parse(JSONObject) - Static method in class com.framed.io.dispatch.DataPointParser
Converts a JSON bus message into a DataPoint.
parse(T, String) - Method in class com.framed.io.parser.Parser
Parses a raw input message and publishes the resulting events on the event bus.
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(JSONArray) - Static method in class com.framed.cdss.utils.CDSSUtils
 
parseMessage(String) - Static method in class com.framed.core.utils.RemoteUtils
Parses a JSON-encoded remote message into a RemoteMessage.
parsePerChannelIntMap(JSONObject, int) - Static method in class com.framed.cdss.utils.CDSSUtils
 
Parser<T> - Class in com.framed.io.parser
Abstract base for services that turn raw input into events published on the event bus.
Parser(EventBus) - Constructor for class com.framed.io.parser.Parser
Creates a new parser bound to the given event bus.
ParsingUtils - Class in com.framed.communicator.driver.protocol.medibus.utils
 
path - Variable in class com.framed.io.writer.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
Each handler gets its own single-thread executor, preserving per-handler FIFO ordering.
Per-Handler Dispatch Override - Search tag in class com.framed.core.remote.SocketEventBus
Section
Per-handler override - Search tag in class com.framed.core.local.LocalEventBus
Section
Persistence / Debouncing - Search tag in class com.framed.cdss.reactors.TrendClassificationReactor
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.io.protocol
Represents an abstract communication protocol that extends the Service class.
Protocol(String, EventBus) - Constructor for class com.framed.io.protocol.Protocol
Creates a new Protocol instance.
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 (broadcast semantics).
publish(String, Object) - Method in class com.framed.core.remote.SocketEventBus
Publishes a message to all registered peers and dispatches it locally.
publishResult(EventBus, Object, String, List<String>, Instant) - Static method in class com.framed.arn.RuleUtils
Publishes a result envelope (timestamp, className, value, channelID) to each output channel and announces those channels so sinks can discover them.
push(DataPoint<?>) - Method in class com.framed.io.dispatch.Dispatcher
Pushes a single datapoint to the underlying sink.
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.io.dispatch.Dispatcher
Pushes a batch of datapoints to the underlying sink.
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
 
PythonParser - Class in com.framed.communicator.driver.parser.python
 
PythonParser(EventBus, JSONArray) - Constructor for class com.framed.communicator.driver.parser.python.PythonParser
 

R

RawByteWriter - Class in com.framed.communicator.io.raw
 
RawByteWriter(String, EventBus, JSONArray) - Constructor for class com.framed.communicator.io.raw.RawByteWriter
 
reactionFunction(Map<String, Object>) - Method in class com.framed.arn.Reactor
Called once per evaluation cycle when any rule is satisfied.
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.DislocationClassificationReactor
 
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.HemodynamicRhythmClassificationReactor
 
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.InterpretationReactor
 
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.LimitClassificationReactor
Receives a snapshot from the runtime, classifies all channel values via LimitClassificationReactor.checkLimits(Map), and publishes one result message per output channel.
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor
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.
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.RRMismatchClassificationReactor
 
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.SFComputationReactor
 
reactionFunction(Map<String, Object>) - Method in class com.framed.cdss.reactors.TrendClassificationReactor
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.
Reactor - Class in com.framed.arn
A reactive multi-input Service that evaluates a set of firing rules on incoming messages, constructs exactly one consistent snapshot per evaluation cycle, and triggers a user-defined Reactor.reactionFunction(Map) once whenever at least one rule is satisfied.
Reactor(EventBus, String, List<Map<String, String>>, List<String>, List<String>) - Constructor for class com.framed.arn.Reactor
Constructs a rule-based Actor.
Reactor(EventBus, String, List<Map<String, String>>, List<String>, List<String>, boolean) - Constructor for class com.framed.arn.Reactor
Constructs a rule-based reactor.
Reactor.Snapshot - Record Class in com.framed.arn
An immutable evaluation snapshot handed to Reactor.reactionFunction(Map).
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 using the bus default dispatch mode.
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 using the bus-wide default dispatch mode.
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.
register(String, Consumer<Object>, DispatchMode) - Method in interface com.framed.core.EventBus
Registers a handler for the specified address using a specific dispatch strategy.
register(String, Consumer<Object>, DispatchMode) - Method in class com.framed.core.local.LocalEventBus
Registers a handler for the specified address with an optional per-handler dispatch mode override.
register(String, Consumer<Object>, DispatchMode) - Method in class com.framed.core.remote.SocketEventBus
Registers a local handler for the specified address with an optional per-handler dispatch mode override.
REGRESSION_SLOPE - Enum constant in enum class com.framed.cdss.utils.TrendMode
 
RemoteMessage - Record Class in com.framed.core.remote
A decoded message exchanged over a remote transport between event bus instances.
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
Utility methods for parsing and dispatching JSON-encoded remote messages to registered handlers.
removePeer(Peer) - Method in class com.framed.core.remote.SocketEventBus
Removes a remote peer from the event bus.
ReplayProtocol - Class in com.framed.communicator.driver.protocol.replay
A replay protocol that reads either CSV (test_ph.csv) or JSONL files and replays all datapoints in real time into the FRAMED EventBus, using the same publish mechanism as the real PC60FW / Oxylog drivers.
ReplayProtocol(String, EventBus, String, JSONArray) - Constructor for class com.framed.communicator.driver.protocol.replay.ReplayProtocol
 
REQUIRE_VALUE - Enum constant in enum class com.framed.arn.RuleType
Satisfied when a new message has arrived and the latest value equals the configured value.
Respiratory Rate Computation - Search tag in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor
Section
RespiratoryRateEstimationReactor - Class in com.framed.cdss.reactors
Reactor for estimating respiratory rate (RR) from a continuous EtCO₂ waveform using a robust slope‑based breath detection algorithm.
RespiratoryRateEstimationReactor(EventBus, String, String, JSONArray, int, double, double, double, int, boolean, double, boolean, int, double, boolean) - Constructor for class com.framed.cdss.reactors.RespiratoryRateEstimationReactor
Creates a respiratory rate estimator reactor that detects breaths from an EtCO₂ waveform using a robust slope-based algorithm with optional smoothing and outlier suppression.
RRMismatchClassificationReactor - Class in com.framed.cdss.reactors
 
RRMismatchClassificationReactor(EventBus, String, String, String, JSONArray, int, boolean) - Constructor for class com.framed.cdss.reactors.RRMismatchClassificationReactor
 
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.arn
Enumerates the types of channel conditions supported: RuleType.ANY: at least one new message RuleType.AT_LEAST: at least n new messages RuleType.REQUIRE_VALUE: at least one new message and latest value equals value
RuleUtils - Class in com.framed.arn
Runtime helpers shared by Reactor and its concrete implementations: extracting a logical timestamp from an incoming message and publishing a result envelope to a reactor's output channels.

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.reactors.RespiratoryRateEstimationReactor
Section
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 it locally.
sendDeviceID() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
 
SEQUENTIAL - Enum constant in enum class com.framed.core.utils.DispatchMode
All handlers run sequentially, inline on the calling (publishing) thread.
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
 
SFComputationReactor - Class in com.framed.cdss.reactors
 
SFComputationReactor(EventBus, String, String, String, String, boolean) - Constructor for class com.framed.cdss.reactors.SFComputationReactor
 
shutdown() - Method in interface com.framed.core.EventBus
Shutdown method of the EventBus.
shutdown() - Method in class com.framed.core.local.LocalEventBus
Shuts down the event bus and releases resources.
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.
shutdown(Duration) - Method in class com.framed.io.dispatch.Dispatcher
Optional: call this when stopping your service to stop worker thread.
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(Map<String, Object>, Instant) - Constructor for record class com.framed.arn.Reactor.Snapshot
Creates an instance of a Snapshot record class.
Snapshot semantics - Search tag in class com.framed.arn.Reactor
Section
SocketEventBus - Class in com.framed.core.remote
A distributed EventBus implementation backed by 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 bus-wide default dispatch mode.
SOH - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.DataConstants
 
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.io.dispatch.Dispatcher
 
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
 
Supported Local Dispatch Modes - Search tag in class com.framed.core.remote.SocketEventBus
Section
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.arn.Reactor
Section
Thread Safety - Search tag in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor
Section
timeOnStart - Variable in class com.framed.io.writer.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.io.dispatch.DataPoint
Returns the value of the timestamp record component.
toJsonString() - Method in record class com.framed.io.dispatch.DataPoint
Serializes this datapoint to its JSON string representation.
toString() - Method in record class com.framed.arn.FiringRule
Returns a string representation of this record class.
toString() - Method in record class com.framed.arn.Reactor.Snapshot
Returns a string representation of this record class.
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.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.io.dispatch.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.
TrendClassificationReactor - Class in com.framed.cdss.reactors
A specialized Reactor that detects a decreasing trend (downward drift) in numeric channel values using a sliding window and a slope-based metric.
TrendClassificationReactor(EventBus, String, JSONArray, String, JSONArray, int, int, int, String, boolean) - Constructor for class com.framed.cdss.reactors.TrendClassificationReactor
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.reactors.TrendClassificationReactor
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.reactors.RespiratoryRateEstimationReactor
Section
type() - Method in record class com.framed.arn.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.orchestrator.Manager
Section

V

v() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
Returns the value of the v record component.
validate() - Method in class com.framed.orchestrator.Manager
Runs all DeploymentValidators discovered on the classpath against the set of instantiated services.
validate(Collection<Service>) - Method in class com.framed.arn.ARN
Filters the deployed services down to Reactors and validates that they form an acyclic network.
validate(Collection<Service>) - Method in interface com.framed.core.spi.DeploymentValidator
Validates the set of instantiated services.
validateCommunicationConfigs(JSONObject) - Static method in class com.framed.orchestrator.ConfigLoader
Validates communication configurations.
validateServiceConfigs(JSONObject) - Static method in class com.framed.orchestrator.ConfigLoader
Validates service instantiation configurations.
value() - Method in record class com.framed.arn.FiringRule
Returns the value of the value record component.
value() - Method in record class com.framed.io.dispatch.DataPoint
Returns the value of the value record component.
valueMatchesExpected(Object, String) - Method in class com.framed.arn.Reactor
Default equality check for the "r:v" (REQUIRE_VALUE) token: compares the latest value's string form against the expected value.
valueOf(String) - Static method in enum class com.framed.arn.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() - Method in record class com.framed.arn.Reactor.Snapshot
Returns the value of the values record component.
values() - Static method in enum class com.framed.arn.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.

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.io.writer.Writer
Writes the given data to the configured path.
Writer<T> - Class in com.framed.io.writer
An abstract base class for writing data of type T to a specified file path.
Writer(String, EventBus) - Constructor for class com.framed.io.writer.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