import { MessageType, JsonWriteOptions, JsonValue, JsonReadOptions, PartialMessage, IBinaryReader, BinaryReadOptions, IBinaryWriter, BinaryWriteOptions } from '@protobuf-ts/runtime'; declare class StringValue$Type extends MessageType { constructor(); /** * Encode `StringValue` to JSON string. */ internalJsonWrite(message: StringValue, options: JsonWriteOptions): JsonValue; /** * Decode `StringValue` from JSON string. */ internalJsonRead(json: JsonValue, options: JsonReadOptions, target?: StringValue): StringValue; create(value?: PartialMessage): StringValue; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StringValue): StringValue; internalBinaryWrite(message: StringValue, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Wrapper message for `string`. * * The JSON representation for `StringValue` is JSON string. * * Not recommended for use in new APIs, but still useful for legacy APIs and * has no plan to be removed. * * @generated from protobuf message google.protobuf.StringValue */ interface StringValue { /** * The string value. * * @generated from protobuf field: string value = 1 */ value: string; } /** * @generated MessageType for protobuf message google.protobuf.StringValue */ declare const StringValue: StringValue$Type; declare class Duration$Type extends MessageType { constructor(); /** * Encode `Duration` to JSON string like "3.000001s". */ internalJsonWrite(message: Duration, options: JsonWriteOptions): JsonValue; /** * Decode `Duration` from JSON string like "3.000001s" */ internalJsonRead(json: JsonValue, options: JsonReadOptions, target?: Duration): Duration; create(value?: PartialMessage): Duration; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Duration): Duration; internalBinaryWrite(message: Duration, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * A Duration represents a signed, fixed-length span of time represented * as a count of seconds and fractions of seconds at nanosecond * resolution. It is independent of any calendar and concepts like "day" * or "month". It is related to Timestamp in that the difference between * two Timestamp values is a Duration and it can be added or subtracted * from a Timestamp. Range is approximately +-10,000 years. * * # Examples * * Example 1: Compute Duration from two Timestamps in pseudo code. * * Timestamp start = ...; * Timestamp end = ...; * Duration duration = ...; * * duration.seconds = end.seconds - start.seconds; * duration.nanos = end.nanos - start.nanos; * * if (duration.seconds < 0 && duration.nanos > 0) { * duration.seconds += 1; * duration.nanos -= 1000000000; * } else if (duration.seconds > 0 && duration.nanos < 0) { * duration.seconds -= 1; * duration.nanos += 1000000000; * } * * Example 2: Compute Timestamp from Timestamp + Duration in pseudo code. * * Timestamp start = ...; * Duration duration = ...; * Timestamp end = ...; * * end.seconds = start.seconds + duration.seconds; * end.nanos = start.nanos + duration.nanos; * * if (end.nanos < 0) { * end.seconds -= 1; * end.nanos += 1000000000; * } else if (end.nanos >= 1000000000) { * end.seconds += 1; * end.nanos -= 1000000000; * } * * Example 3: Compute Duration from datetime.timedelta in Python. * * td = datetime.timedelta(days=3, minutes=10) * duration = Duration() * duration.FromTimedelta(td) * * # JSON Mapping * * In JSON format, the Duration type is encoded as a string rather than an * object, where the string ends in the suffix "s" (indicating seconds) and * is preceded by the number of seconds, with nanoseconds expressed as * fractional seconds. For example, 3 seconds with 0 nanoseconds should be * encoded in JSON format as "3s", while 3 seconds and 1 nanosecond should * be expressed in JSON format as "3.000000001s", and 3 seconds and 1 * microsecond should be expressed in JSON format as "3.000001s". * * * @generated from protobuf message google.protobuf.Duration */ interface Duration { /** * Signed seconds of the span of time. Must be from -315,576,000,000 * to +315,576,000,000 inclusive. Note: these bounds are computed from: * 60 sec/min * 60 min/hr * 24 hr/day * 365.25 days/year * 10000 years * * @generated from protobuf field: int64 seconds = 1 */ seconds: bigint; /** * Signed fractions of a second at nanosecond resolution of the span * of time. Durations less than one second are represented with a 0 * `seconds` field and a positive or negative `nanos` field. For durations * of one second or more, a non-zero value for the `nanos` field must be * of the same sign as the `seconds` field. Must be from -999,999,999 * to +999,999,999 inclusive. * * @generated from protobuf field: int32 nanos = 2 */ nanos: number; } /** * @generated MessageType for protobuf message google.protobuf.Duration */ declare const Duration: Duration$Type; /** * @generated from protobuf enum moose.proto.SchemaRegistry.Encoding */ declare enum SchemaRegistry_Encoding { /** * @generated from protobuf enum value: JSON = 0; */ JSON = 0, /** * @generated from protobuf enum value: AVRO = 1; */ AVRO = 1, /** * @generated from protobuf enum value: PROTOBUF = 2; */ PROTOBUF = 2 } /** * @generated from protobuf enum moose.proto.DictionaryLayout.Type */ declare enum DictionaryLayout_Type { /** * @generated from protobuf enum value: FLAT = 0; */ FLAT = 0, /** * @generated from protobuf enum value: HASHED = 1; */ HASHED = 1, /** * @generated from protobuf enum value: SPARSE_HASHED = 2; */ SPARSE_HASHED = 2, /** * @generated from protobuf enum value: HASHED_ARRAY = 3; */ HASHED_ARRAY = 3, /** * @generated from protobuf enum value: RANGE_HASHED = 4; */ RANGE_HASHED = 4, /** * @generated from protobuf enum value: CACHE = 5; */ CACHE = 5, /** * @generated from protobuf enum value: SSD_CACHE = 6; */ SSD_CACHE = 6, /** * @generated from protobuf enum value: DIRECT = 7; */ DIRECT = 7, /** * @generated from protobuf enum value: IP_TRIE = 8; */ IP_TRIE = 8, /** * @generated from protobuf enum value: COMPLEX_KEY_HASHED = 9; */ COMPLEX_KEY_HASHED = 9, /** * @generated from protobuf enum value: COMPLEX_KEY_SPARSE_HASHED = 10; */ COMPLEX_KEY_SPARSE_HASHED = 10, /** * @generated from protobuf enum value: COMPLEX_KEY_HASHED_ARRAY = 11; */ COMPLEX_KEY_HASHED_ARRAY = 11, /** * @generated from protobuf enum value: COMPLEX_KEY_CACHE = 12; */ COMPLEX_KEY_CACHE = 12, /** * @generated from protobuf enum value: COMPLEX_KEY_SSD_CACHE = 13; */ COMPLEX_KEY_SSD_CACHE = 13, /** * @generated from protobuf enum value: COMPLEX_KEY_DIRECT = 14; */ COMPLEX_KEY_DIRECT = 14 } /** * @deprecated * @generated from protobuf enum moose.proto.EndpointIngestionFormat */ declare enum EndpointIngestionFormat { /** * @generated from protobuf enum value: JSON = 0; */ JSON = 0, /** * @generated from protobuf enum value: JSON_ARRAY = 1; */ JSON_ARRAY = 1 } /** * @generated from protobuf enum moose.proto.Method */ declare enum Method { /** * @generated from protobuf enum value: GET = 0; */ GET = 0, /** * @generated from protobuf enum value: POST = 1; */ POST = 1, /** * @generated from protobuf enum value: PUT = 2; */ PUT = 2, /** * @generated from protobuf enum value: DELETE = 3; */ DELETE = 3 } /** * @generated from protobuf enum moose.proto.SimpleColumnType */ declare enum SimpleColumnType { /** * @generated from protobuf enum value: STRING = 0; */ STRING = 0, /** * @generated from protobuf enum value: BOOLEAN = 1; */ BOOLEAN = 1, /** * @deprecated * @generated from protobuf enum value: INT = 2 [deprecated = true]; */ INT = 2, /** * @generated from protobuf enum value: BIGINT = 3; */ BIGINT = 3, /** * @deprecated * @generated from protobuf enum value: FLOAT = 4 [deprecated = true]; */ FLOAT = 4, /** * @deprecated * @generated from protobuf enum value: DECIMAL = 5 [deprecated = true]; */ DECIMAL = 5, /** * in clickhouse, this is the 32-bit date * otherwise, see DateType where the precision can be specified * * @generated from protobuf enum value: DATETIME = 6; */ DATETIME = 6, /** * Framework Date (standard) -> ClickHouse Date32 (4 bytes) * * @generated from protobuf enum value: DATE = 7; */ DATE = 7, /** * Framework Date16 (memory-optimized) -> ClickHouse Date (2 bytes) * * @generated from protobuf enum value: DATE16 = 8; */ DATE16 = 8, /** * @generated from protobuf enum value: IPV4 = 9; */ IPV4 = 9, /** * @generated from protobuf enum value: IPV6 = 10; */ IPV6 = 10, /** * @generated from protobuf enum value: UUID_TYPE = 13; */ UUID_TYPE = 13, /** * @generated from protobuf enum value: JSON_COLUMN = 14; */ JSON_COLUMN = 14, /** * @generated from protobuf enum value: BYTES = 15; */ BYTES = 15, /** * Geometry types * * @generated from protobuf enum value: POINT = 16; */ POINT = 16, /** * @generated from protobuf enum value: RING = 17; */ RING = 17, /** * @generated from protobuf enum value: LINE_STRING = 18; */ LINE_STRING = 18, /** * @generated from protobuf enum value: MULTI_LINE_STRING = 19; */ MULTI_LINE_STRING = 19, /** * @generated from protobuf enum value: POLYGON = 20; */ POLYGON = 20, /** * @generated from protobuf enum value: MULTI_POLYGON = 21; */ MULTI_POLYGON = 21 } /** * @generated from protobuf enum moose.proto.IntType */ declare enum IntType { /** * this is what we defaulted to * * @generated from protobuf enum value: INT64 = 0; */ INT64 = 0, /** * @generated from protobuf enum value: INT8 = 1; */ INT8 = 1, /** * @generated from protobuf enum value: INT16 = 2; */ INT16 = 2, /** * @generated from protobuf enum value: INT32 = 3; */ INT32 = 3, /** * @generated from protobuf enum value: INT128 = 4; */ INT128 = 4, /** * @generated from protobuf enum value: INT256 = 5; */ INT256 = 5, /** * @generated from protobuf enum value: UINT8 = 6; */ UINT8 = 6, /** * @generated from protobuf enum value: UINT16 = 7; */ UINT16 = 7, /** * @generated from protobuf enum value: UINT32 = 8; */ UINT32 = 8, /** * @generated from protobuf enum value: UINT64 = 9; */ UINT64 = 9, /** * @generated from protobuf enum value: UINT128 = 10; */ UINT128 = 10, /** * @generated from protobuf enum value: UINT256 = 11; */ UINT256 = 11 } /** * @generated from protobuf enum moose.proto.FloatType */ declare enum FloatType { /** * @generated from protobuf enum value: FLOAT64 = 0; */ FLOAT64 = 0, /** * @generated from protobuf enum value: FLOAT32 = 1; */ FLOAT32 = 1 } /** * @generated from protobuf enum moose.proto.PrimitiveTypes */ declare enum PrimitiveTypes { /** * @generated from protobuf enum value: DATA_MODEL = 0; */ DATA_MODEL = 0, /** * @generated from protobuf enum value: FUNCTION = 1; */ FUNCTION = 1, /** * @generated from protobuf enum value: DB_BLOCK = 2; */ DB_BLOCK = 2, /** * @generated from protobuf enum value: CONSUMPTION_API = 3; */ CONSUMPTION_API = 3 } /** * @generated from protobuf enum moose.proto.LifeCycle */ declare enum LifeCycle { /** * @generated from protobuf enum value: FULLY_MANAGED = 0; */ FULLY_MANAGED = 0, /** * @generated from protobuf enum value: DELETION_PROTECTED = 1; */ DELETION_PROTECTED = 1, /** * @generated from protobuf enum value: EXTERNALLY_MANAGED = 2; */ EXTERNALLY_MANAGED = 2 } declare class InfrastructureMap$Type extends MessageType { constructor(); create(value?: PartialMessage): InfrastructureMap; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: InfrastructureMap): InfrastructureMap; private binaryReadMap1; private binaryReadMap2; private binaryReadMap3; private binaryReadMap4; private binaryReadMap5; private binaryReadMap6; private binaryReadMap7; private binaryReadMap10; private binaryReadMap11; private binaryReadMap12; private binaryReadMap13; private binaryReadMap16; private binaryReadMap17; private binaryReadMap18; private binaryReadMap20; private binaryReadMap21; internalBinaryWrite(message: InfrastructureMap, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.InfrastructureMap */ interface InfrastructureMap { /** * @generated from protobuf field: map topics = 1 */ topics: { [key: string]: Topic; }; /** * @generated from protobuf field: map api_endpoints = 2 */ apiEndpoints: { [key: string]: ApiEndpoint; }; /** * @generated from protobuf field: map tables = 3 */ tables: { [key: string]: Table; }; /** * @generated from protobuf field: map dmv1_views = 4 */ dmv1Views: { [key: string]: Dmv1View; }; /** * @generated from protobuf field: map topic_to_table_sync_processes = 5 */ topicToTableSyncProcesses: { [key: string]: TopicToTableSyncProcess; }; /** * @generated from protobuf field: map topic_to_topic_sync_processes = 6 */ topicToTopicSyncProcesses: { [key: string]: TopicToTopicSyncProcess; }; /** * @generated from protobuf field: map function_processes = 7 */ functionProcesses: { [key: string]: FunctionProcess; }; /** * add then when they have fields in rust * OlapProcess block_db_processes = 8; * ConsumptionApiWebServer consumption_api_web_server = 9; * * @generated from protobuf field: map initial_data_loads = 10 */ initialDataLoads: { [key: string]: InitialDataLoad; }; /** * @generated from protobuf field: map orchestration_workers = 11 */ orchestrationWorkers: { [key: string]: OrchestrationWorker; }; /** * @generated from protobuf field: map sql_resources = 12 */ sqlResources: { [key: string]: SqlResource; }; /** * @generated from protobuf field: map web_apps = 13 */ webApps: { [key: string]: WebApp; }; /** * Version of Moose CLI that created or last updated this infrastructure map * Helps with debugging, compatibility tracking, and migration planning * * @generated from protobuf field: string moose_version = 19 */ mooseVersion: string; /** * @generated from protobuf field: string default_database = 15 */ defaultDatabase: string; /** * Structured materialized views (replaces SqlResource for MVs) * * @generated from protobuf field: map materialized_views = 16 */ materializedViews: { [key: string]: MaterializedView; }; /** * Structured views (replaces SqlResource for views) * * @generated from protobuf field: map views = 17 */ views: { [key: string]: View; }; /** * Workflow definitions * * @generated from protobuf field: map workflows = 18 */ workflows: { [key: string]: Workflow; }; /** * Row-level security policies * * @generated from protobuf field: map select_row_policies = 20 */ selectRowPolicies: { [key: string]: SelectRowPolicy; }; /** * ClickHouse Dictionaries * * @generated from protobuf field: map olap_dictionaries = 21 */ olapDictionaries: { [key: string]: OlapDictionary; }; } /** * @generated MessageType for protobuf message moose.proto.InfrastructureMap */ declare const InfrastructureMap: InfrastructureMap$Type; declare class SourceLocation$Type extends MessageType { constructor(); create(value?: PartialMessage): SourceLocation; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SourceLocation): SourceLocation; internalBinaryWrite(message: SourceLocation, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.SourceLocation */ interface SourceLocation { /** * @generated from protobuf field: string file = 1 */ file: string; } /** * @generated MessageType for protobuf message moose.proto.SourceLocation */ declare const SourceLocation: SourceLocation$Type; declare class Metadata$Type extends MessageType { constructor(); create(value?: PartialMessage): Metadata; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Metadata): Metadata; internalBinaryWrite(message: Metadata, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Metadata */ interface Metadata { /** * @generated from protobuf field: string description = 1 */ description: string; /** * @generated from protobuf field: optional moose.proto.SourceLocation source = 2 */ source?: SourceLocation; } /** * @generated MessageType for protobuf message moose.proto.Metadata */ declare const Metadata: Metadata$Type; declare class Topic$Type extends MessageType { constructor(); create(value?: PartialMessage): Topic; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Topic): Topic; internalBinaryWrite(message: Topic, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Topic */ interface Topic { /** * @generated from protobuf field: optional string version = 1 */ version?: string; /** * @generated from protobuf field: string name = 2 */ name: string; /** * @generated from protobuf field: google.protobuf.Duration retention_period = 3 */ retentionPeriod?: Duration; /** * @generated from protobuf field: repeated moose.proto.Column columns = 4 */ columns: Column[]; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 5 */ sourcePrimitive?: PrimitiveSignature; /** * @generated from protobuf field: optional int32 partition_count = 6 */ partitionCount?: number; /** * @generated from protobuf field: optional int32 max_message_bytes = 7 */ maxMessageBytes?: number; /** * @generated from protobuf field: moose.proto.Metadata metadata = 8 */ metadata?: Metadata; /** * @generated from protobuf field: moose.proto.LifeCycle life_cycle = 9 */ lifeCycle: LifeCycle; /** * Optional Schema Registry configuration * * @generated from protobuf field: optional moose.proto.SchemaRegistry schema_registry = 10 */ schemaRegistry?: SchemaRegistry; } /** * @generated MessageType for protobuf message moose.proto.Topic */ declare const Topic: Topic$Type; declare class SchemaRegistry$Type extends MessageType { constructor(); create(value?: PartialMessage): SchemaRegistry; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SchemaRegistry): SchemaRegistry; internalBinaryWrite(message: SchemaRegistry, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Encodes schema reference used for Schema Registry integration * * @generated from protobuf message moose.proto.SchemaRegistry */ interface SchemaRegistry { /** * Encoding/wire format; avoid reserved names in generators * * @generated from protobuf field: moose.proto.SchemaRegistry.Encoding encoding = 1 */ encoding: SchemaRegistry_Encoding; /** * @generated from protobuf oneof: schema_ref */ schemaRef: { oneofKind: "schemaId"; /** * Use a concrete schema ID * * @generated from protobuf field: int32 schema_id = 2 */ schemaId: number; } | { oneofKind: "subject"; /** * Use subject name (latest version) * * @generated from protobuf field: string subject = 3 */ subject: string; } | { oneofKind: "subjectVersion"; /** * Use subject name with explicit version * * @generated from protobuf field: moose.proto.SubjectVersion subject_version = 4 */ subjectVersion: SubjectVersion; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.SchemaRegistry */ declare const SchemaRegistry: SchemaRegistry$Type; declare class SubjectVersion$Type extends MessageType { constructor(); create(value?: PartialMessage): SubjectVersion; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SubjectVersion): SubjectVersion; internalBinaryWrite(message: SubjectVersion, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.SubjectVersion */ interface SubjectVersion { /** * @generated from protobuf field: string subject = 1 */ subject: string; /** * @generated from protobuf field: int32 version = 2 */ version: number; } /** * @generated MessageType for protobuf message moose.proto.SubjectVersion */ declare const SubjectVersion: SubjectVersion$Type; declare class ApiEndpoint$Type extends MessageType { constructor(); create(value?: PartialMessage): ApiEndpoint; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ApiEndpoint): ApiEndpoint; internalBinaryWrite(message: ApiEndpoint, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.ApiEndpoint */ interface ApiEndpoint { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf oneof: api_type */ apiType: { oneofKind: "ingress"; /** * @generated from protobuf field: moose.proto.IngressDetails ingress = 2 */ ingress: IngressDetails; } | { oneofKind: "egress"; /** * @generated from protobuf field: moose.proto.EgressDetails egress = 3 */ egress: EgressDetails; } | { oneofKind: undefined; }; /** * @generated from protobuf field: string path = 4 */ path: string; /** * @generated from protobuf field: moose.proto.Method method = 5 */ method: Method; /** * @generated from protobuf field: optional string version = 6 */ version?: string; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 7 */ sourcePrimitive?: PrimitiveSignature; /** * @generated from protobuf field: moose.proto.Metadata metadata = 8 */ metadata?: Metadata; /** * Infrastructure components this API endpoint reads data from. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pulls_data_from = 9 */ pullsDataFrom: InfrastructureSignature[]; /** * Infrastructure components this API endpoint writes data to. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pushes_data_to = 10 */ pushesDataTo: InfrastructureSignature[]; } /** * @generated MessageType for protobuf message moose.proto.ApiEndpoint */ declare const ApiEndpoint: ApiEndpoint$Type; declare class IngressDetails$Type extends MessageType { constructor(); create(value?: PartialMessage): IngressDetails; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: IngressDetails): IngressDetails; internalBinaryWrite(message: IngressDetails, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.IngressDetails */ interface IngressDetails { /** * @generated from protobuf field: string target_topic = 1 */ targetTopic: string; /** * @deprecated * @generated from protobuf field: optional moose.proto.EndpointIngestionFormat format = 2 [deprecated = true] */ format?: EndpointIngestionFormat; /** * @generated from protobuf field: optional string dead_letter_queue = 3 */ deadLetterQueue?: string; } /** * @generated MessageType for protobuf message moose.proto.IngressDetails */ declare const IngressDetails: IngressDetails$Type; declare class EgressDetails$Type extends MessageType { constructor(); create(value?: PartialMessage): EgressDetails; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: EgressDetails): EgressDetails; internalBinaryWrite(message: EgressDetails, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.EgressDetails */ interface EgressDetails { /** * @generated from protobuf field: repeated moose.proto.ConsumptionQueryParam query_params = 1 */ queryParams: ConsumptionQueryParam[]; /** * might be worth it to use google.protobuf.Value * * @generated from protobuf field: string output_schema = 2 */ outputSchema: string; } /** * @generated MessageType for protobuf message moose.proto.EgressDetails */ declare const EgressDetails: EgressDetails$Type; declare class ConsumptionQueryParam$Type extends MessageType { constructor(); create(value?: PartialMessage): ConsumptionQueryParam; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ConsumptionQueryParam): ConsumptionQueryParam; internalBinaryWrite(message: ConsumptionQueryParam, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.ConsumptionQueryParam */ interface ConsumptionQueryParam { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: moose.proto.ColumnType data_type = 2 */ dataType?: ColumnType; /** * @generated from protobuf field: bool required = 3 */ required: boolean; } /** * @generated MessageType for protobuf message moose.proto.ConsumptionQueryParam */ declare const ConsumptionQueryParam: ConsumptionQueryParam$Type; declare class Table$Type extends MessageType { constructor(); create(value?: PartialMessage
): Table; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Table): Table; private binaryReadMap11; internalBinaryWrite(message: Table, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Table */ interface Table { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: repeated moose.proto.Column columns = 2 */ columns: Column[]; /** * @generated from protobuf field: repeated string order_by = 3 */ orderBy: string[]; /** * @generated from protobuf field: optional string version = 4 */ version?: string; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 5 */ sourcePrimitive?: PrimitiveSignature; /** * @deprecated * @generated from protobuf field: bool deduplicate = 6 [deprecated = true] */ deduplicate: boolean; /** * @generated from protobuf field: google.protobuf.StringValue engine = 7 */ engine?: StringValue; /** * @generated from protobuf field: moose.proto.Metadata metadata = 8 */ metadata?: Metadata; /** * @generated from protobuf field: moose.proto.LifeCycle life_cycle = 9 */ lifeCycle: LifeCycle; /** * Hash of non-alterable engine parameters for change detection * * @generated from protobuf field: optional string engine_params_hash = 10 */ engineParamsHash?: string; /** * Alterable table settings (can be changed with ALTER TABLE MODIFY SETTING) * * @generated from protobuf field: map table_settings = 11 */ tableSettings: { [key: string]: string; }; /** * Optional PARTITION BY expression for ClickHouse tables * * @generated from protobuf field: optional string partition_by = 12 */ partitionBy?: string; /** * Next-version ORDER BY representation to match Rust enum * Non-breaking: keeps legacy order_by (field 3) while adding a structured variant * * @generated from protobuf field: optional moose.proto.OrderBy order_by2 = 13 */ orderBy2?: OrderBy; /** * Optional secondary/data-skipping indexes * * @generated from protobuf field: repeated moose.proto.TableIndex indexes = 14 */ indexes: TableIndex[]; /** * Optional SAMPLE BY expression for ClickHouse tables * * @generated from protobuf field: optional string sample_by_expression = 15 */ sampleByExpression?: string; /** * Optional TTL expression at table level (without leading 'TTL') * * @generated from protobuf field: optional string table_ttl_setting = 16 */ tableTtlSetting?: string; /** * Optional database name for multi-database support * When not specified, uses the global ClickHouse config database * * @generated from protobuf field: optional string database = 17 */ database?: string; /** * Optional cluster name for ON CLUSTER support in ClickHouse * * @generated from protobuf field: optional string cluster_name = 18 */ clusterName?: string; /** * Optional PRIMARY KEY expression * When specified, overrides primary_key boolean flags on columns * * @generated from protobuf field: optional string primary_key_expression = 19 */ primaryKeyExpression?: string; /** * Hash of table settings for change detection (including sensitive settings) * Used to detect settings changes without storing plaintext sensitive values * * @generated from protobuf field: optional string table_settings_hash = 20 */ tableSettingsHash?: string; /** * Optional table projections for alternative data ordering within parts * * @generated from protobuf field: repeated moose.proto.TableProjection projections = 21 */ projections: TableProjection[]; /** * Per-table filter for `moose seed clickhouse` * * @generated from protobuf field: optional moose.proto.SeedFilter seed_filter = 22 */ seedFilter?: SeedFilter; /** * Table-level constraints * * @generated from protobuf field: repeated moose.proto.TableConstraint constraints = 23 */ constraints: TableConstraint[]; } /** * @generated MessageType for protobuf message moose.proto.Table */ declare const Table: Table$Type; declare class TableProjection$Type extends MessageType { constructor(); create(value?: PartialMessage): TableProjection; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TableProjection): TableProjection; internalBinaryWrite(message: TableProjection, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DB-neutral representation of a table projection * * @generated from protobuf message moose.proto.TableProjection */ interface TableProjection { /** * The projection identifier as it appears after `PROJECTION` in the DDL * * @generated from protobuf field: string name = 1 */ name: string; /** * The parenthesised body (without the outer parentheses) * * @generated from protobuf field: string body = 2 */ body: string; } /** * @generated MessageType for protobuf message moose.proto.TableProjection */ declare const TableProjection: TableProjection$Type; declare class TableConstraint$Type extends MessageType { constructor(); create(value?: PartialMessage): TableConstraint; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TableConstraint): TableConstraint; internalBinaryWrite(message: TableConstraint, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DB-neutral representation of a table constraint * * @generated from protobuf message moose.proto.TableConstraint */ interface TableConstraint { /** * The unique identifier or name of the constraint * * @generated from protobuf field: string name = 1 */ name: string; /** * The SQL or logical expression enforcing the constraint condition * * @generated from protobuf field: string expression = 2 */ expression: string; /** * The category of the constraint (e.g., "CHECK", "ASSUME") * * @generated from protobuf field: string constraint_type = 3 */ constraintType: string; } /** * @generated MessageType for protobuf message moose.proto.TableConstraint */ declare const TableConstraint: TableConstraint$Type; declare class OrderBy$Type extends MessageType { constructor(); create(value?: PartialMessage): OrderBy; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderBy): OrderBy; internalBinaryWrite(message: OrderBy, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * or an arbitrary ClickHouse SQL expression. * * @generated from protobuf message moose.proto.OrderBy */ interface OrderBy { /** * @generated from protobuf oneof: t */ t: { oneofKind: "fields"; /** * Explicit ordered list of fields * * @generated from protobuf field: moose.proto.OrderByFields fields = 1 */ fields: OrderByFields; } | { oneofKind: "expression"; /** * Arbitrary ClickHouse expression, e.g. "tuple()" or "(id, name)" * * @generated from protobuf field: string expression = 2 */ expression: string; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.OrderBy */ declare const OrderBy: OrderBy$Type; declare class OrderByFields$Type extends MessageType { constructor(); create(value?: PartialMessage): OrderByFields; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderByFields): OrderByFields; internalBinaryWrite(message: OrderByFields, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.OrderByFields */ interface OrderByFields { /** * @generated from protobuf field: repeated string field = 1 */ field: string[]; } /** * @generated MessageType for protobuf message moose.proto.OrderByFields */ declare const OrderByFields: OrderByFields$Type; declare class TableIndex$Type extends MessageType { constructor(); create(value?: PartialMessage): TableIndex; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TableIndex): TableIndex; internalBinaryWrite(message: TableIndex, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DB-neutral representation of a table index * * @generated from protobuf message moose.proto.TableIndex */ interface TableIndex { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: string expression = 2 */ expression: string; /** * @generated from protobuf field: string type = 3 */ type: string; /** * @generated from protobuf field: repeated string arguments = 4 */ arguments: string[]; /** * @generated from protobuf field: uint64 granularity = 5 */ granularity: bigint; } /** * @generated MessageType for protobuf message moose.proto.TableIndex */ declare const TableIndex: TableIndex$Type; declare class SeedFilter$Type extends MessageType { constructor(); create(value?: PartialMessage): SeedFilter; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SeedFilter): SeedFilter; internalBinaryWrite(message: SeedFilter, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Per-table filtering for `moose seed clickhouse` * * @generated from protobuf message moose.proto.SeedFilter */ interface SeedFilter { /** * Maximum rows to seed (falls back to CLI --limit, then global default) * * @generated from protobuf field: optional uint64 limit = 1 */ limit?: bigint; /** * ClickHouse SQL WHERE expression appended to the seed query * * @generated from protobuf field: optional string where_clause = 2 */ whereClause?: string; } /** * @generated MessageType for protobuf message moose.proto.SeedFilter */ declare const SeedFilter: SeedFilter$Type; declare class Dmv1View$Type extends MessageType { constructor(); create(value?: PartialMessage): Dmv1View; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Dmv1View): Dmv1View; internalBinaryWrite(message: Dmv1View, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Dmv1View */ interface Dmv1View { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: string version = 2 */ version: string; /** * @generated from protobuf oneof: view_type */ viewType: { oneofKind: "tableAlias"; /** * @generated from protobuf field: moose.proto.TableAlias table_alias = 3 */ tableAlias: TableAlias; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.Dmv1View */ declare const Dmv1View: Dmv1View$Type; declare class TableAlias$Type extends MessageType { constructor(); create(value?: PartialMessage): TableAlias; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TableAlias): TableAlias; internalBinaryWrite(message: TableAlias, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.TableAlias */ interface TableAlias { /** * @generated from protobuf field: string source_table_name = 1 */ sourceTableName: string; } /** * @generated MessageType for protobuf message moose.proto.TableAlias */ declare const TableAlias: TableAlias$Type; declare class TableReference$Type extends MessageType { constructor(); create(value?: PartialMessage): TableReference; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TableReference): TableReference; internalBinaryWrite(message: TableReference, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Reference to a table, optionally qualified with database * * @generated from protobuf message moose.proto.TableReference */ interface TableReference { /** * Database name (empty means use default database) * * @generated from protobuf field: optional string database = 1 */ database?: string; /** * Table name * * @generated from protobuf field: string table = 2 */ table: string; } /** * @generated MessageType for protobuf message moose.proto.TableReference */ declare const TableReference: TableReference$Type; declare class SelectQuery$Type extends MessageType { constructor(); create(value?: PartialMessage): SelectQuery; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SelectQuery): SelectQuery; internalBinaryWrite(message: SelectQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Represents a SELECT query with semantic information * * @generated from protobuf message moose.proto.SelectQuery */ interface SelectQuery { /** * The raw SELECT SQL statement * * @generated from protobuf field: string sql = 1 */ sql: string; /** * Tables/views referenced in the FROM clause(s) * * @generated from protobuf field: repeated moose.proto.TableReference source_tables = 2 */ sourceTables: TableReference[]; } /** * @generated MessageType for protobuf message moose.proto.SelectQuery */ declare const SelectQuery: SelectQuery$Type; declare class View$Type extends MessageType { constructor(); create(value?: PartialMessage): View; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: View): View; internalBinaryWrite(message: View, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * User-defined ClickHouse View with an arbitrary SELECT query. * Views are virtual tables that compute results on-demand. * * @generated from protobuf message moose.proto.View */ interface View { /** * Name of the view * * @generated from protobuf field: string name = 1 */ name: string; /** * Database where the view is created (empty = default database) * * @generated from protobuf field: optional string database = 2 */ database?: string; /** * The SELECT query that defines the view * * @generated from protobuf field: moose.proto.SelectQuery select_query = 3 */ selectQuery?: SelectQuery; /** * Optional metadata for the view (e.g., description, source file) * * @generated from protobuf field: optional moose.proto.Metadata metadata = 4 */ metadata?: Metadata; } /** * @generated MessageType for protobuf message moose.proto.View */ declare const View: View$Type; declare class MaterializedView$Type extends MessageType { constructor(); create(value?: PartialMessage): MaterializedView; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: MaterializedView): MaterializedView; internalBinaryWrite(message: MaterializedView, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * ClickHouse Materialized View that writes transformed data to a target table. * MVs run the SELECT query on insert and persist results. * * @generated from protobuf message moose.proto.MaterializedView */ interface MaterializedView { /** * Name of the materialized view * * @generated from protobuf field: string name = 1 */ name: string; /** * Database where the MV is created (empty = default database) * * @generated from protobuf field: optional string database = 2 */ database?: string; /** * The SELECT query that defines the transformation * * @generated from protobuf field: moose.proto.SelectQuery select_query = 3 */ selectQuery?: SelectQuery; /** * Target table where transformed data is written (the TO clause) * * @generated from protobuf field: moose.proto.TableReference target_table = 4 */ targetTable?: TableReference; /** * Optional metadata for the materialized view (e.g., description, source file) * * @generated from protobuf field: optional moose.proto.Metadata metadata = 5 */ metadata?: Metadata; /** * Lifecycle management policy for the materialized view * * @generated from protobuf field: moose.proto.LifeCycle life_cycle = 6 */ lifeCycle: LifeCycle; } /** * @generated MessageType for protobuf message moose.proto.MaterializedView */ declare const MaterializedView: MaterializedView$Type; declare class TopicToTableSyncProcess$Type extends MessageType { constructor(); create(value?: PartialMessage): TopicToTableSyncProcess; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TopicToTableSyncProcess): TopicToTableSyncProcess; internalBinaryWrite(message: TopicToTableSyncProcess, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.TopicToTableSyncProcess */ interface TopicToTableSyncProcess { /** * @generated from protobuf field: string source_topic_id = 1 */ sourceTopicId: string; /** * @generated from protobuf field: string target_table_id = 2 */ targetTableId: string; /** * @generated from protobuf field: repeated moose.proto.Column columns = 3 */ columns: Column[]; /** * @generated from protobuf field: optional string version = 4 */ version?: string; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 5 */ sourcePrimitive?: PrimitiveSignature; } /** * @generated MessageType for protobuf message moose.proto.TopicToTableSyncProcess */ declare const TopicToTableSyncProcess: TopicToTableSyncProcess$Type; declare class TopicToTopicSyncProcess$Type extends MessageType { constructor(); create(value?: PartialMessage): TopicToTopicSyncProcess; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TopicToTopicSyncProcess): TopicToTopicSyncProcess; internalBinaryWrite(message: TopicToTopicSyncProcess, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.TopicToTopicSyncProcess */ interface TopicToTopicSyncProcess { /** * @generated from protobuf field: string source_topic_id = 1 */ sourceTopicId: string; /** * @generated from protobuf field: string target_topic_id = 2 */ targetTopicId: string; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 3 */ sourcePrimitive?: PrimitiveSignature; } /** * @generated MessageType for protobuf message moose.proto.TopicToTopicSyncProcess */ declare const TopicToTopicSyncProcess: TopicToTopicSyncProcess$Type; declare class FunctionProcess$Type extends MessageType { constructor(); create(value?: PartialMessage): FunctionProcess; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: FunctionProcess): FunctionProcess; private binaryReadMap5; internalBinaryWrite(message: FunctionProcess, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.FunctionProcess */ interface FunctionProcess { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: string source_topic = 2 */ sourceTopic: string; /** * @generated from protobuf field: repeated moose.proto.Column source_columns = 3 */ sourceColumns: Column[]; /** * @generated from protobuf field: optional string target_topic = 4 */ targetTopic?: string; /** * @generated from protobuf field: map target_topic_config = 5 */ targetTopicConfig: { [key: string]: string; }; /** * @generated from protobuf field: repeated moose.proto.Column target_columns = 6 */ targetColumns: Column[]; /** * @generated from protobuf field: string executable = 7 */ executable: string; /** * @generated from protobuf field: optional string version = 8 */ version?: string; /** * @generated from protobuf field: moose.proto.PrimitiveSignature source_primitive = 9 */ sourcePrimitive?: PrimitiveSignature; /** * @generated from protobuf field: optional int32 parallel_process_count = 10 */ parallelProcessCount?: number; /** * @generated from protobuf field: optional moose.proto.Metadata metadata = 11 */ metadata?: Metadata; /** * Topic ID for the dead letter queue, used to construct namespace-prefixed topic name * * @generated from protobuf field: optional string dead_letter_queue_topic_id = 12 */ deadLetterQueueTopicId?: string; } /** * @generated MessageType for protobuf message moose.proto.FunctionProcess */ declare const FunctionProcess: FunctionProcess$Type; declare class InitialDataLoad$Type extends MessageType { constructor(); create(value?: PartialMessage): InitialDataLoad; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: InitialDataLoad): InitialDataLoad; internalBinaryWrite(message: InitialDataLoad, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.InitialDataLoad */ interface InitialDataLoad { /** * @generated from protobuf field: moose.proto.Table table = 1 */ table?: Table; /** * @generated from protobuf field: string topic = 2 */ topic: string; /** * @generated from protobuf field: optional uint64 progress = 3 */ progress?: bigint; } /** * @generated MessageType for protobuf message moose.proto.InitialDataLoad */ declare const InitialDataLoad: InitialDataLoad$Type; declare class Column$Type extends MessageType { constructor(); create(value?: PartialMessage): Column; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Column): Column; private binaryReadMap7; internalBinaryWrite(message: Column, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Column */ interface Column { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: moose.proto.ColumnType data_type = 2 */ dataType?: ColumnType; /** * @generated from protobuf field: bool required = 3 */ required: boolean; /** * @generated from protobuf field: bool unique = 4 */ unique: boolean; /** * @generated from protobuf field: bool primary_key = 5 */ primaryKey: boolean; /** * was an enum that we never used * * @deprecated * @generated from protobuf field: int32 default = 6 [deprecated = true] */ default: number; /** * Column default is now a free-form SQL expression passed as a string * * @generated from protobuf field: google.protobuf.StringValue default_expr = 9 */ defaultExpr?: StringValue; /** * @generated from protobuf field: map annotations = 7 */ annotations: { [key: string]: string; }; /** * @generated from protobuf field: optional string comment = 8 */ comment?: string; /** * Optional column-level TTL expression (without leading 'TTL') * * @generated from protobuf field: optional string ttl = 10 */ ttl?: string; /** * Compression codec expression (e.g., "ZSTD(3)", "Delta, LZ4") * * @generated from protobuf field: optional string codec = 11 */ codec?: string; /** * Materialized expression * * @generated from protobuf field: optional string materialized = 12 */ materialized?: string; /** * Alias expression (computed at query time, not stored) * * @generated from protobuf field: optional string alias = 13 */ alias?: string; } /** * @generated MessageType for protobuf message moose.proto.Column */ declare const Column: Column$Type; declare class Decimal$Type extends MessageType { constructor(); create(value?: PartialMessage): Decimal; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Decimal): Decimal; internalBinaryWrite(message: Decimal, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Decimal */ interface Decimal { /** * @generated from protobuf field: int32 precision = 1 */ precision: number; /** * @generated from protobuf field: int32 scale = 2 */ scale: number; } /** * @generated MessageType for protobuf message moose.proto.Decimal */ declare const Decimal: Decimal$Type; declare class Tuple$Type extends MessageType { constructor(); create(value?: PartialMessage): Tuple; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Tuple): Tuple; internalBinaryWrite(message: Tuple, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Tuple */ interface Tuple { /** * @generated from protobuf field: repeated string names = 1 */ names: string[]; /** * @generated from protobuf field: repeated moose.proto.ColumnType types = 2 */ types: ColumnType[]; } /** * @generated MessageType for protobuf message moose.proto.Tuple */ declare const Tuple: Tuple$Type; declare class Map$Type extends MessageType { constructor(); create(value?: PartialMessage): Map; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Map): Map; internalBinaryWrite(message: Map, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Map */ interface Map { /** * @generated from protobuf field: moose.proto.ColumnType key_type = 1 */ keyType?: ColumnType; /** * @generated from protobuf field: moose.proto.ColumnType value_type = 2 */ valueType?: ColumnType; } /** * @generated MessageType for protobuf message moose.proto.Map */ declare const Map: Map$Type; declare class JsonTypedPath$Type extends MessageType { constructor(); create(value?: PartialMessage): JsonTypedPath; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: JsonTypedPath): JsonTypedPath; internalBinaryWrite(message: JsonTypedPath, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * JSON type with optional settings * * @generated from protobuf message moose.proto.JsonTypedPath */ interface JsonTypedPath { /** * JSON path like "a.b[0].c" * * @generated from protobuf field: string path = 1 */ path: string; /** * Concrete type for the value at the path * * @generated from protobuf field: moose.proto.ColumnType type = 2 */ type?: ColumnType; } /** * @generated MessageType for protobuf message moose.proto.JsonTypedPath */ declare const JsonTypedPath: JsonTypedPath$Type; declare class Json$Type extends MessageType { constructor(); create(value?: PartialMessage): Json; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Json): Json; internalBinaryWrite(message: Json, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Json */ interface Json { /** * Limits for dynamic discovery * * @generated from protobuf field: optional uint64 max_dynamic_paths = 1 */ maxDynamicPaths?: bigint; /** * @generated from protobuf field: optional uint64 max_dynamic_types = 2 */ maxDynamicTypes?: bigint; /** * List of typed paths (path, type) * * @generated from protobuf field: repeated moose.proto.JsonTypedPath typed_paths = 3 */ typedPaths: JsonTypedPath[]; /** * Paths to skip during ingestion * * @generated from protobuf field: repeated string skip_paths = 4 */ skipPaths: string[]; /** * Regex patterns of paths to skip * * @generated from protobuf field: repeated string skip_regexps = 5 */ skipRegexps: string[]; } /** * @generated MessageType for protobuf message moose.proto.Json */ declare const Json: Json$Type; declare class ColumnType$Type extends MessageType { constructor(); create(value?: PartialMessage): ColumnType; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ColumnType): ColumnType; internalBinaryWrite(message: ColumnType, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * TODO: nullable not being a type, relying on `bool required` * is causing some mess e.g. the special case array_of_nullable * * @generated from protobuf message moose.proto.ColumnType */ interface ColumnType { /** * @generated from protobuf oneof: t */ t: { oneofKind: "simple"; /** * @generated from protobuf field: moose.proto.SimpleColumnType simple = 1 */ simple: SimpleColumnType; } | { oneofKind: "enum"; /** * @generated from protobuf field: moose.proto.DataEnum enum = 2 */ enum: DataEnum; } | { oneofKind: "array"; /** * @generated from protobuf field: moose.proto.ColumnType array = 3 */ array: ColumnType; } | { oneofKind: "nested"; /** * @generated from protobuf field: moose.proto.Nested nested = 4 */ nested: Nested; } | { oneofKind: "arrayOfNullable"; /** * @generated from protobuf field: moose.proto.ColumnType array_of_nullable = 5 */ arrayOfNullable: ColumnType; } | { oneofKind: "tuple"; /** * @generated from protobuf field: moose.proto.Tuple tuple = 6 */ tuple: Tuple; } | { oneofKind: "nullable"; /** * @generated from protobuf field: moose.proto.ColumnType nullable = 7 */ nullable: ColumnType; } | { oneofKind: "map"; /** * @generated from protobuf field: moose.proto.Map map = 8 */ map: Map; } | { oneofKind: "json"; /** * JSON with settings (non-breaking addition). Keep legacy `simple = JSON_COLUMN` for back-compat. * * @generated from protobuf field: moose.proto.Json json = 9 */ json: Json; } | { oneofKind: "fixedString"; /** * @generated from protobuf field: uint64 fixed_string = 11 */ fixedString: bigint; } | { oneofKind: "dateTime"; /** * @generated from protobuf field: moose.proto.DateType date_time = 12 */ dateTime: DateType; } | { oneofKind: "decimal"; /** * @generated from protobuf field: moose.proto.Decimal decimal = 13 */ decimal: Decimal; } | { oneofKind: "float"; /** * @generated from protobuf field: moose.proto.FloatType float = 14 */ float: FloatType; } | { oneofKind: "int"; /** * @generated from protobuf field: moose.proto.IntType int = 15 */ int: IntType; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.ColumnType */ declare const ColumnType: ColumnType$Type; declare class DateType$Type extends MessageType { constructor(); create(value?: PartialMessage): DateType; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DateType): DateType; internalBinaryWrite(message: DateType, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.DateType */ interface DateType { /** * @generated from protobuf field: int32 precision = 1 */ precision: number; } /** * @generated MessageType for protobuf message moose.proto.DateType */ declare const DateType: DateType$Type; declare class DataEnum$Type extends MessageType { constructor(); create(value?: PartialMessage): DataEnum; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DataEnum): DataEnum; internalBinaryWrite(message: DataEnum, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.DataEnum */ interface DataEnum { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: repeated moose.proto.EnumMember values = 2 */ values: EnumMember[]; } /** * @generated MessageType for protobuf message moose.proto.DataEnum */ declare const DataEnum: DataEnum$Type; declare class Nested$Type extends MessageType { constructor(); create(value?: PartialMessage): Nested; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Nested): Nested; internalBinaryWrite(message: Nested, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Nested */ interface Nested { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: repeated moose.proto.Column columns = 2 */ columns: Column[]; /** * @generated from protobuf field: bool jwt = 3 */ jwt: boolean; } /** * @generated MessageType for protobuf message moose.proto.Nested */ declare const Nested: Nested$Type; declare class EnumMember$Type extends MessageType { constructor(); create(value?: PartialMessage): EnumMember; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: EnumMember): EnumMember; internalBinaryWrite(message: EnumMember, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.EnumMember */ interface EnumMember { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: moose.proto.EnumValue value = 2 */ value?: EnumValue; } /** * @generated MessageType for protobuf message moose.proto.EnumMember */ declare const EnumMember: EnumMember$Type; declare class EnumValue$Type extends MessageType { constructor(); create(value?: PartialMessage): EnumValue; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: EnumValue): EnumValue; internalBinaryWrite(message: EnumValue, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.EnumValue */ interface EnumValue { /** * @generated from protobuf oneof: value */ value: { oneofKind: "intValue"; /** * @generated from protobuf field: int32 int_value = 1 */ intValue: number; } | { oneofKind: "stringValue"; /** * @generated from protobuf field: string string_value = 2 */ stringValue: string; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.EnumValue */ declare const EnumValue: EnumValue$Type; declare class PrimitiveSignature$Type extends MessageType { constructor(); create(value?: PartialMessage): PrimitiveSignature; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: PrimitiveSignature): PrimitiveSignature; internalBinaryWrite(message: PrimitiveSignature, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.PrimitiveSignature */ interface PrimitiveSignature { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: moose.proto.PrimitiveTypes primitive_type = 2 */ primitiveType: PrimitiveTypes; } /** * @generated MessageType for protobuf message moose.proto.PrimitiveSignature */ declare const PrimitiveSignature: PrimitiveSignature$Type; declare class OrchestrationWorker$Type extends MessageType { constructor(); create(value?: PartialMessage): OrchestrationWorker; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrchestrationWorker): OrchestrationWorker; internalBinaryWrite(message: OrchestrationWorker, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.OrchestrationWorker */ interface OrchestrationWorker { /** * @generated from protobuf field: string supported_language = 1 */ supportedLanguage: string; } /** * @generated MessageType for protobuf message moose.proto.OrchestrationWorker */ declare const OrchestrationWorker: OrchestrationWorker$Type; declare class SqlResource$Type extends MessageType { constructor(); create(value?: PartialMessage): SqlResource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SqlResource): SqlResource; internalBinaryWrite(message: SqlResource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.SqlResource */ interface SqlResource { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: repeated string setup = 2 */ setup: string[]; /** * @generated from protobuf field: repeated string teardown = 3 */ teardown: string[]; /** * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pulls_data_from = 5 */ pullsDataFrom: InfrastructureSignature[]; /** * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pushes_data_to = 6 */ pushesDataTo: InfrastructureSignature[]; /** * Optional database name for multi-database support * When not specified, uses the global ClickHouse config database * * @generated from protobuf field: optional string database = 7 */ database?: string; /** * Optional source file path where this SQL resource is defined * * @generated from protobuf field: string source_file = 8 */ sourceFile: string; } /** * @generated MessageType for protobuf message moose.proto.SqlResource */ declare const SqlResource: SqlResource$Type; declare class InfrastructureSignature$Type extends MessageType { constructor(); create(value?: PartialMessage): InfrastructureSignature; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: InfrastructureSignature): InfrastructureSignature; internalBinaryWrite(message: InfrastructureSignature, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.InfrastructureSignature */ interface InfrastructureSignature { /** * @generated from protobuf oneof: signature */ signature: { oneofKind: "topicId"; /** * @generated from protobuf field: string topic_id = 1 */ topicId: string; } | { oneofKind: "tableId"; /** * @generated from protobuf field: string table_id = 2 */ tableId: string; } | { oneofKind: "dmv1ViewId"; /** * @generated from protobuf field: string dmv1_view_id = 3 */ dmv1ViewId: string; } | { oneofKind: "sqlResourceId"; /** * @generated from protobuf field: string sql_resource_id = 4 */ sqlResourceId: string; } | { oneofKind: "apiEndpointId"; /** * @generated from protobuf field: string api_endpoint_id = 5 */ apiEndpointId: string; } | { oneofKind: "topicToTableSyncProcessId"; /** * @generated from protobuf field: string topic_to_table_sync_process_id = 6 */ topicToTableSyncProcessId: string; } | { oneofKind: "materializedViewId"; /** * @generated from protobuf field: string materialized_view_id = 7 */ materializedViewId: string; } | { oneofKind: "viewId"; /** * @generated from protobuf field: string view_id = 8 */ viewId: string; } | { oneofKind: "selectRowPolicyId"; /** * @generated from protobuf field: string select_row_policy_id = 9 */ selectRowPolicyId: string; } | { oneofKind: "olapDictionaryId"; /** * @generated from protobuf field: string olap_dictionary_id = 10 */ olapDictionaryId: string; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.InfrastructureSignature */ declare const InfrastructureSignature: InfrastructureSignature$Type; declare class WebApp$Type extends MessageType { constructor(); create(value?: PartialMessage): WebApp; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WebApp): WebApp; internalBinaryWrite(message: WebApp, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.WebApp */ interface WebApp { /** * @generated from protobuf field: string name = 1 */ name: string; /** * @generated from protobuf field: string mount_path = 2 */ mountPath: string; /** * @generated from protobuf field: optional moose.proto.WebAppMetadata metadata = 3 */ metadata?: WebAppMetadata; /** * Infrastructure components this web app reads data from. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pulls_data_from = 4 */ pullsDataFrom: InfrastructureSignature[]; /** * Infrastructure components this web app writes data to. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pushes_data_to = 5 */ pushesDataTo: InfrastructureSignature[]; } /** * @generated MessageType for protobuf message moose.proto.WebApp */ declare const WebApp: WebApp$Type; declare class WebAppMetadata$Type extends MessageType { constructor(); create(value?: PartialMessage): WebAppMetadata; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WebAppMetadata): WebAppMetadata; internalBinaryWrite(message: WebAppMetadata, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.WebAppMetadata */ interface WebAppMetadata { /** * @generated from protobuf field: optional string description = 1 */ description?: string; } /** * @generated MessageType for protobuf message moose.proto.WebAppMetadata */ declare const WebAppMetadata: WebAppMetadata$Type; declare class Workflow$Type extends MessageType { constructor(); create(value?: PartialMessage): Workflow; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Workflow): Workflow; internalBinaryWrite(message: Workflow, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * @generated from protobuf message moose.proto.Workflow */ interface Workflow { /** * Unique workflow identifier * * @generated from protobuf field: string name = 1 */ name: string; /** * Cron schedule for automatic execution * * @generated from protobuf field: string schedule = 2 */ schedule: string; /** * Number of retry attempts on failure * * @generated from protobuf field: uint32 retries = 3 */ retries: number; /** * Workflow timeout * * @generated from protobuf field: string timeout = 4 */ timeout: string; /** * Programming language of the workflow * * @generated from protobuf field: string language = 5 */ language: string; /** * Infrastructure components this workflow reads data from. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pulls_data_from = 6 */ pullsDataFrom: InfrastructureSignature[]; /** * Infrastructure components this workflow writes data to. * * @generated from protobuf field: repeated moose.proto.InfrastructureSignature pushes_data_to = 7 */ pushesDataTo: InfrastructureSignature[]; } /** * @generated MessageType for protobuf message moose.proto.Workflow */ declare const Workflow: Workflow$Type; declare class SelectRowPolicy$Type extends MessageType { constructor(); create(value?: PartialMessage): SelectRowPolicy; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SelectRowPolicy): SelectRowPolicy; internalBinaryWrite(message: SelectRowPolicy, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * Row-level security policy for ClickHouse * * @generated from protobuf message moose.proto.SelectRowPolicy */ interface SelectRowPolicy { /** * Policy name * * @generated from protobuf field: string name = 1 */ name: string; /** * Tables the policy applies to (with optional per-table database) * * @generated from protobuf field: repeated moose.proto.TableReference tables = 2 */ tables: TableReference[]; /** * Column to filter on * * @generated from protobuf field: string column = 3 */ column: string; /** * JWT claim name that provides the filter value * * @generated from protobuf field: string claim = 4 */ claim: string; } /** * @generated MessageType for protobuf message moose.proto.SelectRowPolicy */ declare const SelectRowPolicy: SelectRowPolicy$Type; declare class DictionaryColumn$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryColumn; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryColumn): DictionaryColumn; internalBinaryWrite(message: DictionaryColumn, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryColumn represents an attribute/column in a ClickHouse dictionary * * @generated from protobuf message moose.proto.DictionaryColumn */ interface DictionaryColumn { /** * Column name * * @generated from protobuf field: string name = 1 */ name: string; /** * ClickHouse type string (e.g., "UInt64", "String", "Nullable(String)") * * @generated from protobuf field: string type_string = 2 */ typeString: string; /** * Default value expression (DEFAULT) * * @generated from protobuf field: optional string default_value = 3 */ defaultValue?: string; /** * Computed expression (EXPRESSION) * * @generated from protobuf field: optional string expression = 4 */ expression?: string; /** * IS_INJECTIVE attribute for optimized GROUP BY * * @generated from protobuf field: optional bool is_injective = 5 */ isInjective?: boolean; /** * IS_HIERARCHICAL attribute for parent-child lookups * * @generated from protobuf field: optional bool is_hierarchical = 6 */ isHierarchical?: boolean; /** * IS_OBJECT_ID attribute (MongoDB only) * * @generated from protobuf field: optional bool is_object_id = 7 */ isObjectId?: boolean; /** * Column comment * * @generated from protobuf field: optional string comment = 8 */ comment?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryColumn */ declare const DictionaryColumn: DictionaryColumn$Type; declare class DictionaryTableSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryTableSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryTableSource): DictionaryTableSource; internalBinaryWrite(message: DictionaryTableSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryTableSource — dictionary reads from a ClickHouse table * * @generated from protobuf message moose.proto.DictionaryTableSource */ interface DictionaryTableSource { /** * Source table name * * @generated from protobuf field: string table = 1 */ table: string; /** * Source database (empty = default database) * * @generated from protobuf field: optional string database = 2 */ database?: string; /** * Optional WHERE clause for row filtering * * @generated from protobuf field: optional string where_clause = 3 */ whereClause?: string; /** * Optional query for checking if data has changed (triggers reload) * * @generated from protobuf field: optional string invalidate_query = 4 */ invalidateQuery?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryTableSource */ declare const DictionaryTableSource: DictionaryTableSource$Type; declare class DictionaryQuerySource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryQuerySource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryQuerySource): DictionaryQuerySource; internalBinaryWrite(message: DictionaryQuerySource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryQuerySource — dictionary reads from an arbitrary SQL query * * @generated from protobuf message moose.proto.DictionaryQuerySource */ interface DictionaryQuerySource { /** * The SELECT query * * @generated from protobuf field: string query = 1 */ query: string; /** * Optional query for checking if data has changed (triggers reload) * * @generated from protobuf field: optional string invalidate_query = 2 */ invalidateQuery?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryQuerySource */ declare const DictionaryQuerySource: DictionaryQuerySource$Type; declare class DictionaryLayout$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryLayout; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryLayout): DictionaryLayout; internalBinaryWrite(message: DictionaryLayout, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryLayout — memory layout and storage model for the dictionary * * @generated from protobuf message moose.proto.DictionaryLayout */ interface DictionaryLayout { /** * @generated from protobuf field: moose.proto.DictionaryLayout.Type type = 1 */ type: DictionaryLayout_Type; /** * Hashed / SparseHashed / ComplexKeyHashed / ComplexKeySparseHashed * * @generated from protobuf field: optional uint64 initial_array_size = 2 */ initialArraySize?: bigint; /** * @generated from protobuf field: optional double max_load_factor = 3 */ maxLoadFactor?: number; /** * HashedArray / ComplexKeyHashedArray * * @generated from protobuf field: optional uint32 shards = 4 */ shards?: number; /** * Cache / SsdCache / ComplexKeyCache / ComplexKeySsdCache * * @generated from protobuf field: optional uint64 size_in_cells = 5 */ sizeInCells?: bigint; /** * @generated from protobuf field: optional uint32 max_threads_for_updates = 6 */ maxThreadsForUpdates?: number; /** * SsdCache / ComplexKeySsdCache * * @generated from protobuf field: optional string ssd_path = 7 */ ssdPath?: string; /** * @generated from protobuf field: optional uint64 block_size = 8 */ blockSize?: bigint; /** * @generated from protobuf field: optional uint64 file_size = 9 */ fileSize?: bigint; /** * @generated from protobuf field: optional uint64 read_buffer_size = 10 */ readBufferSize?: bigint; /** * @generated from protobuf field: optional uint64 write_buffer_size = 11 */ writeBufferSize?: bigint; /** * @generated from protobuf field: optional uint64 max_stored_keys = 12 */ maxStoredKeys?: bigint; /** * IpTrie * * @generated from protobuf field: optional bool access_to_key_from_attributes = 13 */ accessToKeyFromAttributes?: boolean; /** * RangeHashed * * @generated from protobuf field: optional string range_lookup_strategy = 14 */ rangeLookupStrategy?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryLayout */ declare const DictionaryLayout: DictionaryLayout$Type; declare class DictionaryRangeLifetime$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryRangeLifetime; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryRangeLifetime): DictionaryRangeLifetime; internalBinaryWrite(message: DictionaryRangeLifetime, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryRangeLifetime — min/max seconds for range-based refresh * * @generated from protobuf message moose.proto.DictionaryRangeLifetime */ interface DictionaryRangeLifetime { /** * @generated from protobuf field: uint64 min = 1 */ min: bigint; /** * @generated from protobuf field: uint64 max = 2 */ max: bigint; } /** * @generated MessageType for protobuf message moose.proto.DictionaryRangeLifetime */ declare const DictionaryRangeLifetime: DictionaryRangeLifetime$Type; declare class DictionaryLifetime$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryLifetime; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryLifetime): DictionaryLifetime; internalBinaryWrite(message: DictionaryLifetime, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryLifetime — how often dictionary data is refreshed * * @generated from protobuf message moose.proto.DictionaryLifetime */ interface DictionaryLifetime { /** * @generated from protobuf oneof: t */ t: { oneofKind: "staticLifetime"; /** * Static: LIFETIME(0) — never automatically refresh * * @generated from protobuf field: bool static_lifetime = 1 */ staticLifetime: boolean; } | { oneofKind: "single"; /** * Single: LIFETIME(N) — refresh every N seconds * * @generated from protobuf field: uint64 single = 2 */ single: bigint; } | { oneofKind: "range"; /** * Range: LIFETIME(MIN N MAX M) — refresh between min and max seconds * * @generated from protobuf field: moose.proto.DictionaryRangeLifetime range = 3 */ range: DictionaryRangeLifetime; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.DictionaryLifetime */ declare const DictionaryLifetime: DictionaryLifetime$Type; declare class DictionaryHttpSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryHttpSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryHttpSource): DictionaryHttpSource; internalBinaryWrite(message: DictionaryHttpSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryHttpSource — external HTTP source * * @generated from protobuf message moose.proto.DictionaryHttpSource */ interface DictionaryHttpSource { /** * Full URL of the HTTP endpoint serving dictionary data * * @generated from protobuf field: string url = 1 */ url: string; /** * ClickHouse input format (e.g. CSV, JSONEachRow, TSV) * * @generated from protobuf field: string format = 2 */ format: string; /** * HTTP method override; defaults to GET when absent * * @generated from protobuf field: optional string method = 3 */ method?: string; /** * Optional SQL WHERE clause appended to the source query * * @generated from protobuf field: optional string where_clause = 4 */ whereClause?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryHttpSource */ declare const DictionaryHttpSource: DictionaryHttpSource$Type; declare class DictionaryClickHouseSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryClickHouseSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryClickHouseSource): DictionaryClickHouseSource; internalBinaryWrite(message: DictionaryClickHouseSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryClickHouseSource — remote ClickHouse server as source * * @generated from protobuf message moose.proto.DictionaryClickHouseSource */ interface DictionaryClickHouseSource { /** * Hostname or IP of the remote ClickHouse server * * @generated from protobuf field: string host = 1 */ host: string; /** * TCP port of the remote ClickHouse server * * @generated from protobuf field: uint32 port = 2 */ port: number; /** * Username for authentication * * @generated from protobuf field: string user = 3 */ user: string; /** * Password for authentication (masked via strip_dict_metadata() before proto/Redis serialization; not stored in plaintext) * * @generated from protobuf field: string password = 4 */ password: string; /** * Database name on the remote server * * @generated from protobuf field: string db = 5 */ db: string; /** * Table name on the remote server * * @generated from protobuf field: string table = 6 */ table: string; /** * Custom SQL query; overrides table when present * * @generated from protobuf field: optional string query = 7 */ query?: string; /** * SQL WHERE clause appended to the generated SELECT * * @generated from protobuf field: optional string where_clause = 8 */ whereClause?: string; /** * Query whose result change triggers dictionary reload * * @generated from protobuf field: optional string invalidate_query = 9 */ invalidateQuery?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryClickHouseSource */ declare const DictionaryClickHouseSource: DictionaryClickHouseSource$Type; declare class DictionaryMysqlSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryMysqlSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryMysqlSource): DictionaryMysqlSource; internalBinaryWrite(message: DictionaryMysqlSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryMysqlSource — MySQL database as source * * @generated from protobuf message moose.proto.DictionaryMysqlSource */ interface DictionaryMysqlSource { /** * Hostname or IP of the MySQL server * * @generated from protobuf field: string host = 1 */ host: string; /** * TCP port of the MySQL server * * @generated from protobuf field: uint32 port = 2 */ port: number; /** * Username for authentication * * @generated from protobuf field: string user = 3 */ user: string; /** * Password for authentication (masked via strip_dict_metadata() before proto/Redis serialization; not stored in plaintext) * * @generated from protobuf field: string password = 4 */ password: string; /** * Database name * * @generated from protobuf field: string db = 5 */ db: string; /** * Table name * * @generated from protobuf field: string table = 6 */ table: string; /** * Custom SQL query; overrides table when present * * @generated from protobuf field: optional string query = 7 */ query?: string; /** * SQL WHERE clause appended to the generated SELECT * * @generated from protobuf field: optional string where_clause = 8 */ whereClause?: string; /** * Query whose result change triggers dictionary reload * * @generated from protobuf field: optional string invalidate_query = 9 */ invalidateQuery?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryMysqlSource */ declare const DictionaryMysqlSource: DictionaryMysqlSource$Type; declare class DictionaryPostgresqlSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryPostgresqlSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryPostgresqlSource): DictionaryPostgresqlSource; internalBinaryWrite(message: DictionaryPostgresqlSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryPostgresqlSource — PostgreSQL database as source * * @generated from protobuf message moose.proto.DictionaryPostgresqlSource */ interface DictionaryPostgresqlSource { /** * Hostname or IP of the PostgreSQL server * * @generated from protobuf field: string host = 1 */ host: string; /** * TCP port of the PostgreSQL server * * @generated from protobuf field: uint32 port = 2 */ port: number; /** * Username for authentication * * @generated from protobuf field: string user = 3 */ user: string; /** * Password for authentication (masked via strip_dict_metadata() before proto/Redis serialization; not stored in plaintext) * * @generated from protobuf field: string password = 4 */ password: string; /** * Database name * * @generated from protobuf field: string db = 5 */ db: string; /** * Table name * * @generated from protobuf field: string table = 6 */ table: string; /** * Custom SQL query; overrides table when present * * @generated from protobuf field: optional string query = 7 */ query?: string; /** * SQL WHERE clause appended to the generated SELECT * * @generated from protobuf field: optional string where_clause = 8 */ whereClause?: string; /** * Query whose result change triggers dictionary reload * * @generated from protobuf field: optional string invalidate_query = 9 */ invalidateQuery?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryPostgresqlSource */ declare const DictionaryPostgresqlSource: DictionaryPostgresqlSource$Type; declare class DictionaryRedisSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryRedisSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryRedisSource): DictionaryRedisSource; internalBinaryWrite(message: DictionaryRedisSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryRedisSource — Redis as source * * @generated from protobuf message moose.proto.DictionaryRedisSource */ interface DictionaryRedisSource { /** * Hostname or IP of the Redis server * * @generated from protobuf field: string host = 1 */ host: string; /** * TCP port of the Redis server * * @generated from protobuf field: uint32 port = 2 */ port: number; /** * Optional password for Redis AUTH command * * @generated from protobuf field: optional string password = 3 */ password?: string; /** * Redis database index (0-based); defaults to 0 when absent * * @generated from protobuf field: optional uint32 db_index = 4 */ dbIndex?: number; /** * Storage type: simple, hash, range_hashed, etc. * * @generated from protobuf field: string storage_type = 5 */ storageType: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryRedisSource */ declare const DictionaryRedisSource: DictionaryRedisSource$Type; declare class DictionaryMongoDbSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryMongoDbSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryMongoDbSource): DictionaryMongoDbSource; internalBinaryWrite(message: DictionaryMongoDbSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryMongoDbSource — MongoDB as source * * @generated from protobuf message moose.proto.DictionaryMongoDbSource */ interface DictionaryMongoDbSource { /** * Hostname or IP of the MongoDB server * * @generated from protobuf field: string host = 1 */ host: string; /** * TCP port of the MongoDB server * * @generated from protobuf field: uint32 port = 2 */ port: number; /** * Username for authentication * * @generated from protobuf field: string user = 3 */ user: string; /** * Password for authentication (masked via strip_dict_metadata() before proto/Redis serialization; not stored in plaintext) * * @generated from protobuf field: string password = 4 */ password: string; /** * Database name * * @generated from protobuf field: string db = 5 */ db: string; /** * Collection name * * @generated from protobuf field: string collection = 6 */ collection: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryMongoDbSource */ declare const DictionaryMongoDbSource: DictionaryMongoDbSource$Type; declare class DictionaryExecutableSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryExecutableSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryExecutableSource): DictionaryExecutableSource; internalBinaryWrite(message: DictionaryExecutableSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryExecutableSource — external executable as source * * @generated from protobuf message moose.proto.DictionaryExecutableSource */ interface DictionaryExecutableSource { /** * Shell command to execute; must emit records on stdout * * @generated from protobuf field: string command = 1 */ command: string; /** * ClickHouse input format of the executable output (e.g. TabSeparated) * * @generated from protobuf field: string format = 2 */ format: string; /** * When true, the first column is used implicitly as the dictionary key * * @generated from protobuf field: optional bool implicit_key = 3 */ implicitKey?: boolean; } /** * @generated MessageType for protobuf message moose.proto.DictionaryExecutableSource */ declare const DictionaryExecutableSource: DictionaryExecutableSource$Type; declare class DictionaryS3Source$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryS3Source; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryS3Source): DictionaryS3Source; internalBinaryWrite(message: DictionaryS3Source, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryS3Source — S3 object storage as source * * @generated from protobuf message moose.proto.DictionaryS3Source */ interface DictionaryS3Source { /** * S3 URL (s3://bucket/path or https://endpoint/bucket/path) * * @generated from protobuf field: string url = 1 */ url: string; /** * ClickHouse input format of the S3 object (e.g. Parquet, CSV) * * @generated from protobuf field: string format = 2 */ format: string; /** * AWS access key ID; omit to use instance profile / environment credentials * * @generated from protobuf field: optional string access_key_id = 3 */ accessKeyId?: string; /** * AWS secret access key (masked via strip_dict_metadata() before proto/Redis serialization; not stored in plaintext) * * @generated from protobuf field: optional string secret_access_key = 4 */ secretAccessKey?: string; } /** * @generated MessageType for protobuf message moose.proto.DictionaryS3Source */ declare const DictionaryS3Source: DictionaryS3Source$Type; declare class DictionaryExternalSource$Type extends MessageType { constructor(); create(value?: PartialMessage): DictionaryExternalSource; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DictionaryExternalSource): DictionaryExternalSource; internalBinaryWrite(message: DictionaryExternalSource, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * DictionaryExternalSource — union of all supported external sources * * @generated from protobuf message moose.proto.DictionaryExternalSource */ interface DictionaryExternalSource { /** * @generated from protobuf oneof: t */ t: { oneofKind: "http"; /** * @generated from protobuf field: moose.proto.DictionaryHttpSource http = 1 */ http: DictionaryHttpSource; } | { oneofKind: "clickhouse"; /** * @generated from protobuf field: moose.proto.DictionaryClickHouseSource clickhouse = 2 */ clickhouse: DictionaryClickHouseSource; } | { oneofKind: "mysql"; /** * @generated from protobuf field: moose.proto.DictionaryMysqlSource mysql = 3 */ mysql: DictionaryMysqlSource; } | { oneofKind: "postgresql"; /** * @generated from protobuf field: moose.proto.DictionaryPostgresqlSource postgresql = 4 */ postgresql: DictionaryPostgresqlSource; } | { oneofKind: "redis"; /** * @generated from protobuf field: moose.proto.DictionaryRedisSource redis = 5 */ redis: DictionaryRedisSource; } | { oneofKind: "mongodb"; /** * @generated from protobuf field: moose.proto.DictionaryMongoDbSource mongodb = 6 */ mongodb: DictionaryMongoDbSource; } | { oneofKind: "executable"; /** * @generated from protobuf field: moose.proto.DictionaryExecutableSource executable = 7 */ executable: DictionaryExecutableSource; } | { oneofKind: "s3"; /** * @generated from protobuf field: moose.proto.DictionaryS3Source s3 = 8 */ s3: DictionaryS3Source; } | { oneofKind: undefined; }; } /** * @generated MessageType for protobuf message moose.proto.DictionaryExternalSource */ declare const DictionaryExternalSource: DictionaryExternalSource$Type; declare class OlapDictionary$Type extends MessageType { constructor(); create(value?: PartialMessage): OlapDictionary; internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OlapDictionary): OlapDictionary; private binaryReadMap12; internalBinaryWrite(message: OlapDictionary, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; } /** * OlapDictionary — a ClickHouse Dictionary definition * * @generated from protobuf message moose.proto.OlapDictionary */ interface OlapDictionary { /** * Dictionary name * * @generated from protobuf field: string name = 1 */ name: string; /** * Database where the dictionary is created (empty = default database) * * @generated from protobuf field: optional string database = 2 */ database?: string; /** * Optional ON CLUSTER name for distributed deployments * * @generated from protobuf field: optional string cluster_name = 3 */ clusterName?: string; /** * Source: exactly one must be set * * @generated from protobuf oneof: source */ source: { oneofKind: "tableSource"; /** * @generated from protobuf field: moose.proto.DictionaryTableSource table_source = 4 */ tableSource: DictionaryTableSource; } | { oneofKind: "querySource"; /** * @generated from protobuf field: moose.proto.DictionaryQuerySource query_source = 5 */ querySource: DictionaryQuerySource; } | { oneofKind: "externalSource"; /** * @generated from protobuf field: moose.proto.DictionaryExternalSource external_source = 6 */ externalSource: DictionaryExternalSource; } | { oneofKind: undefined; }; /** * Primary key column names (single-column = simple key, multi-column = complex key) * * @generated from protobuf field: repeated string primary_key = 7 */ primaryKey: string[]; /** * Dictionary attribute columns * * @generated from protobuf field: repeated moose.proto.DictionaryColumn columns = 8 */ columns: DictionaryColumn[]; /** * Layout type and configuration * * @generated from protobuf field: moose.proto.DictionaryLayout layout = 9 */ layout?: DictionaryLayout; /** * Lifetime / refresh policy * * @generated from protobuf field: moose.proto.DictionaryLifetime lifetime = 10 */ lifetime?: DictionaryLifetime; /** * Optional invalidation query (checked before reload; if unchanged, skip) * * @generated from protobuf field: optional string invalidate_query = 11 */ invalidateQuery?: string; /** * Dictionary-level settings map * * @generated from protobuf field: map settings = 12 */ settings: { [key: string]: string; }; /** * Optional COMMENT clause * * @generated from protobuf field: optional string comment = 13 */ comment?: string; /** * Lifecycle management policy * * @generated from protobuf field: moose.proto.LifeCycle life_cycle = 14 */ lifeCycle: LifeCycle; /** * Optional metadata (description, source file) * * @generated from protobuf field: optional moose.proto.Metadata metadata = 15 */ metadata?: Metadata; /** * Optional version string (e.g. "0.1"). When set, the version suffix is baked * into `name` (e.g. "my_dict_0_1") so versioned dictionaries are distinct objects. * * @generated from protobuf field: optional string version = 16 */ version?: string; } /** * @generated MessageType for protobuf message moose.proto.OlapDictionary */ declare const OlapDictionary: OlapDictionary$Type; export { ApiEndpoint, Column, ColumnType, ConsumptionQueryParam, DataEnum, DateType, Decimal, DictionaryClickHouseSource, DictionaryColumn, DictionaryExecutableSource, DictionaryExternalSource, DictionaryHttpSource, DictionaryLayout, DictionaryLayout_Type, DictionaryLifetime, DictionaryMongoDbSource, DictionaryMysqlSource, DictionaryPostgresqlSource, DictionaryQuerySource, DictionaryRangeLifetime, DictionaryRedisSource, DictionaryS3Source, DictionaryTableSource, Dmv1View, EgressDetails, EndpointIngestionFormat, EnumMember, EnumValue, FloatType, FunctionProcess, InfrastructureMap, InfrastructureSignature, IngressDetails, InitialDataLoad, IntType, Json, JsonTypedPath, LifeCycle, Map, MaterializedView, Metadata, Method, Nested, OlapDictionary, OrchestrationWorker, OrderBy, OrderByFields, PrimitiveSignature, PrimitiveTypes, SchemaRegistry, SchemaRegistry_Encoding, SeedFilter, SelectQuery, SelectRowPolicy, SimpleColumnType, SourceLocation, SqlResource, SubjectVersion, Table, TableAlias, TableConstraint, TableIndex, TableProjection, TableReference, Topic, TopicToTableSyncProcess, TopicToTopicSyncProcess, Tuple, View, WebApp, WebAppMetadata, Workflow };