|
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 |
@@ -142,7 +142,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
142 | 142 | return &mockNetConn{addr: addr}, nil |
143 | 143 | } |
144 | 144 |
|
145 | | - processor := hitless.NewPoolHook(baseDialer, "tcp", nil, nil) |
| 145 | + processor := maintnotifications.NewPoolHook(baseDialer, "tcp", nil, nil) |
146 | 146 | defer processor.Shutdown(context.Background()) |
147 | 147 |
|
148 | 148 | // Create hooks manager and add processor as hook |
@@ -215,7 +215,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
215 | 215 | return nil, &net.OpError{Op: "dial", Err: &net.DNSError{Name: addr}} |
216 | 216 | } |
217 | 217 |
|
218 | | - processor := hitless.NewPoolHook(failingDialer, "tcp", nil, nil) |
| 218 | + processor := maintnotifications.NewPoolHook(failingDialer, "tcp", nil, nil) |
219 | 219 | defer processor.Shutdown(context.Background()) |
220 | 220 |
|
221 | 221 | // Create hooks manager and add processor as hook |
@@ -279,7 +279,7 @@ func TestEventDrivenHandoffIntegration(t *testing.T) { |
279 | 279 | return &mockNetConn{addr: addr}, nil |
280 | 280 | } |
281 | 281 |
|
282 | | - processor := hitless.NewPoolHook(slowDialer, "tcp", nil, nil) |
| 282 | + processor := maintnotifications.NewPoolHook(slowDialer, "tcp", nil, nil) |
283 | 283 | defer processor.Shutdown(context.Background()) |
284 | 284 |
|
285 | 285 | // Create hooks manager and add processor as hook |
|
0 commit comments