lib/publisher.js
function assertPublisherOptions(options) {
    mod_assert.object(options, 'options');
    mod_assert.object(options.log, 'options.log');
    mod_assert.object(options.moray, 'options.moray');
    mod_assert.string(options.moray.bucketName, 'options.moray.bucketName');
    mod_assert.optionalObject(options.backoff, 'options.backoff');
    mod_assert.optionalObject(options.moray.client, 'options.moray.client');
    mod_assert.optionalObject(options.restifyServer, 'options.restifyServer');
    if (options.moray.client === undefined || options.moray.client === null) {
        mod_assert.string(options.moray.host, 'options.moray.host');
        mod_assert.number(options.moray.port, 'options.moray.port');
    } else {
        mod_assert.equal(options.moray.host, undefined, 'options.moray.host');
        mod_assert.equal(options.moray.port, undefined, 'options.moray.port');
    }
}
function assertPublisherOptions(options) {
    mod_assert.object(options, 'options');
    mod_assert.object(options.log, 'options.log');
    mod_assert.object(options.moray, 'options.moray');
    mod_assert.string(options.moray.bucketName, 'options.moray.bucketName');
    mod_assert.optionalObject(options.backoff, 'options.backoff');
    mod_assert.optionalObject(options.moray.client, 'options.moray.client');
    mod_assert.optionalObject(options.restifyServer, 'options.restifyServer');
    if (options.moray.client === undefined || options.moray.client === null) {
        mod_assert.string(options.moray.host, 'options.moray.host');
        mod_assert.number(options.moray.port, 'options.moray.port');
    } else {
        mod_assert.equal(options.moray.host, undefined, 'options.moray.host');
        mod_assert.equal(options.moray.port, undefined, 'options.moray.port');
    }
}
function assertPublisherOptions ( options ) { mod_assert . object ( options , 'options' ) ; mod_assert . object ( options . log , 'options.log' ) ; mod_assert . object ( options . moray , 'options.moray' ) ; mod_assert . string ( options . moray . bucketName , 'options.moray.bucketName' ) ; mod_assert . optionalObject ( options . backoff , 'options.backoff' ) ; mod_assert . optionalObject ( options . moray . client , 'options.moray.client' ) ; mod_assert . optionalObject ( options . restifyServer , 'options.restifyServer' ) ; if ( options . moray . client === undefined || options . moray . client === null ) { mod_assert . string ( options . moray . host , 'options.moray.host' ) ; mod_assert . number ( options . moray . port , 'options.moray.port' ) ; } else { mod_assert . equal ( options . moray . host , undefined , 'options.moray.host' ) ; mod_assert . equal ( options . moray . port , undefined , 'options.moray.port' ) ; } }
Prime number chosen to alleviate overlap with pollTime
Prime number chosen to alleviate overlap with pollTime