Module: Outhad::Integrations::Protocol

Included in:

Core::BaseConnector

Defined in:

lib/outhad/integrations/protocol/protocol.rb

Defined Under Namespace

Modules: Types Classes: Catalog, ConnectionStatus, Connector, ConnectorSpecification, ControlMessage, LogMessage, Model, OuthadMessage, ProtocolModel, RecordMessage, Stream, SyncConfig, TrackingMessage, VectorConfig

Constant Summary

SyncMode =

Types::String.enum("full_refresh", "incremental")

SyncStatus =

Types::String.enum("started", "running", "complete", "incomplete")

DestinationSyncMode =

Types::String.enum("insert", "upsert")

ConnectorType =

Types::String.enum("source", "destination")

ConnectorQueryType =

Types::String.enum("raw_sql", "soql", "ai_ml", "vector_search")

ModelQueryType =

Types::String.enum("raw_sql", "dbt", "soql", "table_selector", "ai_ml", "dynamic_sql", "unstructured", "vector_search")

ConnectionStatusType =

Types::String.enum("succeeded", "failed")

StreamType =

Types::String.enum("static", "dynamic", "user_defined")

StreamAction =

Types::String.enum("fetch", "create", "update", "delete")

OuthadMessageType =

Types::String.enum(
  "record", "log", "connector_spec",
  "connection_status", "catalog", "control",
  "tracking"
)

ControlMessageType =

Types::String.enum(
  "rate_limit", "connection_config", "full_refresh"
)

LogLevel =

Types::String.enum("fatal", "error", "warn", "info", "debug", "trace")

RequestRateLimitingUnit =

Types::String.default("minute").enum("minute", "hour", "day")

SchemaMode =

Types::String.enum("schema", "schemaless")

FileFormatType =

Types::String.enum("csv")

CompressionType =

Types::String.enum("un_compressed", "zip")