* Join an array of Sql fragments with a separator. * @param fragments - Array of Sql fragments to join * @param separator - Optional separator s

Processes a file system event and tracks it if it's relevant. Only processes events that are relevant (create, modify, remove) and ignores metadata ch

* Log info message

Emit a structured log message to stderr. Args: level: Log level (e.g., "info", "error", "debug") message: Lo

Check if this severity should include issues of the given level

* Add a filter condition. * Automatically skips if value is undefined or null.

Returns the number of batches in the queue. # Returns The number of batches waiting to be inserted

Checks if there are no pending changes

Raise an exception with the source->target topic prefix.

Get the ID string for any signature variant

Checks if the batch queue is empty. # Returns `true` if there are no batches in the queue, `false` otherwise

Returns the environment name as a string

* Generates a `dictHas('dict', key)` SQL fragment. * * @param keys - Key expression(s) * * @example * ```typescript * sql`SELECT * F

* Log debug message (for verbose output)

KEYS: Return all keys matching a glob pattern.

create a RoutineFailure error without an error

* Template literal tag for SQL fragments (e.g. expressions, conditions, partial clauses). * Produces a Sql instance with `isFragment = true`.

GET: Return the value of a string key. Returns Err on type mismatch (key holds a list).

Execute query with Moose QueryClient.

Returns the version as a string slice.

Marks a value to be resolved from an environment variable at runtime. Args: env_var_name: Name of the environment variable to res

Should the version of the data models be included in the id?

* Execute the query with Moose QueryClient. * @param client - Moose QueryClient from getMooseClients()

* Log warning message

Receive the next event from the handler thread. This function will always block the current thread if there is no data available and it's possible fo

Parse a ClickHouse type string into an AST

Wrapper function for the show_message macro. This function allows calling the show_message functionality from contexts where macros cannot be used di

* Deletes all keys in the cache * * @example * await cache.clear();

* Gets the singleton instance of MooseCache. Creates a new instance if one doesn't exist. * The client will automatically connect to Redis and hand

* Sends one or more records to this stream's Kafka topic. * Values are JSON-serialized as message values.

* Log error message

Parses a version string like "10.24.0" into a PnpmVersion. Returns None if the string cannot be parsed.

Helper to create a minimal test table

Applies bold formatting to the text. # Returns Self for method chaining

Loads settings from all configuration sources Convenience method that calls read_settings() and handles errors appropriately. This method can be call

Exits the terminal interface. It disables the raw mode and reverts back the terminal properties.

Parse a frame from `src`, consuming the data.

* Generates a `dictGet('dict', 'attr', key)` SQL fragment. * * @param attr - The attribute (column) name to retrieve * @param keys - Key expr

Convert Pydantic model fields to Column definitions.

Create a minimal OlapTable for use as a source

Helper function to create a basic test table

SET: Store a string value, optionally with an expiry.

Compares this infrastructure map with a target map using a custom table diff strategy This method is similar to `diff()` but allows specifying a cust

* Create a scoped logger with a prefix

Validates that a set of OLAP changes comply with lifecycle policies. This is a **guard function** meant to be called at the execution boundary (in `o

Apply this delta to an infrastructure map, mutating it in place. This is the fold step: `foldl apply empty_map deltas == target_map`. Each variant ei

* Append another Sql fragment, returning a new Sql instance.

Returns the project name based on the language configuration