|
7 | 7 | "testing" |
8 | 8 | "time" |
9 | 9 |
|
10 | | - "github.com/redis/go-redis/v9/hitless" |
| 10 | + "github.com/redis/go-redis/v9/maintnotifications" |
11 | 11 | "github.com/redis/go-redis/v9/internal/pool" |
12 | 12 | "github.com/redis/go-redis/v9/logging" |
13 | 13 | ) |
@@ -42,7 +42,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
42 | 42 | } |
43 | 43 |
|
44 | 44 | // Create processor with event-driven handoff support |
45 | | - processor := hitless.NewPoolHook(baseDialer, "tcp", nil, nil) |
| 45 | + processor := maintnotifications.NewPoolHook(baseDialer, "tcp", nil, nil) |
46 | 46 | defer processor.Shutdown(context.Background()) |
47 | 47 |
|
48 | 48 | // Create a test pool with hooks |
@@ -141,7 +141,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
141 | 141 | return &mockNetConn{addr: addr}, nil |
142 | 142 | } |
143 | 143 |
|
144 | | - processor := hitless.NewPoolHook(baseDialer, "tcp", nil, nil) |
| 144 | + processor := maintnotifications.NewPoolHook(baseDialer, "tcp", nil, nil) |
145 | 145 | defer processor.Shutdown(context.Background()) |
146 | 146 |
|
147 | 147 | // Create hooks manager and add processor as hook |
@@ -213,7 +213,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
213 | 213 | return nil, &net.OpError{Op: "dial", Err: &net.DNSError{Name: addr}} |
214 | 214 | } |
215 | 215 |
|
216 | | - processor := hitless.NewPoolHook(failingDialer, "tcp", nil, nil) |
| 216 | + processor := maintnotifications.NewPoolHook(failingDialer, "tcp", nil, nil) |
217 | 217 | defer processor.Shutdown(context.Background()) |
218 | 218 |
|
219 | 219 | // Create hooks manager and add processor as hook |
@@ -276,7 +276,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
276 | 276 | return &mockNetConn{addr: addr}, nil |
277 | 277 | } |
278 | 278 |
|
279 | | - processor := hitless.NewPoolHook(slowDialer, "tcp", nil, nil) |
| 279 | + processor := maintnotifications.NewPoolHook(slowDialer, "tcp", nil, nil) |
280 | 280 | defer processor.Shutdown(context.Background()) |
281 | 281 |
|
282 | 282 | // Create hooks manager and add processor as hook |
|
0 commit comments