You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-04 15:02:09 +03:00
76 lines
2.0 KiB
TypeScript
76 lines
2.0 KiB
TypeScript
export const IS_READ_ONLY = true;
|
|
|
|
export function transformArguments(): Array<string> {
|
|
return ['ROLE'];
|
|
}
|
|
|
|
interface RoleReplyInterface<T extends string> {
|
|
role: T;
|
|
}
|
|
|
|
type RoleMasterRawReply = ['master', number, Array<[string, string, string]>];
|
|
|
|
interface RoleMasterReply extends RoleReplyInterface<'master'> {
|
|
replicationOffest: number;
|
|
replicas: Array<{
|
|
ip: string;
|
|
port: number;
|
|
replicationOffest: number;
|
|
}>;
|
|
}
|
|
|
|
type RoleReplicaState = 'connect' | 'connecting' | 'sync' | 'connected';
|
|
|
|
type RoleReplicaRawReply = ['slave', string, number, RoleReplicaState, number];
|
|
|
|
interface RoleReplicaReply extends RoleReplyInterface<'slave'> {
|
|
master: {
|
|
ip: string;
|
|
port: number;
|
|
};
|
|
state: RoleReplicaState;
|
|
dataReceived: number;
|
|
}
|
|
|
|
type RoleSentinelRawReply = ['sentinel', Array<string>];
|
|
|
|
interface RoleSentinelReply extends RoleReplyInterface<'sentinel'> {
|
|
masterNames: Array<string>;
|
|
}
|
|
|
|
type RoleRawReply = RoleMasterRawReply | RoleReplicaRawReply | RoleSentinelRawReply;
|
|
|
|
type RoleReply = RoleMasterReply | RoleReplicaReply | RoleSentinelReply;
|
|
|
|
export function transformReply(reply: RoleRawReply): RoleReply {
|
|
switch (reply[0]) {
|
|
case 'master':
|
|
return {
|
|
role: 'master',
|
|
replicationOffest: reply[1],
|
|
replicas: reply[2].map(([ip, port, replicationOffest]) => ({
|
|
ip,
|
|
port: Number(port),
|
|
replicationOffest: Number(replicationOffest)
|
|
}))
|
|
};
|
|
|
|
case 'slave':
|
|
return {
|
|
role: 'slave',
|
|
master: {
|
|
ip: reply[1],
|
|
port: reply[2]
|
|
},
|
|
state: reply[3],
|
|
dataReceived: reply[4]
|
|
};
|
|
|
|
case 'sentinel':
|
|
return {
|
|
role: 'sentinel',
|
|
masterNames: reply[1]
|
|
};
|
|
}
|
|
}
|