package mz_storage_types.sources

Get desktop application:
View/edit binary Protocol Buffers messages

• oneof kind

  • google.protobuf.Empty gzip = 1

  • google.protobuf.Empty none = 2

Used in: mz_storage_client.client.ProtoRunIngestionCommand

• repeated ProtoIngestionDescription.ProtoSourceExport source_exports = 2

  repeated ProtoSourceImport source_imports = 1;

• optional controller.ProtoCollectionMetadata ingestion_metadata = 3

• optional ProtoSourceDesc desc = 4

• optional instances.ProtoStorageInstanceId instance_id = 6

• optional mz_repr.global_id.ProtoGlobalId remap_collection_id = 7

Used in: ProtoIngestionDescription

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional controller.ProtoCollectionMetadata storage_metadata = 3

• optional ProtoSourceExportDetails details = 5

• optional ProtoSourceExportDataConfig data_config = 6

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional controller.ProtoCollectionMetadata storage_metadata = 2

• uint64 offset = 1

Used in: ProtoSourceDesc

• oneof kind

  • kafka.ProtoKafkaSourceConnection kafka = 1

  • postgres.ProtoPostgresSourceConnection postgres = 4

  • load_generator.ProtoLoadGeneratorSourceConnection loadgen = 6

  • mysql.ProtoMySqlSourceConnection mysql = 8

  • sql_server.ProtoSqlServerSource sql_server = 9

• oneof kind

  • mz_repr.row.ProtoRow ok = 1

  • errors.ProtoDataflowError err = 2

Used in: ProtoIngestionDescription

• optional ProtoSourceConnection connection = 1

• optional mz_proto.ProtoDuration timestamp_interval = 5

• optional ProtoSourceExportDataConfig primary_export = 6

• optional ProtoSourceExportDetails primary_export_details = 7

Used in: ProtoIngestionDescription.ProtoSourceExport, ProtoSourceDesc

• optional encoding.ProtoSourceDataEncoding encoding = 1

• optional envelope.ProtoSourceEnvelope envelope = 2

Used in: ProtoIngestionDescription.ProtoSourceExport, ProtoSourceDesc

• oneof kind

  • kafka.ProtoKafkaSourceExportDetails kafka = 1

  • postgres.ProtoPostgresSourceExportDetails postgres = 2

  • mysql.ProtoMySqlSourceExportDetails mysql = 3

  • sql_server.ProtoSqlServerSourceExportDetails sql_server = 5

  • load_generator.ProtoLoadGeneratorSourceExportDetails loadgen = 4

NOTE: this message is encoded and stored as part of a source export statement option (currently only `CREATE SUBSOURCE` statements) Be extra careful about changes, ensuring that all changes are backwards compatible

• oneof kind

  • postgres.ProtoPostgresSourceExportStatementDetails postgres = 1

  • mysql.ProtoMySqlSourceExportStatementDetails mysql = 2

  • sql_server.ProtoSqlServerSourceExportStatementDetails sql_server = 5

  • load_generator.ProtoLoadGeneratorSourceExportStatementDetails loadgen = 3

  • kafka.ProtoKafkaSourceExportStatementDetails kafka = 4

• oneof kind

  • google.protobuf.Empty epoch_milliseconds = 1

  • string external = 2

  • string user = 3