Function mixed_points

pulse-proxy/src/test/integration/multi_node.rs:265–308

()

#[tokio::test]
async fn mixed_points() {
  let (bind_resolver, helper1, helper2) = start_multi_node().await;
  let mut upstream1 = FakeWireUpstream::new("fake_upstream1", bind_resolver.clone()).await;
  let mut upstream2 = FakeWireUpstream::new("fake_upstream2", bind_resolver.clone()).await;
  let mut stream1 = TcpStream::connect(bind_resolver.local_tcp_addr("inflow:tcp_2"))
    .await
    .unwrap();
  let mut stream2 = TcpStream::connect(bind_resolver.local_tcp_addr("inflow:tcp_2"))
    .await
    .unwrap();

  let lines = &[
    "node_request.count 123 0 source=server-0\n",
    "node_request.500.sum 234 0 source=server-0\n",
    "node_request.failure.count 25 1 source=server-0\n",
    "node_request.count 120 1 source=server-0\n",
    "node_request.500.sum 0 2 source=server-0\n",
    "node_request.500.sum 20 3 source=server-0\n",
    "node_request.count 120 2 source=server-0\n",
    "node_request.other_request.timer.p95 12345.938 3 source=server-0\n",
    "node_request.other_request.timer.p95 5.938 4 source=server-0\n",
    "node_request.count 130 4 source=server-0\n",
    "node_request.count 140 5 source=server-0\n",
    "node_request.other_request.timer.p95 1E-6 5 source=server-0\n",
    "node_request.failure.count 35 6 source=server-0\n",
    "node_request.count 15 7 source=server-0\n",
  ];

  for (i, line) in lines.iter().enumerate() {
    if i % 2 == 0 {
      write_all(&mut stream1, &[line]).await;
    } else {
      write_all(&mut stream2, &[line]).await;
    }
  }

  let mut metrics = upstream1.wait_for_metrics().await;
  metrics.extend(upstream2.wait_for_metrics().await);
  // TODO(mattklein123): Actually compare the metrics above.
  assert_eq!(lines.len(), metrics.len());

  helper1.shutdown().await;
  helper2.shutdown().await;
}

fmt_reuse! {
HEALTH_CHECK = r#"