(r *http.Request)
| 31 | ) |
| 32 | |
| 33 | func GetServiceName(r *http.Request) string { |
| 34 | // provided by the gRPC client through WithAuthority(...) call |
| 35 | return r.Host |
| 36 | } |
| 37 | |
| 38 | func giveBackCCCapacity(endpoint *common.UpstreamEndpoint) { |
| 39 | endpointInflight := atomic.AddInt32(&endpoint.InFlight, -1) |
no outgoing calls
no test coverage detected