(r orca.ServerMetricsRecorder, orcaData *testpb.TestOrcaReport)
| 754 | } |
| 755 | |
| 756 | func setORCAMetrics(r orca.ServerMetricsRecorder, orcaData *testpb.TestOrcaReport) { |
| 757 | r.SetCPUUtilization(orcaData.CpuUtilization) |
| 758 | r.SetMemoryUtilization(orcaData.MemoryUtilization) |
| 759 | if rq, ok := r.(orca.CallMetricsRecorder); ok { |
| 760 | for k, v := range orcaData.RequestCost { |
| 761 | rq.SetRequestCost(k, v) |
| 762 | } |
| 763 | } |
| 764 | for k, v := range orcaData.Utilization { |
| 765 | r.SetNamedUtilization(k, v) |
| 766 | } |
| 767 | } |
| 768 | |
| 769 | func (s *testServer) StreamingOutputCall(args *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error { |
| 770 | cs := args.GetResponseParameters() |
no test coverage detected