Module: Etl::Integrations::Protocol

Included in:

Core::BaseConnector

Defined in:

lib/etl/integrations/protocol/protocol.rb

Defined Under Namespace

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

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")

ModelQueryType =

Types::String.enum("raw_sql", "dbt", "soql")

ConnectionStatusType =

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

StreamType =

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

StreamAction =

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

MultiwovenMessageType =

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")