File tree Expand file tree Collapse file tree 1 file changed +13
-5
lines changed
packages/client/lib/client Expand file tree Collapse file tree 1 file changed +13
-5
lines changed Original file line number Diff line number Diff line change @@ -9,6 +9,14 @@ export const MAINTENANCE_EVENTS = {
9
9
TIMEOUTS_UPDATE : "timeouts-update" ,
10
10
} as const ;
11
11
12
+ const PN = {
13
+ MOVING : "MOVING" ,
14
+ MIGRATING : "MIGRATING" ,
15
+ MIGRATED : "MIGRATED" ,
16
+ FAILING_OVER : "FAILING_OVER" ,
17
+ FAILED_OVER : "FAILED_OVER" ,
18
+ }
19
+
12
20
export default class EnterpriseMaintenanceManager extends EventEmitter {
13
21
#commandsQueue: RedisCommandsQueue ;
14
22
#options: RedisClientOptions ;
@@ -22,19 +30,19 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
22
30
23
31
#onPush = ( push : Array < any > ) : boolean => {
24
32
switch ( push [ 0 ] . toString ( ) ) {
25
- case " MOVING" : {
33
+ case PN . MOVING : {
26
34
const [ _ , afterMs , url ] = push ;
27
35
const [ host , port ] = url . toString ( ) . split ( ":" ) ;
28
36
this . #onMoving( afterMs , host , Number ( port ) ) ;
29
37
return true ;
30
38
}
31
- case " MIGRATING" :
32
- case " FAILING_OVER" : {
39
+ case PN . MIGRATING :
40
+ case PN . FAILING_OVER : {
33
41
this . #onMigrating( ) ;
34
42
return true ;
35
43
}
36
- case " MIGRATED" :
37
- case " FAILED_OVER" : {
44
+ case PN . MIGRATED :
45
+ case PN . FAILED_OVER : {
38
46
this . #onMigrated( ) ;
39
47
return true ;
40
48
}
You can’t perform that action at this time.
0 commit comments