| 448 | /// correctly answer the `Peek`. |
| 449 | #[derive(Clone, Debug, PartialEq, Serialize, Deserialize)] |
| 450 | pub struct Peek { |
| 451 | /// Target-specific metadata. |
| 452 | pub target: PeekTarget, |
| 453 | /// The relation description for the rows returned by this peek, before |
| 454 | /// applying the [RowSetFinishing] but _after_ applying the given |
| 455 | /// `map_filter_project`. |
| 456 | pub result_desc: RelationDesc, |
| 457 | /// If `Some`, then look up only the given keys from the collection (instead of a full scan). |
| 458 | /// The vector is never empty. |
| 459 | pub literal_constraints: Option<Vec<Row>>, |
| 460 | /// The identifier of this peek request. |
| 461 | /// |
| 462 | /// Used in responses and cancellation requests. |
| 463 | pub uuid: Uuid, |
| 464 | /// The logical timestamp at which the collection is queried. |
| 465 | pub timestamp: Timestamp, |
| 466 | /// Actions to apply to the result set before returning them. |
| 467 | pub finishing: RowSetFinishing, |
| 468 | /// Linear operation to apply in-line on each result. |
| 469 | pub map_filter_project: mz_expr::SafeMfpPlan, |
| 470 | /// An `OpenTelemetryContext` to forward trace information along |
| 471 | /// to the compute worker to allow associating traces between |
| 472 | /// the compute controller and the compute worker. |
| 473 | pub otel_ctx: OpenTelemetryContext, |
| 474 | } |
| 475 | |
| 476 | impl TryIntoProtocolNonce for ComputeCommand { |
| 477 | fn try_into_protocol_nonce(self) -> Result<Uuid, Self> { |
no outgoing calls
no test coverage detected