User-facing configuration for OlapDictionary. Exactly one of ``source_table``, ``source_query``, or ``external_source`` must be set. Providi

Hash table layout — good general-purpose choice for arbitrary integer keys.

Configuration for MergeTree engine

Configuration for creating a complete ingestion pipeline. Defines which components (table, stream, ingest API) should be created. Set a compo

Represents a standard SQL database View. Emits structured data for the Moose infrastructure system. Args: name: The name of the view

Configuration options for creating a View. Attributes: select_statement: The SQL SELECT statement defining the view's logic. base

A WebApp resource that wraps a FastAPI application. WebApps are managed by the Moose infrastructure and automatically proxied through the Rus

Mock FastAPI application for testing.

Configuration for a WebApp. Attributes: mount_path: The URL path where the WebApp will be mounted (required). Cannot b

Configuration for S3Queue engine - only non-alterable constructor parameters. S3Queue-specific settings like 'mode', 'keeper_path', etc. should b

A singleton Redis cache client that automatically handles connection management and key prefixing. Example: cache = MooseCache()

Configuration for ReplacingMergeTree engine (with deduplication) Args: ver: Optional column name for version tracking is_deleted:

Kafka engine for streaming data from Kafka topics. Args: broker_list: Kafka broker addresses (e.g., 'kafka:9092') topic_list: Top

Dictionary refresh policy. - ``DictionaryLifetime(min=0, max=0)`` — static, never refresh. - ``DictionaryLifetime(min=300, max=360)`` — refre

Configuration for ReplicatedMergeTree engine (replicated version of MergeTree) Args: keeper_path: Keeper path for replication (e.g., '/cl

Configuration for IcebergS3 engine - read-only Iceberg table access. Provides direct querying of Apache Iceberg tables stored on S3. Data is

Configuration for data streams (e.g., Redpanda topics). Attributes: parallelism: Number of partitions for the stream. retention_p

ClickHouse MATERIALIZED column annotation. The column value is computed at INSERT time and physically stored. Cannot be explicitly insert

Configuration options for creating a Materialized View. Attributes: select_statement: The SQL SELECT statement defining the view's data.

Configuration for Merge engine - read-only view over multiple tables matching a regex pattern. Args: source_database: Database to scan fo

Configuration for S3 engine - direct read/write from S3 storage. Args: path: S3 path to the data file(s) (e.g., 's3://bucket/path/file.js

Per-column attributes for a dictionary attribute column. These control ClickHouse-specific behaviour for each attribute column. The column na

HTTP/HTTPS endpoint as dictionary source.

Result of an insert operation with detailed success/failure information. Attributes: successful: Number of records successfully inserted.

MongoDB collection as dictionary source.

Metadata for a WebApp. Attributes: description: Optional description of the WebApp's purpose.

Multi-column key hash table.

Represents the unique signature of an infrastructure component (Table, Topic, etc.). Used primarily for defining dependencies between SQL resourc

Ingestion configuration that includes the mandatory destination stream. Attributes: destination: The `Stream` where ingested data will be

MySQL database as dictionary source.

Configuration for a Task. Attributes: run: The handler function that executes the task logic. Signature: run(context: TaskCo

Represents a workflow composed of one or more tasks. Workflows define a sequence of tasks to be executed, with optional scheduling, retries,

Configuration for a workflow. Attributes: starting_task: The first task to execute in the workflow. retries: Optional number of r

Configuration for AggregatingMergeTree engine, which stores pre-aggregated values and aggregate states that are automatically merged during backgr

Configuration for APIs. Attributes: version: Optional version string. path: Optional custom path for the API endpoint. If not spe

Configuration for Buffer engine - in-memory buffer that flushes to a destination table. Args: target_database: Target database name for t

Remote ClickHouse server as dictionary source.

Configuration for stream consumers. Attributes: version: Optional version string to identify a specific consumer. Allows

External executable process as dictionary source.

Configuration for a Kafka topic including namespace support. Attributes: streaming_engine_type: The type of topic (source or target)

PostgreSQL database as dictionary source.

Redis as dictionary source.

S3 object storage as dictionary source.

Base engine configuration for all ClickHouse table engines.

Fixed-size LRU cache, loaded on demand.

ClickHouse ALIAS column annotation. The column value is computed on-the-fly at SELECT time and NOT physically stored. Cannot be explicitl

Optional invalidation check: skip reload when result unchanged.

Represents a failed record during insertion with error details. Attributes: record: The original record that failed to insert. er

Raw data ingested via API

Raw data ingested via API

Represents an OLAP table (e.g., a ClickHouse table) typed with a Pydantic model. Args: name: The name of the OLAP table. config:

Helper seed for streaming pass-through of arbitrary values without intermediate allocation. This is used to efficiently pass through extra fields in i

Client for executing queries, typically against ClickHouse. Args: ch_client_or_config: Either an instance of the ClickHouse client or a R

Configuration for ReplicatedReplacingMergeTree engine (replicated version with deduplication) Args: keeper_path: Keeper path for replicat

Configuration for S3Queue engine with all specific fields.