Add MQTT message to the buffer as a StreamMessage. :param MQTTMessage msg: MQTT message to add to buffer

Make a GET request to the C++ application.

Return a rule by ID, or ``None`` if not found. Raises: PersistenceError: on backend failure.

@brief applies a JSON patch to a copy of the current object @sa https://json.nlohmann.me/api/basic_json/patch/

* Check whether the instrumentation scope has given name and version. * This could be used to check version equality and avoid heap allocation.

Return True if the document exists.

Split the stream Returns: Boolean indicating if the split was successful or an error was encountered.

Make a POST request to the C++ application.

deletes the retrieved element, do not use for non integral types

@brief return the type of the JSON value (explicit) @sa https://json.nlohmann.me/api/basic_json/type/

* returns the database name. * @public * @returns {string} * @example * const mdx = require("@nvidia-mdx/web-api-core"); * co

Parse raw VLM response text into a flat key-value dictionary. Args: raw_response: The complete text returned by the VLM.

Write StreamMessage objects with serialization Args: messages: List of StreamMessage objects to serialize and write

Run non-blocking sleep on runtime loop (for async retry path).

* getParam(const std::string &, const char *, std::string &, size_t) * * Returns a query parameter contained in the supplied buffer. The * occu

* Finds sensor IDs associated with a rounded world-coordinate lookup within a place. * @public * @async * @param {Database} documentDb

* @return Returns a vector of unique pointers containing all the data in the * CircularBuffer. This operation will empty the Buffer, which is why t

! @brief internal implementation of the serialization function This function is called by the public member function dump and organizes t

Get the value if we know the key from AppConfig.app. :param str key: Key to look up :param str default_value: Defaul

Encode text into embedding vector. Args: text: Text to encode Returns: Embedding vector as numpy ar

Parse VLM response based on *response_format* (or auto-detected model type). Supported formats: - ``"auto"`` -- detect from

* returns the database client. * @public * @returns {Object} * @example * const mdx = require("@nvidia-mdx/web-api-core"); *

Create a real-time alert rule and return (response_dict, status_code). When a :class:`~.rule_store.RuleStore` is configured the rule is

Build an AlertRuleConfig with sensible test defaults.

string operations