| 512 | } |
| 513 | |
| 514 | fn make_request_for_db(vshard: u32, db: u64, req_id: u64) -> envelope::Request { |
| 515 | envelope::Request { |
| 516 | request_id: RequestId::new(req_id), |
| 517 | tenant_id: TenantId::new(1), |
| 518 | database_id: DatabaseId::new(db), |
| 519 | vshard_id: VShardId::new(vshard), |
| 520 | plan: PhysicalPlan::Document(DocumentOp::PointGet { |
| 521 | collection: "c".into(), |
| 522 | document_id: "d".into(), |
| 523 | surrogate: nodedb_types::Surrogate::ZERO, |
| 524 | pk_bytes: Vec::new(), |
| 525 | rls_filters: Vec::new(), |
| 526 | system_as_of_ms: None, |
| 527 | valid_at_ms: None, |
| 528 | }), |
| 529 | deadline: Instant::now() + Duration::from_secs(5), |
| 530 | priority: Priority::Normal, |
| 531 | trace_id: TraceId::ZERO, |
| 532 | consistency: ReadConsistency::Strong, |
| 533 | idempotency_key: None, |
| 534 | event_source: crate::event::EventSource::User, |
| 535 | user_roles: Vec::new(), |
| 536 | user_id: None, |
| 537 | statement_digest: None, |
| 538 | } |
| 539 | } |
| 540 | |
| 541 | #[test] |
| 542 | fn dispatch_routes_to_correct_core() { |