(_ *callInfo, attempt *csAttempt)
| 326 | |
| 327 | func (o PeerCallOption) before(*callInfo) error { return nil } |
| 328 | func (o PeerCallOption) after(_ *callInfo, attempt *csAttempt) { |
| 329 | if x, ok := peer.FromContext(attempt.transportStream.Context()); ok { |
| 330 | *o.PeerAddr = *x |
| 331 | } |
| 332 | } |
| 333 | |
| 334 | // WaitForReady configures the RPC's behavior when the client is in |
| 335 | // TRANSIENT_FAILURE, which occurs when all addresses fail to connect. If |
nothing calls this directly
no test coverage detected