Module catalog

Modules§

connection: Nested message and enum types in Connection.
connection_params: Nested message and enum types in ConnectionParams.
function: Nested message and enum types in Function.
source: Nested message and enum types in Source.
subscription: Nested message and enum types in Subscription.
table: Nested message and enum types in Table.

Structs§

ColIndexMapping: A mapping of column indices.
Comment
Connection
ConnectionParams
Database
Function
Index
IndexColumnProperties: https://www.postgresql.org/docs/current/functions-info.html#FUNCTIONS-INFO-INDEX-COLUMN-PROPS
OptionsWithSecret
Schema
Secret
Sink: the catalog of the sink. There are two kind of schema here. The full schema is all columns stored in the column which is the sink executor/fragment’s output schema. The visible schema contains the columns whose is_hidden is false, which is the columns sink out to the external system. The distribution key and all other keys are indexed in the full schema.
SinkFormatDesc: Similar to StreamSourceInfo, and may replace SinkType later.
Source
StreamSourceInfo
Subscription
Table: Includes full information about a table.
View
WatermarkDesc
WebhookSourceInfo

Enums§

CreateType: How the stream job was created will determine whether they are persisted.
HandleConflictBehavior
SchemaRegistryNameStrategy
SinkType
StreamJobStatus

Type Aliases§

PbColIndexMapping: Alias for ColIndexMapping.
PbComment: Alias for Comment.
PbConnection: Alias for Connection.
PbConnectionParams: Alias for ConnectionParams.
PbCreateType: Alias for CreateType.
PbDatabase: Alias for Database.
PbFunction: Alias for Function.
PbHandleConflictBehavior: Alias for HandleConflictBehavior.
PbIndex: Alias for Index.
PbIndexColumnProperties: Alias for IndexColumnProperties.
PbOptionsWithSecret: Alias for OptionsWithSecret.
PbSchema: Alias for Schema.
PbSchemaRegistryNameStrategy: Alias for SchemaRegistryNameStrategy.
PbSecret: Alias for Secret.
PbSink: Alias for Sink.
PbSinkFormatDesc: Alias for SinkFormatDesc.
PbSinkType: Alias for SinkType.
PbSource: Alias for Source.
PbStreamJobStatus: Alias for StreamJobStatus.
PbStreamSourceInfo: Alias for StreamSourceInfo.
PbSubscription: Alias for Subscription.
PbTable: Alias for Table.
PbView: Alias for View.
PbWatermarkDesc: Alias for WatermarkDesc.
PbWebhookSourceInfo: Alias for WebhookSourceInfo.