package mz_storage_client.client

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc CommandResponseStream (stream ProtoStorageCommand, stream ProtoStorageResponse)

  client.proto:31

  message ProtoStorageCommand

  client.proto:62

  • oneof kind

    • ProtoStorageCommand.ProtoCreateTimely create_timely = 6

    • ProtoRunIngestionCommand run_ingestion = 1

    • ProtoCompaction allow_compaction = 2

    • google.protobuf.Empty initialization_complete = 3

    • google.protobuf.Empty allow_writes = 7

    • ProtoRunSinkCommand run_sink = 4

    • mz_storage_types.parameters.ProtoStorageParameters update_configuration = 5

    • ProtoRunOneshotIngestion run_oneshot_ingestion = 10

    • mz_proto.ProtoU128 cancel_oneshot_ingestion = 11

  message ProtoStorageResponse

  client.proto:81

  • oneof kind

    • ProtoStorageResponse.ProtoFrontierUpper frontier_upper = 1

    • ProtoStorageResponse.ProtoDroppedId dropped_id = 2

    • ProtoStorageResponse.ProtoStatisticsUpdates stats = 3

    • ProtoStorageResponse.ProtoStatusUpdate status_update = 4

    • ProtoStorageResponse.ProtoStagedBatches staged_batches = 5

Used in: mz_compute_client.protocol.command.ProtoComputeCommand, ProtoStorageCommand

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional mz_repr.antichain.ProtoU64Antichain frontier = 2

Used in: ProtoStorageCommand

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional mz_storage_types.sources.ProtoIngestionDescription description = 2

Used in: ProtoStorageCommand

• optional mz_proto.ProtoU128 ingestion_id = 1

• optional mz_repr.global_id.ProtoGlobalId collection_id = 2

• optional mz_storage_types.controller.ProtoCollectionMetadata storage_metadata = 3

• optional mz_storage_types.oneshot_sources.ProtoOneshotIngestionRequest request = 4

Used in: ProtoStorageCommand

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional mz_storage_types.sinks.ProtoStorageSinkDesc description = 2

Used in: ProtoStorageCommand

• optional mz_cluster_client.client.ProtoTimelyConfig config = 1

• optional mz_cluster_client.client.ProtoClusterStartupEpoch epoch = 2

Used in: ProtoStorageResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

Used in: ProtoStorageResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional mz_repr.antichain.ProtoU64Antichain upper = 2

Used in: ProtoStorageResponse

• repeated ProtoStagedBatches.Inner batches = 1

Used in: Inner

• oneof value

  • mz_persist_client.batch.ProtoBatch batch = 1

  • string error = 2

Used in: ProtoStagedBatches

• optional mz_proto.ProtoU128 id = 1

• repeated BatchResult batches = 2

Used in: ProtoStorageResponse

• repeated statistics.ProtoSourceStatisticsUpdate source_updates = 1

• repeated statistics.ProtoSinkStatisticsUpdate sink_updates = 2

Used in: ProtoStatusUpdate

• oneof kind

  • google.protobuf.Empty starting = 1

  • google.protobuf.Empty running = 2

  • google.protobuf.Empty paused = 3

  • google.protobuf.Empty stalled = 4

  • google.protobuf.Empty ceased = 5

  • google.protobuf.Empty dropped = 6

Used in: ProtoStorageResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional ProtoStatus status = 2

• optional mz_proto.chrono.ProtoNaiveDateTime timestamp = 3

• optional string error = 4

• repeated string hints = 5

• map<string, string> namespaced_errors = 6

• optional string replica_id = 7