We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 19c8d6d commit 50692d4Copy full SHA for 50692d4
packages/client/lib/client/enterprise-maintenance-manager.ts
@@ -62,6 +62,7 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
62
// 1 [EVENT] MOVING PN received
63
// 2 [ACTION] Pause writing
64
this.emit(MAINTENANCE_EVENTS.PAUSE_WRITING);
65
+ this.#onMigrating();
66
67
const newSocket = new RedisSocket({
68
...this.#options.socket,
@@ -78,6 +79,7 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
78
79
80
// 5 + 6
81
this.emit(MAINTENANCE_EVENTS.RESUME_WRITING, newSocket);
82
+ this.#onMigrated();
83
};
84
85
#onMigrating = async () => {
0 commit comments