package mz_compute_client.protocol.response

Get desktop application:
View/edit binary Protocol Buffers messages

Used as response type in: service.ProtoCompute.CommandResponseStream

• oneof kind

  • ProtoComputeResponse.ProtoFrontiersKind frontiers = 1

  • ProtoComputeResponse.ProtoPeekResponseKind peek_response = 2

  • ProtoComputeResponse.ProtoSubscribeResponseKind subscribe_response = 3

  • ProtoComputeResponse.ProtoCopyToResponseKind copy_to_response = 4

  • ProtoStatusResponse status = 5

Used in: ProtoComputeResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional ProtoCopyToResponse resp = 2

Used in: ProtoComputeResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional ProtoFrontiersResponse resp = 2

Used in: ProtoComputeResponse

• optional mz_proto.ProtoU128 id = 1

• optional ProtoPeekResponse resp = 2

• map<string, string> otel_ctx = 3

Used in: ProtoComputeResponse

• optional mz_repr.global_id.ProtoGlobalId id = 1

• optional ProtoSubscribeResponse resp = 2

Used in: ProtoComputeResponse.ProtoCopyToResponseKind

• oneof kind

  • uint64 rows = 1

  • string error = 2

  • google.protobuf.Empty dropped = 3

Used in: ProtoComputeResponse.ProtoFrontiersKind

• optional mz_repr.antichain.ProtoU64Antichain write_frontier = 1

• optional mz_repr.antichain.ProtoU64Antichain input_frontier = 2

• optional mz_repr.antichain.ProtoU64Antichain output_frontier = 3

Used in: ProtoStatusResponse

• optional mz_repr.global_id.ProtoGlobalId collection_id = 1

• uint64 lir_id = 2

• uint64 worker_id = 3

• bool hydrated = 4

Used in: ProtoComputeResponse.ProtoPeekResponseKind

• oneof kind

  • mz_expr.row.collection.ProtoRowCollection rows = 1

  • string error = 2

  • google.protobuf.Empty canceled = 3

Used in: ProtoComputeResponse

• oneof kind

  • ProtoOperatorHydrationStatus operator_hydration = 1

Used in: ProtoSubscribeResponse

• optional mz_repr.antichain.ProtoU64Antichain lower = 1

• optional mz_repr.antichain.ProtoU64Antichain upper = 2

• optional ProtoSubscribeBatch.ProtoSubscribeBatchContents updates = 4

Used in: ProtoSubscribeBatch

• oneof kind

  • ProtoSubscribeUpdates updates = 1

  • string error = 2

Used in: ProtoSubscribeBatchContents

• repeated ProtoUpdate updates = 1

Used in: ProtoSubscribeUpdates

• uint64 timestamp = 1

• optional mz_repr.row.ProtoRow row = 2

• int64 diff = 3

Used in: ProtoComputeResponse.ProtoSubscribeResponseKind

• oneof kind

  • ProtoSubscribeBatch batch = 1

  • mz_repr.antichain.ProtoU64Antichain dropped_at = 2