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
- 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. - 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
addressis an output channel of the producergroup, so that sinks subscribed toService.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
nnew 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
Boundsrecord class.
C
- CDSSUtils - Class in com.framed.cdss.utils
- channelID() - Method in record class com.framed.io.dispatch.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.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
classNamerecord 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
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.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
DataPointrecord 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
deviceIDrecord 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
Reactorthat subscribes to the giveninputChannels, evaluates the providedfiringRules, and optionally exposesoutputChannels. - 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
Factoryclass provides dynamic instantiation ofServiceimplementations 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
FiringRulerecord 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
Reactorthat 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.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
Serviceimplementation 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
Reactorthat 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
EventBusinterface 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_HANDLERas 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
logicalTsrecord component. - 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
-
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
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
N
- n() - Method in record class com.framed.arn.FiringRule
-
Returns the value of the
nrecord component. - NamedThreadFactory - Class in com.framed.io.dispatch
- newThread(Runnable) - Method in class com.framed.io.dispatch.NamedThreadFactory
- 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
- 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
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
-
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
portrecord component. - Protocol - Class in com.framed.io.protocol
-
Represents an abstract communication protocol that extends the
Serviceclass. - 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
Servicethat evaluates a set of firing rules on incoming messages, constructs exactly one consistent snapshot per evaluation cycle, and triggers a user-definedReactor.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
RemoteMessagerecord 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 messageRuleType.AT_LEAST: at leastnnew messagesRuleType.REQUIRE_VALUE: at least one new message and latest value equalsvalue - RuleUtils - Class in com.framed.arn
-
Runtime helpers shared by
Reactorand 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
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.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
- 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
Snapshotrecord class. - Snapshot semantics - Search tag in class com.framed.arn.Reactor
- 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 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
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.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
timestamprecord 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
Reactorthat 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
TrendClassifierthat 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 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.reactors.RespiratoryRateEstimationReactor
- Section
- type() - Method in record class com.framed.arn.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.orchestrator.Manager
- Section
V
- v() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample
-
Returns the value of the
vrecord 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
valuerecord component. - value() - Method in record class com.framed.io.dispatch.DataPoint
-
Returns the value of the
valuerecord 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
valuesrecord 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
Tto a specified file path. - Writer(String, EventBus) - Constructor for class com.framed.io.writer.Writer
-
Creates a new Writer instance.
All Classes and Interfaces|All Packages|Constant Field Values
