Index (FRAMED API)

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

A

AA - Static variable in class com.framed.interop.hl7.hl7v2.AckBuilder: Application Accept.
accept(String, String, String, Object, Instant) - Method in interface com.framed.interop.hl7.ObservationSink: Accepts one decoded observation.
achievedHz() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the achievedHz record component.
achievedHz() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the achievedHz record component.
achievedHz() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the achievedHz record component.
AckBuilder - Class in com.framed.interop.hl7.hl7v2: Builds HL7 v2 general acknowledgement (ACK) messages in response to a received message.
ACTIVE - Enum constant in enum class com.framed.communicator.driver.protocol.medibus.utils.MedibusState
adc(int, long) - Method in class com.framed.communicator.driver.protocol.mimic.WfdbSegmentReader: Decodes the raw ADC value of signal signalIndex in frame frame.
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.
AE - Static variable in class com.framed.interop.hl7.hl7v2.AckBuilder: Application Error.
ALARM_RESPONSE_CP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
ALARM_RESPONSE_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
Algorithm Overview - Search tag in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor: Section
allow(String, Object, long) - Method in class com.framed.interop.gate.EmissionGate: Convenience for infallible emissions: checks and, when allowed, immediately commits.
allows(String, Object, long) - Method in class com.framed.interop.gate.EmissionGate: Checks whether value on key may be emitted now, without recording anything.
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 via Service.subscribeToAnnouncements(String, Consumer) 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.
AR - Static variable in class com.framed.interop.hl7.hl7v2.AckBuilder: Application Reject.
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.
awaitCompletion(Duration) - Method in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Blocks until the replay has published its last event.
awaitQuiescence(Duration, Duration) - Method in class com.framed.streamer.dispatcher.CountingDispatcher: Blocks until the sink has been idle for quietPeriod, i.e. until the push queue has drained.

B

baseline() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the baseline record component.
baseTime() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
BOFCOMCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
BOFRESPCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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.
build(Hl7Message, String, String, Instant) - Static method in class com.framed.interop.hl7.hl7v2.AckBuilder: Builds an ACK echoing the control id of the incoming message, with sender/receiver swapped.
build(SendingIds, PatientContext, CodedConcept, String, Instant, String) - Static method in class com.framed.interop.hl7.hl7v2.OruBuilder: Builds an ORU^R01 carrying a single observation.
build(SendingIds, PatientContext, List<OruBuilder.Observation>, Instant, String) - Static method in class com.framed.interop.hl7.hl7v2.OruBuilder: Builds an ORU^R01 carrying one or more observations (one OBX each, stamped with its own observation time in OBX-14).
byteOffset() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the byteOffset record component.

C

CARRIAGE_RETURN - Static variable in class com.framed.interop.hl7.mllp.MllpCodec: Trailing carriage return (0x0D).
CDSSUtils - Class in com.framed.cdss.utils
Channel(String, String, String) - Constructor for record class com.framed.interop.mapping.ObservationMapping.Channel: Creates an instance of a Channel record class.
channelForCode(String) - Method in class com.framed.interop.mapping.ObservationMapping: Reverse-maps an incoming code to the FRAMED channel it should be published under.
channelID() - Method in record class com.framed.interop.mapping.ObservationMapping.Channel: Returns the value of the channelID record component.
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.interop.mapping.ObservationMapping.Channel: Returns the value of the className record component.
className() - Method in record class com.framed.io.dispatch.DataPoint: Returns the value of the className record component.
close() - Method in class com.framed.interop.hl7.mllp.MllpClient
close() - Method in class com.framed.interop.hl7.mllp.MllpServer
close() - Method in interface com.framed.interop.mqtt.MqttTransport: Closes the connection and releases resources.
close() - Method in class com.framed.interop.mqtt.PahoMqttTransport
code() - Method in record class com.framed.communicator.driver.protocol.medibus.utils.MedibusParam: Returns the value of the code record component.
code() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the code record component.
CodedConcept - Record Class in com.framed.interop.mapping: A coded clinical concept: how a FRAMED channel is identified in an interoperability standard.
CodedConcept(String, String, String, String, String) - Constructor for record class com.framed.interop.mapping.CodedConcept: Convenience constructor for concepts without SDC attributes (mdc empty, kind CodedConcept.Kind.METRIC).
CodedConcept(String, String, String, String, String, String, CodedConcept.Kind) - Constructor for record class com.framed.interop.mapping.CodedConcept: Defaults a blank valueType to "NM", a null system to "LOINC", a null mdc to empty and a null kind to CodedConcept.Kind.METRIC.
CodedConcept.Kind - Enum Class in com.framed.interop.mapping: Channel kind at the SDC boundary (mapping JSON field kind, lowercase).
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.mimic - package com.framed.communicator.driver.protocol.mimic
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.interop.gate - package com.framed.interop.gate
com.framed.interop.hl7 - package com.framed.interop.hl7
com.framed.interop.hl7.hl7v2 - package com.framed.interop.hl7.hl7v2
com.framed.interop.hl7.mllp - package com.framed.interop.hl7.mllp
com.framed.interop.mapping - package com.framed.interop.mapping
com.framed.interop.mqtt - package com.framed.interop.mqtt
com.framed.interop.sdc - package com.framed.interop.sdc
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
commit(String, Object, long) - Method in class com.framed.interop.gate.EmissionGate: Records a completed emission of value on key: both filters' state at once (EmissionGate.commitAttempt(java.lang.String, long) + EmissionGate.commitValue(java.lang.String, java.lang.Object)).
commitAttempt(String, long) - Method in class com.framed.interop.gate.EmissionGate: Records an emission attempt on key: only the interval filter's state.
commitValue(String, Object) - Method in class com.framed.interop.gate.EmissionGate: Records a delivered value on key: only the onChange filter's state.
components(String) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Escape: Escapes each ^-separated component of an already component-structured value (e.g. a configured PV1-3 location such as "ICU^01^A"), preserving the component separators themselves.
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
concept() - Method in record class com.framed.interop.hl7.hl7v2.OruBuilder.Observation: Returns the value of the concept record component.
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 keys - Search tag in class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Section
Configuration keys - Search tag in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Section
Configuration keys - Search tag in class com.framed.streamer.dispatcher.CountingDispatcher: Section
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.mimic.MimicReplayProtocol
connect() - Method in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Starts the replay on its own thread; a second call while one is running does nothing.
connect() - Method in class com.framed.interop.hl7.Hl7v2Protocol
connect() - Method in interface com.framed.interop.mqtt.MqttTransport: Establishes the broker connection.
connect() - Method in class com.framed.interop.mqtt.PahoMqttTransport
connect() - Method in class com.framed.io.protocol.Protocol: Establishes a connection using the specific protocol implementation and starts the configured data export.
Connection model - Search tag in class com.framed.core.remote.NioTcpTransport: Section
controlId() - Method in class com.framed.interop.hl7.hl7v2.Hl7Message
Core semantics - Search tag in class com.framed.arn.Reactor: Section
CountingDispatcher - Class in com.framed.streamer.dispatcher: A sink that performs no I/O and only counts what reaches it — the measurement instrument for throughput and latency benchmarks.
CountingDispatcher(EventBus, JSONArray, JSONArray) - Constructor for class com.framed.streamer.dispatcher.CountingDispatcher: Creates a counting sink bound to the announced channels of the given devices.
CountingDispatcher.Snapshot - Record Class in com.framed.streamer.dispatcher: Immutable view of one measurement run.
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.ProtocolMap
DATA_RESPONSE_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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
decode(byte[]) - Static method in class com.framed.interop.mqtt.MqttCodec: Decodes a JSON payload.
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.
description() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the description record component.
DEV_ID_REQUEST - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
DEV_ID_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
deviceID() - Method in record class com.framed.interop.mapping.ObservationMapping.Channel: Returns the value of the deviceID record component.
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
display() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the display record component.
dob() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the dob record component.
DOWN - Enum constant in enum class com.framed.cdss.utils.TrendDirection
dropped() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the dropped record component.

E

EmissionGate - Class in com.framed.interop.gate: Per-key outbound emission throttle.
EmissionGate(boolean, long) - Constructor for class com.framed.interop.gate.EmissionGate
EMPTY - Static variable in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: The figures of a replay that has not published anything yet.
encode(DataPoint<?>, CodedConcept) - Static method in class com.framed.interop.mqtt.MqttCodec: Encodes a datapoint (with optional coded concept) to a JSON payload.
END_BLOCK - Static variable in class com.framed.interop.hl7.mllp.MllpCodec: End-of-block marker (file separator, 0x1C).
ENDOFTEXT - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
EOFCHAR - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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.communicator.driver.protocol.medibus.utils.MedibusParam: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: 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.interop.hl7.hl7v2.OruBuilder.Observation: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.interop.mapping.CodedConcept: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.framed.interop.mapping.ObservationMapping.Channel: 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.
equals(Object) - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: 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.
events() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the events record component.
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
field(String) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Escape: Escapes all reserved characters, for data that occupies a whole field or component: \ -> \E\, | -> \F\, ^ -> \S\, ~ -> \R\, & -> \T\, and the segment/line breaks CR -> \X0D\, LF -> \X0A\ (hex escape, §2.7.4).
field(String[], String, int) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Message: Returns field n of a specific segment instance, honouring the MSH offset.
field(String, int) - Method in class com.framed.interop.hl7.hl7v2.Hl7Message: Returns field n of the first id segment, honouring the MSH offset.
fileName() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the fileName record component.
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.
firstComponent(String) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Message
firstName() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the firstName record component.
format() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the format record component.
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.
frame(String) - Static method in class com.framed.interop.hl7.mllp.MllpCodec: Frames an HL7 message for MLLP transport.
frames() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the frames record component.
framesBehind() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the framesBehind record component.
fromJson(JSONObject) - Static method in record class com.framed.interop.hl7.hl7v2.PatientContext: Builds a context from a config JSON object, defaulting missing fields to empty/UNKNOWN.
fromJson(JSONObject) - Static method in record class com.framed.interop.hl7.hl7v2.SendingIds: Builds from a config JSON object, defaulting to FRAMED/HIS identifiers.
fromJson(JSONObject) - Static method in class com.framed.interop.mapping.ObservationMapping: Builds a mapping from an already-parsed JSON object (testing-friendly).

G

gain() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the gain record component.
gap() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Returns the value of the gap record component.
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.
getPort() - Method in class com.framed.interop.hl7.Hl7v2Protocol
getPort() - Method in class com.framed.interop.hl7.mllp.MllpServer
getRealtimeConfigMessage(List<Byte>, List<Byte>, String) - Static method in class com.framed.communicator.driver.protocol.medibus.utils.DataUtils

H

handle(String) - Method in class com.framed.interop.hl7.InboundRouter: Handles one raw HL7 message.
handleEventBus(Object, String) - Method in class com.framed.communicator.io.parsed.MedibusParsedWriter
handleEventBus(Object, String) - Method in class com.framed.communicator.io.raw.RawByteWriter
handlerErrors() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the handlerErrors record component.
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.communicator.driver.protocol.medibus.utils.MedibusParam: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: 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.interop.hl7.hl7v2.OruBuilder.Observation: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.interop.mapping.CodedConcept: Returns a hash code value for this object.
hashCode() - Method in record class com.framed.interop.mapping.ObservationMapping.Channel: 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.
hashCode() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: 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
Hl7Escape - Class in com.framed.interop.hl7.hl7v2: HL7 v2 escaping of reserved characters (HL7 v2.5 §2.7), for embedding free-form data into message fields built with the default encoding characters (|^~\&).
Hl7Message - Class in com.framed.interop.hl7.hl7v2: A lightweight, read-oriented HL7 v2 pipe-encoded message: a list of segments, each split into fields on |.
Hl7v2Dispatcher - Class in com.framed.interop.hl7: Outbound HL7 v2 sink: maps FRAMED datapoints to ORU^R01 messages and sends them over MLLP to a remote endpoint, retrying on transient failures via the Dispatcher base.
Hl7v2Dispatcher(EventBus, JSONArray, String, int, String, JSONObject, JSONObject, JSONObject) - Constructor for class com.framed.interop.hl7.Hl7v2Dispatcher
Hl7v2Protocol - Class in com.framed.interop.hl7: Inbound HL7 v2 source: runs an MLLP server, parses received ORU/ADT messages and publishes their observations onto the bus in the standard "<className>.<deviceID>.<channelID>.parsed" convention, so existing reactors and dispatchers consume external data transparently.
Hl7v2Protocol(String, EventBus, int, String, String, boolean) - Constructor for class com.framed.interop.hl7.Hl7v2Protocol
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.ProtocolMap
ICC_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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.
id() - Method in record class com.framed.communicator.driver.protocol.medibus.utils.MedibusParam: Returns the value of the id record component.
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
InboundRouter - Class in com.framed.interop.hl7: Parses inbound HL7 messages and routes their content onto the FRAMED bus as EAV observations, returning the HL7 acknowledgement to send back.
InboundRouter(ObservationMapping, ObservationSink, String, boolean) - Constructor for class com.framed.interop.hl7.InboundRouter
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
isMultiSegment() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
isNumeric() - Method in record class com.framed.interop.mapping.CodedConcept
isWaveform() - Method in record class com.framed.interop.mapping.CodedConcept

J

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

K

keptPace() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns true if the producer held its schedule: at least 98 % of the target rate was achieved and no frame missed its slot by more than one frame period.
keyFor(String, String) - Static method in class com.framed.interop.gate.EmissionGate: The canonical device-scoped emission key (see class doc).
kind() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the kind record component.

L

label() - Method in record class com.framed.communicator.driver.protocol.medibus.utils.MedibusParam: Returns the value of the label record component.
lastLogicalFireTs - Variable in class com.framed.arn.Reactor: Last logical timestamp at which this reactor fired.
lastName() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the lastName record component.
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.
load(Path) - Static method in class com.framed.interop.mapping.ObservationMapping: Loads a mapping from the given JSON file.
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.
location() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the location record component.
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.
lookup(String, String, String) - Method in class com.framed.interop.mapping.ObservationMapping: Looks up the concept for a FRAMED channel, most-specific key first.
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.
maxLagMillis() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the maxLagMillis record component.
maxLagMs() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the maxLagMs record component.
maxLatencyMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the maxLatencyMillis record component.
mdc() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the mdc record component.
MEAN_STEP_DIFF - Enum constant in enum class com.framed.cdss.utils.TrendMode
meanLagMillis() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the meanLagMillis record component.
meanLagMs() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the meanLagMs record component.
meanLatencyMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the meanLatencyMillis record component.
MedibusFramer - Class in com.framed.communicator.driver.protocol.medibus
MedibusFramer(Consumer<byte[]>, EventBus, String) - Constructor for class com.framed.communicator.driver.protocol.medibus.MedibusFramer
MedibusParam - Record Class in com.framed.communicator.driver.protocol.medibus.utils: A single Medibus(.X) protocol parameter: the mapping from a one-byte protocol code to a stable, address-safe channel identifier plus human-readable metadata.
MedibusParam(byte, String, String, String) - Constructor for record class com.framed.communicator.driver.protocol.medibus.utils.MedibusParam: Creates an instance of a MedibusParam record class.
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.ProtocolMap: Alarm event catalog, code page 1 (ids are slugs of the alarm text).
MedibusXAlarmsCP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Alarm event catalog, code page 2.
MedibusXDeviceSettings - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Device setting parameters.
MedibusXMeasurementCP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Numeric measurement parameters from code page 1 (keyed by Medibus data code).
MedibusXMeasurementCP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Numeric measurement parameters from code page 2.
MedibusXRealTimeData - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Real-time (waveform) data channels.
MedibusXTextMessages - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap: Text/status message catalog (ids are slugs of the message text).
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
messageType() - Method in class com.framed.interop.hl7.hl7v2.Hl7Message
METRIC - Enum constant in enum class com.framed.interop.mapping.CodedConcept.Kind: A discrete measurement (BICEPS metric category MSRMT).
MimicReplayProtocol - Class in com.framed.communicator.driver.protocol.mimic: Replays a MIMIC-III Waveform Database record into the FRAMED EventBus in (scaled) real time, exercising the normal, non-interop data path: each decoded sample is published as a parsed DataPoint message on an address of the shape "<className>.<deviceID>.<channelID>.parsed", exactly as the live device drivers do.
MimicReplayProtocol(String, EventBus, String, String, String, JSONArray, double, double) - Constructor for class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Creates a MIMIC replay protocol.
MimicReplayProtocol.PacingStats - Record Class in com.framed.communicator.driver.protocol.mimic: Immutable summary of how closely replay followed its schedule.
MllpClient - Class in com.framed.interop.hl7.mllp: MLLP client (the message initiator): connects to a remote MLLP endpoint, sends a framed HL7 message and reads back the framed acknowledgement.
MllpClient(String, int, int) - Constructor for class com.framed.interop.hl7.mllp.MllpClient
MllpCodec - Class in com.framed.interop.hl7.mllp: Minimal Lower Layer Protocol (MLLP) framing.
MllpServer - Class in com.framed.interop.hl7.mllp: MLLP server (the message responder): listens for connections, reads each framed HL7 message and replies with the acknowledgement produced by the supplied handler.
MllpServer(int, UnaryOperator<String>) - Constructor for class com.framed.interop.hl7.mllp.MllpServer: Binds and starts accepting connections immediately.
MqttCodec - Class in com.framed.interop.mqtt: Encodes/decodes the self-describing JSON payload carried on MQTT.
MqttService - Class in com.framed.interop.mqtt: Bidirectional MQTT bridge.
MqttService(EventBus, String, String, String, JSONArray, JSONArray, String, int, String, JSONObject, boolean, String) - Constructor for class com.framed.interop.mqtt.MqttService: Config-loadable constructor.
MqttTransport - Interface in com.framed.interop.mqtt: Minimal MQTT transport abstraction used by MqttService.
mrn() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the mrn record component.

N

n() - Method in record class com.framed.arn.FiringRule: Returns the value of the n record component.
name() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Returns the value of the name 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.ProtocolMap
NOP_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
numFrames() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbSegmentReader
numSamples() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Returns the value of the numSamples record component.
numSamplesPerSignal() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
numSignals() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbSegmentReader

O

Observation(CodedConcept, String, Instant) - Constructor for record class com.framed.interop.hl7.hl7v2.OruBuilder.Observation: Creates an instance of a Observation record class.
ObservationMapping - Class in com.framed.interop.mapping: Bidirectional mapping between FRAMED channels and CodedConcepts, loaded from a JSON file.
ObservationMapping.Channel - Record Class in com.framed.interop.mapping: A resolved FRAMED channel coordinate decoded from a mapping key.
ObservationSink - Interface in com.framed.interop.hl7: Sink for observations decoded from inbound HL7, expressed in FRAMED's EAV coordinates.
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.CountingDispatcher: Counts the drop instead of printing it.
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.CountingDispatcher: Counts the failure instead of printing a stack trace, for the same reason as CountingDispatcher.onDrop(com.framed.io.dispatch.DataPoint<?>, java.lang.Throwable).
onHandlerError(String, String, Object, Exception) - Method in class com.framed.streamer.dispatcher.JsonlDispatcher
onReplayComplete() - Method in class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Invoked once the whole record (or maxSeconds of it) has been replayed.
open(Path, List<WfdbSignal>, long) - Static method in class com.framed.communicator.driver.protocol.mimic.WfdbSegmentReader: Opens the .dat file for a segment described by signals.
OruBuilder - Class in com.framed.interop.hl7.hl7v2: Builds ORU^R01 (unsolicited observation result) HL7 v2.5 messages from FRAMED observations.
OruBuilder.Observation - Record Class in com.framed.interop.hl7.hl7v2: A single observation to encode as an OBX segment.
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

p50LagMillis() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the p50LagMillis record component.
p50LatencyMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the p50LatencyMillis record component.
p95LagMillis() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the p95LagMillis record component.
p95LatencyMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the p95LatencyMillis record component.
p99LatencyMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the p99LatencyMillis record component.
Pacing statistics - Search tag in class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Section
pacingStats() - Method in class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Returns a snapshot of the replay's pacing fidelity — how well the producer held the configured sample rate.
PacingStats(long, long, double, double, long, double, long, long, long, long) - Constructor for record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Creates an instance of a PacingStats record class.
PahoMqttTransport - Class in com.framed.interop.mqtt: MqttTransport backed by the Eclipse Paho MQTT 3.1.1 asynchronous client.
PahoMqttTransport(String, String) - Constructor for class com.framed.interop.mqtt.PahoMqttTransport
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(String) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Message: Parses a raw HL7 message.
parse(Path) - Static method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader: Parses the header file at path.
parse(List<String>) - Static method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader: Parses header content already read into lines.
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
passthrough() - Static method in class com.framed.interop.gate.EmissionGate: A pass-through gate that never suppresses.
path - Variable in class com.framed.io.writer.Writer: The file system path where data will be written.
PatientContext - Record Class in com.framed.interop.hl7.hl7v2: Static patient/encounter context used to populate the PID/PV1 segments of outbound messages.
PatientContext(String, String, String, String, String, String) - Constructor for record class com.framed.interop.hl7.hl7v2.PatientContext: Creates an instance of a PatientContext record class.
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.
perChannel() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the perChannel record component.
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_RT_TRANSMISSION - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_ALARMS_CP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_ALARMS_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_DATE_TIME - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_DEVICE_ID - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_DEVICE_SETTINGS - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_ICC - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_MEASURED_DATA_CP1 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_MEASURED_DATA_CP2 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_NOP - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_RT_CONFIG_CHANGED - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_RT_DATA_CONFIG - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_STOP_COM - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
POLL_REQUEST_TEXT_MESSAGES - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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.
ProtocolMap - Class in com.framed.communicator.driver.protocol.medibus.utils
publish(String, byte[], int) - Method in interface com.framed.interop.mqtt.MqttTransport: Publishes a message.
publish(String, byte[], int) - Method in class com.framed.interop.mqtt.PahoMqttTransport
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.
publishedEvents() - Method in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Returns how many events have been published so far.
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.interop.hl7.Hl7v2Dispatcher
push(DataPoint<?>) - Method in class com.framed.interop.sdc.SdcProviderDispatcher
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.CountingDispatcher
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.interop.hl7.Hl7v2Dispatcher
pushBatch(List<DataPoint<?>>) - Method in class com.framed.interop.sdc.SdcProviderDispatcher
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.CountingDispatcher
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).
readMessage(InputStream) - Static method in class com.framed.interop.hl7.mllp.MllpCodec: Reads a single MLLP-framed message from a stream, blocking until a full frame arrives.
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
received() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the received record component.
receivingApp() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns the value of the receivingApp record component.
receivingFacility() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns the value of the receivingFacility record component.
recordName() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
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.
Repetition - Search tag in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Section
Replay clock - Search tag in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Section
ReplayProtocol - Class in com.framed.communicator.driver.protocol.replay: Replays a recorded .jsonl session onto the event bus, on the parsed addresses the original parsers used.
ReplayProtocol(String, EventBus, String, JSONArray, JSONArray, double, int, double, double, boolean) - Constructor for class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Creates a replay of filePath.
ReplayProtocol.ReplayStats - Record Class in com.framed.communicator.driver.protocol.replay: Figures describing one completed replay: how much was published, how fast, and how far behind its own schedule the replay thread ran.
ReplayStats(long, double, double, double, double, long) - Constructor for record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Creates an instance of a ReplayStats record class.
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.
reset() - Method in class com.framed.streamer.dispatcher.CountingDispatcher: Discards everything counted so far, as if the sink had just been constructed.
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.ProtocolMap
RT_BYTE_MASK - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
RT_CONFIG_CHANGED - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
RT_CONFIG_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
RT_TRANSMISSION_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
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.
samples() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the samples record component.
samplingFrequency() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
SC_CORRUPT_DATA - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_DATASTREAM_1_4 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_DATASTREAM_5_8 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_DATASTREAM_9_12 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_END_OF_SEQUENCE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_START_CYCLE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_TX_DATASTREAM_5_8 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SC_TX_DATASTREAM_9_12 - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SdcProviderDispatcher - Class in com.framed.interop.sdc: Outbound IEEE 11073 SDC sink (SdcProviderDispatcher, INTEROP_PLAN Step 3 Phase B): exposes FRAMED as a BICEPS provider whose MDIB mirrors the mapped channels, so any SDC consumer can discover the device over WS-Discovery, read the MDIB and subscribe to episodic metric reports and waveform streams (MDPWS/WS-Eventing, via SDCri).
SdcProviderDispatcher(EventBus, JSONArray, String, String, String, double, double, JSONObject) - Constructor for class com.framed.interop.sdc.SdcProviderDispatcher: Config-loadable constructor.
See Also - Search tag in class com.framed.cdss.reactors.RespiratoryRateEstimationReactor: Section
segment(String) - Method in class com.framed.interop.hl7.hl7v2.Hl7Message
Segment(String, long, boolean) - Constructor for record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Creates an instance of a Segment record class.
segments() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
segments(String) - Method in class com.framed.interop.hl7.hl7v2.Hl7Message
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.
sendAndReceive(String) - Method in class com.framed.interop.hl7.mllp.MllpClient: Sends an HL7 message and returns the acknowledgement message.
sendDeviceID() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
sendingApp() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns the value of the sendingApp record component.
sendingFacility() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns the value of the sendingFacility record component.
SendingIds - Record Class in com.framed.interop.hl7.hl7v2: The MSH sending/receiving application and facility identifiers (MSH-3..MSH-6).
SendingIds(String, String, String, String) - Constructor for record class com.framed.interop.hl7.hl7v2.SendingIds: Creates an instance of a SendingIds record class.
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.
SETTING - Enum constant in enum class com.framed.interop.mapping.CodedConcept.Kind: A device setting (BICEPS metric category SET).
SETTINGS_RESPONSE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
sex() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns the value of the sex record component.
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.
signals() - Method in class com.framed.communicator.driver.protocol.mimic.WfdbHeader
size() - Method in class com.framed.interop.mapping.ObservationMapping
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() - Method in class com.framed.streamer.dispatcher.CountingDispatcher: Returns a consistent snapshot of everything counted so far.
Snapshot(long, long, long, Map<String, Long>, long, double, double, long, long, long, long) - Constructor for record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Creates an instance of a Snapshot record class.
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.ProtocolMap
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.
START_BLOCK - Static variable in class com.framed.interop.hl7.mllp.MllpCodec: Start-of-block marker (vertical tab, 0x0B).
startupDelayMillis() - Method in class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol: Milliseconds to wait after construction before replay begins, giving sinks and reactors time to be instantiated and to subscribe.
stats() - Method in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Returns how much the replay published and how well it held its schedule.
stop() - Method in class com.framed.communicator.driver.protocol.medibus.MedibusProtocol
stop() - Method in class com.framed.communicator.driver.protocol.replay.ReplayProtocol: Interrupts the replay thread; does not wait for it to finish.
stop() - Method in class com.framed.core.Service: Stops the service.
stop() - Method in class com.framed.interop.hl7.Hl7v2Dispatcher
stop() - Method in class com.framed.interop.hl7.Hl7v2Protocol
stop() - Method in class com.framed.interop.mqtt.MqttService
stop() - Method in class com.framed.interop.sdc.SdcProviderDispatcher
stop() - Method in class com.framed.io.dispatch.Dispatcher
stop() - Method in class com.framed.streamer.dispatcher.CountingDispatcher: Prints the run summary, then stops the push worker.
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
subscribe(String, int, BiConsumer<String, byte[]>) - Method in interface com.framed.interop.mqtt.MqttTransport: Subscribes to a topic filter, delivering matching messages to handler as (topic, payload).
subscribe(String, int, BiConsumer<String, byte[]>) - Method in class com.framed.interop.mqtt.PahoMqttTransport
subscribeToAnnouncements(String, Consumer<String>) - Method in class com.framed.core.Service: Subscribes to group's address-discovery topic, so this service learns each output channel the producer announces and can bind a handler to it.
Supported Local Dispatch Modes - Search tag in class com.framed.core.remote.SocketEventBus: Section
swapped() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds
SYNC_BYTE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SYNC_CMD_BYTE - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
SYNC_MASK - Static variable in class com.framed.communicator.driver.protocol.medibus.utils.ProtocolMap
system() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the system record component.

T

t() - Method in record class com.framed.cdss.utils.SlopeUtils.Sample: Returns the value of the t record component.
targetHz() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the targetHz record component.
targetHz() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the targetHz 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.ProtocolMap
Threading - Search tag in class com.framed.core.remote.NioTcpTransport: Section
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.interop.hl7.hl7v2.OruBuilder.Observation: Returns the value of the timestamp record component.
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.
toPhysical(int) - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Converts a raw ADC sample to its physical value using (adc - baseline) / gain.
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.communicator.driver.protocol.medibus.utils.MedibusParam: Returns a string representation of this record class.
toString() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns a string representation of this record class.
toString() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbHeader.Segment: Returns a string representation of this record class.
toString() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns a string representation of this record class.
toString() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: 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.interop.hl7.hl7v2.OruBuilder.Observation: Returns a string representation of this record class.
toString() - Method in record class com.framed.interop.hl7.hl7v2.PatientContext: Returns a string representation of this record class.
toString() - Method in record class com.framed.interop.hl7.hl7v2.SendingIds: Returns a string representation of this record class.
toString() - Method in record class com.framed.interop.mapping.CodedConcept: Returns a string representation of this record class.
toString() - Method in record class com.framed.interop.mapping.ObservationMapping.Channel: 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.
toString() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: 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.
uncalibrated() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Whether this signal is uncalibrated (WFDB gain 0).
unescape(String) - Static method in class com.framed.interop.hl7.hl7v2.Hl7Escape: Decodes the escape sequences produced by Hl7Escape.field(java.lang.String) (delimiter escapes \E\ \F\ \S\ \R\ \T\ and hex escapes \Xhh..\) back to the original text.
unit() - Method in record class com.framed.communicator.driver.protocol.medibus.utils.MedibusParam: Returns the value of the unit record component.
unit() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the unit record component.
units() - Method in record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Returns the value of the units record component.
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.interop.hl7.hl7v2.OruBuilder.Observation: 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.
valueOf(String) - Static method in enum class com.framed.interop.mapping.CodedConcept.Kind: 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.
values() - Static method in enum class com.framed.interop.mapping.CodedConcept.Kind: Returns an array containing the constants of this enum class, in the order they are declared.
valueType() - Method in record class com.framed.interop.mapping.CodedConcept: Returns the value of the valueType record component.

W

wallElapsedMillis() - Method in record class com.framed.communicator.driver.protocol.mimic.MimicReplayProtocol.PacingStats: Returns the value of the wallElapsedMillis record component.
wallElapsedMillis() - Method in record class com.framed.streamer.dispatcher.CountingDispatcher.Snapshot: Returns the value of the wallElapsedMillis record component.
wallSeconds() - Method in record class com.framed.communicator.driver.protocol.replay.ReplayProtocol.ReplayStats: Returns the value of the wallSeconds record component.
WAVEFORM - Enum constant in enum class com.framed.interop.mapping.CodedConcept.Kind: A high-rate waveform (BICEPS real-time sample array); HL7/MQTT skip these.
WfdbHeader - Class in com.framed.communicator.driver.protocol.mimic: A parsed WFDB header (.hea) file, covering the three header flavours used by the MIMIC-III Waveform Database: Master (multi-segment) header — its record line carries a /numSegments suffix and it lists one WfdbHeader.Segment per line instead of signal specifications.
WfdbHeader.Segment - Record Class in com.framed.communicator.driver.protocol.mimic: A segment reference on a master (multi-segment) header line.
WfdbSegmentReader - Class in com.framed.communicator.driver.protocol.mimic: Decodes the raw ADC samples of a single WFDB segment from its .dat file.
WfdbSignal - Record Class in com.framed.communicator.driver.protocol.mimic: The specification of a single signal, as declared on one signal-specification line of a WFDB header file.
WfdbSignal(String, int, int, double, int, String, String) - Constructor for record class com.framed.communicator.driver.protocol.mimic.WfdbSignal: Creates an instance of a WfdbSignal record class.
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 K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values