leader-election-mongo
    TypeScript icon, indicating that this package has built-in type declarations

    0.0.2 • Public • Published

    leader-election-mongo

    A leader election package which uses MongoDB. A single leader is chosen from a group of instances in a single, non-recurring election.

    Use cases

    This package is useful when doing a single election for tasks such as a once-daily cron job (as opposed to having a group of instances continuously trying to determine a leader). It is intended for a relatively small number of instances, such as 5 or 10, not 10,000.

    Install

    npm install leader-election-mongo

    Example

    Here is an example using promises:

    const crypto = require('crypto')
    const { Leader } = require('leader-election-mongo')
    const { MongoClient } = require('mongodb')
     
    const url = 'mongodb://localhost:27017'
     
    MongoClient.connect(
        url,
        {
            useNewUrlParser: true,
            useUnifiedTopology: true
        },
        function (err, client) {
            const id = process.pid + '-' + crypto.randomBytes(8).toString('hex')
            const db = client.db('leadertest')
            const candidate = new Leader(db, { id, ttl: 10000 })
     
            candidate
                .initDatabase()
                .then(collectionExists => {
                    if (collectionExists) {
                        return candidate.elect()
                    }
                    console.log(`${id} collection was not initialized!`)
                    process.exit()
                })
                .then(isLeader => {
                    if (isLeader) {
                        console.log(`${id} is the LEADER`)
                        // do your stuff here
                        return candidate.cleanup()
                    } else {
                        console.log(`${id} is not the leader`)
                        process.exit()
                    }
                })
                .then(() => {
                    console.log(`${id} Cleanup finished`)
                    process.exit()
                })
        }
    )

    This package can also be used with async/await:

    const crypto = require('crypto')
    const { Leader } = require('leader-election-mongo')
    const { MongoClient } = require('mongodb')
     
    const url = 'mongodb://localhost:27017'
     
    MongoClient.connect(
        url,
        {
            useNewUrlParser: true,
            useUnifiedTopology: true
        },
        async function (err, client) {
            const id = process.pid + '-' + crypto.randomBytes(8).toString('hex')
            const db = client.db('leadertest')
            const candidate = new Leader(db, { id })
     
            const collectionExists = await candidate.initDatabase()
            if (!collectionExists) {
                console.log(`${id} collection was not initialized!`)
                process.exit()
            }
     
            const isLeader = await candidate.elect()
            if (!isLeader) {
                console.log(`${id} is not the leader`)
                process.exit()
            }
     
            console.log(`${id} is the LEADER`)
            // do your stuff here
     
            await candidate.cleanup()
            console.log(`${id} Cleanup finished`)
            process.exit()
        }
    )

    API

    new Leader(db, options)

    Create a new Leader class.

    db is a MongoClient.Db object.

    options.id is an optional ID for this instance. Default is a random hex string.

    options.ttl is the lock time-to-live in milliseconds. Will be automatically released after that time. The default and minimum value is 5000.

    If the provided MongoClient.Db object doesn't have admin privileges, the TTL cleanup will only happen every 60 seconds (the MongoDB default) which might cause a problem if the leader doesn't call cleanup() and you try to run multiple elections within 60 seconds.

    options.key is a unique identifier for the group of instances trying to be elected as leader. Default value is 'default'

    initDatabase()

    Initializes the election collection. Returns a promise that resolves to a boolean indicating whether the collection exists.

    elect()

    Performs the election and returns a promise that resolves to true if the instance is the leader; otherwise, false.

    cleanup()

    Removes the election collection. Returns a promise that resolves to void.

    Events

    elected The event fired when the instance becomes a leader.

    cleaned The event fired when the cleanup is finished.

    License

    See the LICENSE file (spoiler alert, it's Apache-2.0).

    Credits

    Inspired by the mongo-leader package, but with a modified API and different election algorithm.

    Keywords

    Install

    npm i leader-election-mongo

    DownloadsWeekly Downloads

    1

    Version

    0.0.2

    License

    Apache-2.0

    Unpacked Size

    20.9 kB

    Total Files

    5

    Last publish

    Collaborators

    • jbuchmann-coosto