FM / SentinelConnector

/opt/canhelp/node_modules/ioredis/built/connectors/SentinelConnector/

/opt/canhelp/node_modules/ioredis/built/connectors/SentinelConnector

Name	Size	Mode	Actions
FailoverDetector.d.ts	340	0644	edit dl rm
FailoverDetector.js	1720	0644	edit dl rm
index.d.ts	2503	0644	edit dl rm
index.js	11989	0644	edit dl rm
SentinelIterator.d.ts	443	0644	edit dl rm
SentinelIterator.js	1182	0644	edit dl rm
types.d.ts	824	0644	edit dl rm
types.js	77	0644	edit dl rm

Edit: /opt/canhelp/node_modules/ioredis/built/connectors/SentinelConnector/SentinelIterator.js (1182B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
function isSentinelEql(a, b) {
    return ((a.host || "127.0.0.1") === (b.host || "127.0.0.1") &&
        (a.port || 26379) === (b.port || 26379));
}
class SentinelIterator {
    constructor(sentinels) {
        this.cursor = 0;
        this.sentinels = sentinels.slice(0);
    }
    next() {
        const done = this.cursor >= this.sentinels.length;
        return { done, value: done ? undefined : this.sentinels[this.cursor++] };
    }
    reset(moveCurrentEndpointToFirst) {
        if (moveCurrentEndpointToFirst &&
            this.sentinels.length > 1 &&
            this.cursor !== 1) {
            this.sentinels.unshift(...this.sentinels.splice(this.cursor - 1));
        }
        this.cursor = 0;
    }
    add(sentinel) {
        for (let i = 0; i < this.sentinels.length; i++) {
            if (isSentinelEql(sentinel, this.sentinels[i])) {
                return false;
            }
        }
        this.sentinels.push(sentinel);
        return true;
    }
    toString() {
        return `${JSON.stringify(this.sentinels)} @${this.cursor}`;
    }
}
exports.default = SentinelIterator;

cmd: