TestORCAPerRPCReport verifies that per-call ORCA load reports flow from the server through the orcaPicker's Done callback into the context.
(t *testing.T)
| 100 | // TestORCAPerRPCReport verifies that per-call ORCA load reports flow from the |
| 101 | // server through the orcaPicker's Done callback into the context. |
| 102 | func (s) TestORCAPerRPCReport(t *testing.T) { |
| 103 | ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout) |
| 104 | defer cancel() |
| 105 | |
| 106 | srv := startORCAServer(t) |
| 107 | if err := srv.StartClient(grpc.WithDefaultServiceConfig(orcaSvcConfig())); err != nil { |
| 108 | t.Fatalf("Error starting client: %v", err) |
| 109 | } |
| 110 | |
| 111 | DoORCAPerRPCTest(ctx, srv.Client) |
| 112 | } |
| 113 | |
| 114 | // TestORCAOOBReport verifies that OOB ORCA load reports flow through |
| 115 | // OnLoadReport and are returned by the picker when no per-call report is |
nothing calls this directly
no test coverage detected