CloseAll closes all remaining gRPC connections.
()
| 181 | |
| 182 | // CloseAll closes all remaining gRPC connections. |
| 183 | func CloseAll() { |
| 184 | connMu.Lock() |
| 185 | defer connMu.Unlock() |
| 186 | for target, conn := range conns { |
| 187 | delete(conns, target) |
| 188 | if conn == nil { |
| 189 | continue |
| 190 | } |
| 191 | conn.Close() |
| 192 | } |
| 193 | } |
| 194 | |
| 195 | // Retry defines retry logic for gRPC calls. |
| 196 | type Retry[T proto.Message] struct { |