(err error)
| 346 | } |
| 347 | |
| 348 | func (c *controllableConn) breakWith(err error) { |
| 349 | c.mu.Lock() |
| 350 | c.readErr = err |
| 351 | c.mu.Unlock() |
| 352 | c.Conn.Close() |
| 353 | } |
| 354 | |
| 355 | // runDisconnectLabelTest sets up a pickfirst balancer and a basic OpenTelemetry |
| 356 | // environment to test the "grpc.disconnect_error" label on subchannel disconnections. |
no test coverage detected