(_ context.Context, conn *pool.Conn, _ error)
| 177 | } |
| 178 | |
| 179 | func (ph *PoolHook) OnRemove(_ context.Context, conn *pool.Conn, _ error) { |
| 180 | if tracker, ok := ph.operationsManager.(maintNotificationsConnTracker); ok && conn != nil { |
| 181 | tracker.UntrackMaintNotificationsConn(conn.GetID()) |
| 182 | } |
| 183 | } |
| 184 | |
| 185 | // Shutdown gracefully shuts down the processor, waiting for workers to complete |
| 186 | func (ph *PoolHook) Shutdown(ctx context.Context) error { |
nothing calls this directly
no test coverage detected