probeDial emits a [PROBE/dial] log for upstream dial timing.
(logger *zap.Logger, phase string, connID int64, addr string, durNs int64, fields ...zap.Field)
| 96 | |
| 97 | // probeDial emits a [PROBE/dial] log for upstream dial timing. |
| 98 | func probeDial(logger *zap.Logger, phase string, connID int64, addr string, durNs int64, fields ...zap.Field) { |
| 99 | if !probeOn() { |
| 100 | return |
| 101 | } |
| 102 | base := []zap.Field{ |
| 103 | zap.String("probe", "dial"), |
| 104 | zap.String("phase", phase), |
| 105 | zap.Int64("connID", connID), |
| 106 | zap.String("addr", addr), |
| 107 | zap.Int64("dur_ns", durNs), |
| 108 | zap.Int64("ts_ns", time.Now().UnixNano()), |
| 109 | } |
| 110 | logger.Info("[PROBE/dial]", append(base, fields...)...) |
| 111 | } |
| 112 | |
| 113 | type Proxy struct { |
| 114 | logger *zap.Logger |
no test coverage detected