| 485 | use std::time::{Duration, Instant}; |
| 486 | |
| 487 | fn make_request(vshard: u32) -> envelope::Request { |
| 488 | envelope::Request { |
| 489 | request_id: RequestId::new(1), |
| 490 | tenant_id: TenantId::new(1), |
| 491 | database_id: DatabaseId::DEFAULT, |
| 492 | vshard_id: VShardId::new(vshard), |
| 493 | plan: PhysicalPlan::Document(DocumentOp::PointGet { |
| 494 | collection: "users".into(), |
| 495 | document_id: "u1".into(), |
| 496 | surrogate: nodedb_types::Surrogate::ZERO, |
| 497 | pk_bytes: Vec::new(), |
| 498 | rls_filters: Vec::new(), |
| 499 | system_as_of_ms: None, |
| 500 | valid_at_ms: None, |
| 501 | }), |
| 502 | deadline: Instant::now() + Duration::from_secs(5), |
| 503 | priority: Priority::Normal, |
| 504 | trace_id: TraceId::ZERO, |
| 505 | consistency: ReadConsistency::Strong, |
| 506 | idempotency_key: None, |
| 507 | event_source: crate::event::EventSource::User, |
| 508 | user_roles: Vec::new(), |
| 509 | user_id: None, |
| 510 | statement_digest: None, |
| 511 | } |
| 512 | } |
| 513 | |
| 514 | fn make_request_for_db(vshard: u32, db: u64, req_id: u64) -> envelope::Request { |
| 515 | envelope::Request { |