Socket
Socket
Sign inDemoInstall

aerospike

Package Overview
Dependencies
Maintainers
3
Versions
135
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

aerospike - npm Package Compare versions

Comparing version 3.7.2 to 3.8.0

examples/test.log
lib/commands/connect_command.js
lib/typedefs.js
src/main/stats.cc
test/stats.js

12

CHANGELOG.md

@@ -7,2 +7,14 @@ # Changelog

## [3.8.0] - 2018-12-14
* **New Features**
* Add support for rack-aware clients.
* Add client run-time stats.
* **Updates**
* Update C client library to [v4.4.0](http://www.aerospike.com/download/client/c/notes.html#4.4.0).
* Remove unused error codes.
* Improve global command queue docs.
* Shared memory layout has changed. The default Config#sharedMemory.key has changed to 0xA8000000 so old client applications do not mix shared memory with new client applications. If you are using shared memory clients with a custom shared memory key, it's critical that you change the key when upgrading to this version.
## [3.7.2] - 2018-11-09

@@ -9,0 +21,0 @@

36

lib/aerospike.js

@@ -440,3 +440,3 @@ // *****************************************************************************

* @param {Config} [config] - The configuration for the client.
* @param {Client~connectCallback} [callback] - The function to call, once the client is connected to the cluster successfully.
* @param {connectCallback} [callback] - The function to call, once the client is connected to the cluster successfully.
*

@@ -527,30 +527,14 @@ * @return {?Promise} If no callback function is passed, the function returns

/**
* Configures the global command queue. (Disabled by default.)
* @summary Configures the global command queue. (Disabled by default.)
*
* This method must be called before an {@link Client} instances are connected.
* @description Note that there is only one instance of the command queue that
* is shared by all client instances, even client instances connected to
* different Aerospike clusters. The <code>setupGlobalCommandQueue</code>
* method must be called before any clien} instances are connected.
*
* @param {CommandQueuePolicy} policy
* @see {@link CommandQueuePolicy}
* @param {CommandQueuePolicy} policy - Set of policy values governing the
* behaviour of the global command queue.
*
* @example
*
* const Aerospike = require('aerospike')
*
* Aerospike.setupGlobalCommandQueue({
* maxCommandsInProcess: 50,
* maxCommandsInQueue: 150
* })
* Aerospike.connect()
* .then(client => {
* let commands = []
* for (var i = 0; i < 100; i++) {
* commands.push(client.put(new Aerospike.Key('test', 'test', i), {i: i}))
* }
* // First 50 commands will be executed immediately,
* // remaining commands will be queued and executed once the client frees up.
* Promise.all(commands)
* .then(() => console.info('All commands executed successfully'))
* .catch(error => console.error('Error:', error))
* .then(() => client.close())
* })
* @see {@link CommandQueuePolicy} for more information about the use of the
* command queue.
*/

@@ -557,0 +541,0 @@ exports.setupGlobalCommandQueue = function (policy) {

232

lib/client.js

@@ -216,3 +216,3 @@ // *****************************************************************************

* @param {BatchPolicy} [policy] - The Batch Policy to use for this operation.
* @param {Client~batchRecordsCallback} [callback] - The function to call when
* @param {batchRecordsCallback} [callback] - The function to call when
* the operation completes, with the results of the batch operation.

@@ -270,3 +270,3 @@ *

* @param {BatchPolicy} [policy] - The Batch Policy to use for this operation.
* @param {Client~batchRecordsCallback} [callback] - The function to call when
* @param {batchRecordsCallback} [callback] - The function to call when
* the operation completes, with the results of the batch operation.

@@ -336,3 +336,3 @@ *

* @param {BatchPolicy} [policy] - The Batch Policy to use for this operation.
* @param {Client~batchRecordsCallback} [callback] - The function to call when
* @param {batchRecordsCallback} [callback] - The function to call when
* the operation completes, with the results of the batch operation.

@@ -381,3 +381,3 @@ *

* @param {BatchPolicy} [policy] - The Batch Policy to use for this operation.
* @param {Client~batchRecordsCallback} [callback] - The function to call when
* @param {batchRecordsCallback} [callback] - The function to call when
* the operation completes, with the results of the batch operation.

@@ -476,3 +476,3 @@ *

*
* @param {Client~connectCallback} [callback] - The function to call once the
* @param {connectCallback} [callback] - The function to call once the
* client connection has been established successfully and the client is ready

@@ -511,28 +511,15 @@ * to accept commands.

if (typeof callback === 'function') {
this.as_client.connect((err) => {
err = AerospikeError.fromASError(err)
this.connected = !err
if (this.connected) {
_connectedClients += 1
} else {
this.as_client.close()
}
process.nextTick(callback, err, this)
let cmd = new Commands.Connect(this)
return cmd.execute()
.then(() => {
this.connected = true
_connectedClients += 1
if (callback) callback(null, this)
else return this
})
} else {
return new Promise((resolve, reject) => {
this.as_client.connect((err) => {
err = AerospikeError.fromASError(err)
this.connected = !err
if (this.connected) {
_connectedClients += 1
resolve(this)
} else {
this.as_client.close()
reject(err)
}
})
.catch(error => {
this.as_client.close()
if (callback) callback(error)
else throw error
})
}
}

@@ -592,3 +579,3 @@

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -677,3 +664,3 @@ * @returns {?Promise} - If no callback function is passed, the function

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -728,3 +715,3 @@ * @returns {?Promise} - If no callback function is passed, the function

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -779,3 +766,3 @@ * @returns {?Promise} - If no callback function is passed, the function

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -823,3 +810,3 @@ * @returns {?Promise} - If no callback function is passed, the function

* @param {ApplyPolicy} [policy] - The Apply Policy to use for this operation.
* @param {Client~valueCallback} [callback] - The function to call when the
* @param {valueCallback} [callback] - The function to call when the
* operation has completed with the results of the operation.

@@ -867,3 +854,3 @@ *

* @param {ReadPolicy} [policy] - The Read Policy to use for this operation.
* @param {Client~valueCallback} [callback] - The function to call when the
* @param {valueCallback} [callback] - The function to call when the
* operation completes; the passed value is <code>true</code> if the record

@@ -912,3 +899,3 @@ * exists or <code>false</code> otherwise.

* @param {ReadPolicy} [policy] - The Read Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation; if no callback

@@ -950,3 +937,3 @@ * function is provided, the method returns a <code>Promise<code> instead.

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~doneCallback} [callback] - The function to call when the
* @param {doneCallback} [callback] - The function to call when the
* operation completes with the result of the operation.

@@ -995,3 +982,3 @@ *

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~infoCallback} [callback] - The function to call when an info response from a cluster host is received.
* @param {infoCallback} [callback] - The function to call when an info response from a cluster host is received.
*

@@ -1035,3 +1022,3 @@ * @see <a href="http://www.aerospike.com/docs/reference/info" title="Info Command Reference">&uArr;Info Command Reference</a>

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~infoCallback} callback - The function to call when an info
* @param {infoCallback} callback - The function to call when an info
* response from a cluster host is received.

@@ -1079,3 +1066,3 @@ *

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~infoAllCallback} callback - The function to call when an info
* @param {infoAllCallback} callback - The function to call when an info
* response from all cluster hosts is received.

@@ -1146,3 +1133,3 @@ *

* @param {OperatePolicy} [policy] - The Operate Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation; if no callback

@@ -1204,3 +1191,3 @@ * function is provided, the method returns a <code>Promise<code> instead.

* @param {OperatePolicy} [policy] - The Operate Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation.

@@ -1224,3 +1211,3 @@ *

* @param {OperatePolicy} [policy] - The Operate Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation.

@@ -1244,3 +1231,3 @@ *

* @param {OperatePolicy} [policy] - The Operate Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation.

@@ -1274,3 +1261,3 @@ *

* @param {OperatePolicy} [policy] - The Operate Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation.

@@ -1301,3 +1288,3 @@ *

* @param {WritePolicy} [policy] - The Write Policy to use for this operation.
* @param {Client~writeCallback} callback - The function to call when the operation completes with the result of the operation.
* @param {writeCallback} callback - The function to call when the operation completes with the result of the operation.
*

@@ -1372,3 +1359,3 @@ * @example

* @param {RemovePolicy} [policy] - The Remove Policy to use for this operation.
* @param {Client~writeCallback} callback - The function to call when the operation completes with the results of the operation.
* @param {writeCallback} callback - The function to call when the operation completes with the results of the operation.
*

@@ -1428,3 +1415,3 @@ * @example

* @param {ReadPolicy} [policy] - The Read Policy to use for this operation.
* @param {Client~recordCallback} [callback] - The function to call when the
* @param {recordCallback} [callback] - The function to call when the
* operation completes with the results of the operation; if no callback

@@ -1471,3 +1458,3 @@ * function is provided, the method returns a <code>Promise<code> instead.

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~doneCallback} callback - The function to call when the
* @param {doneCallback} callback - The function to call when the
* operation completes with the result of the operation.

@@ -1515,3 +1502,3 @@ *

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} callback - The function to call when the
* @param {jobCallback} callback - The function to call when the
* operation completes with the result of the operation.

@@ -1562,2 +1549,29 @@ *

/**
* @function Client#stats
*
* @summary Returns runtime stats about the client instance.
*
* @returns {ClientStats} client stats
*
* @since v3.8.0
*
* @example
* require('aerospike').connect().then(client => {
* const stats = client.stats()
* console.info(stats) // => { commands: { inFlight: 0, queued: 0 },
* // nodes:
* // [ { name: 'BB94DC08D270008',
* // syncConnections: { inPool: 1, inUse: 0 },
* // asyncConnections: { inPool: 0, inUse: 0 } },
* // { name: 'C1D4DC08D270008',
* // syncConnections: { inPool: 0, inUse: 0 },
* // asyncConnections: { inPool: 0, inUse: 0 } } ] }
* client.close()
* })
*/
Client.prototype.stats = function () {
return this.as_client.getStats()
}
/**
* @function Client#udfRemove

@@ -1577,3 +1591,3 @@ *

* @param {InfoPolicy} [policy] - The Info Policy to use for this operation.
* @param {Client~jobCallback} callback - The function to call when the
* @param {jobCallback} callback - The function to call when the
* operation completes which the result of the operation.

@@ -1617,118 +1631,2 @@ *

/**
* @callback Client~doneCallback
*
* @summary Callback function called when an operation has completed.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
*/
/**
* @callback Client~recordCallback
*
* @summary Callback function returning a single record from the cluster.
*
* @description
*
* If the operation was successful, <code>null</code> will be returned for the
* error parameter. If there was an error, <code>record</code> will be
* <code>undefined</code> and the <code>error</code> paramter will provide more
* information about the error.
*
* @param {?AerospikeError} error - The error code and message or
* <code>null</code> if the operation was successful.
* @param {Record} [record] - Aerospike record incl. bins, key and meta data.
* Depending on the operation, all, some or no bin values will be returned.
*/
/**
* @callback Client~valueCallback
*
* @summary Callback function returning a single, arbitrary return value.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {*} value - The return value of the operation.
*/
/**
* @callback Client~writeCallback
*
* @summary Callback function called when a write operation on a single record has completed.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {Key} key - The key of the record.
*/
/**
* @callback Client~batchRecordsCallback
*
* @summary Callback function returning one or more records from the cluster.
*
* @description
*
* If the operation was successful, <code>null</code> will be returned for the
* error parameter. If there was an error, <code>results</code> will be
* <code>undefined</code> and the <code>error</code> paramter will provide more
* information about the error.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {Object[]} [results] - The results of the operation. Depending on the
* specific operation, the full record, a selection of bins or just the meta
* data for the record will be included in the results.
* @param {number} results.status - The status for fetching an individual record.
* @param {Record} [results.record] - A database record of <code>null</code> if status is not AEROSPIKE_OK.
*/
/**
* @callback Client~connectCallback
*
* @summary The function called when the client has successfully connected to the server.
*
* @description
*
* Once you receive the connect callback the client instance
* returned in the callback is ready to accept commands for the Aerospike
* cluster.
*
* If an error occurred while connecting to the cluster, the
* <code>client</code> parameter will be <code>undefined</code> and the
* <code>error</code> parameter will include more information about the error.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {Client} [client] - Aerospike client instance.
*/
/**
* @callback Client~infoCallback
*
* @summary The function called when a cluster host responds to an info query.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {string} [response] - The response string with the requested info.
*/
/**
* @callback Client~infoAllCallback
*
* @summary The function called when all cluster nodes have responded to the
* info request. Note that the error parameter in the callback will be
* non-<code>null</code> if at least one of the cluster hosts responded with an
* error to the info request.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {Object[]} [responses] - The response string with the requested info.
* @param {String} responses[].info - The response string with the requested info.
* @param {Object} responses[].host - The node that send the info response.
* @param {String} responses[].host.node_id - The name of the node.
*/
/**
* @callback Client~jobCallback
*
* @summary Function called when a potentially long-running job has been started.
*
* @param {?AerospikeError} error - The error code and message or <code>null</code> if the operation was successful.
* @param {Job} [job] - Handle on a potentially long-running job which can be used to check for job completion.
*/
module.exports = Client

4

lib/commands/command.js

@@ -72,2 +72,4 @@ // *****************************************************************************

this.key = undefined
this.ensureConnected = true
}

@@ -107,3 +109,3 @@

execute () {
if (!this.connected()) {
if (this.ensureConnected && !this.connected()) {
return this.sendError('Not connected.')

@@ -110,0 +112,0 @@ }

2

lib/commands/index.js

@@ -21,2 +21,3 @@ // *****************************************************************************

const Command = require('./command')
const ConnectCommandBase = require('./connect_command')
const ExistsCommandBase = require('./exists_command')

@@ -33,2 +34,3 @@ const ReadRecordCommand = require('./read_record_command')

BatchSelect: class BatchSelectCommand extends BatchCommand('batchSelect') { },
Connect: class ConnectCommand extends ConnectCommandBase('connect') { },
Exists: class ExistsCommand extends ExistsCommandBase('existsAsync') { },

@@ -35,0 +37,0 @@ Get: class GetCommand extends ReadRecordCommand('getAsync') { },

49

lib/config.js

@@ -21,2 +21,4 @@ // *****************************************************************************

const inspect = Symbol.for('nodejs.util.inspect.custom')
/**

@@ -384,2 +386,35 @@ * The Config class contains the settings for an Aerospike client

this.useAlternateAccessAddress = Boolean(config.useAlternateAccessAddress)
/**
* @name Config#rackAware
* @summary Track server rack data.
* @description This field is useful when directing read commands to the
* server node that contains the key and exists on the same rack as the
* client. This serves to lower cloud provider costs when nodes are
* distributed across different racks/data centers.
*
* {@link Config#rackId rackId} config, {@link
* module:aerospike/policy.replica PREFER_RACK} replica policy, and server
* rack configuration must also be set to enable this functionality.
*
* @type {boolean}
* @default false
* @since 3.8.0
*/
this.rackAware = config.rackAware
/**
* @name Config#rackId
* @summary Rack where this client instance resides.
* @description {@link Config#rackAware rackAware} config, {@link
* module:aerospike/policy.replica PREFER_RACK} replica policy, and server
* rack configuration must also be set to enable this functionality.
*
* @type {number}
* @default 0
* @since 3.8.0
*/
if (Number.isInteger(config.rackId)) {
this.rackId = config.rackId
}
}

@@ -400,2 +435,16 @@

}
/**
* Custom inspector that masks the password property when printing the
* config.
*
* @private
*/
[inspect] () {
let copy = Object.assign({}, this)
if (this.password !== undefined) {
Object.assign(copy, { password: '[FILTERED]' })
}
return copy
}
}

@@ -402,0 +451,0 @@

2

lib/index_job.js

@@ -105,3 +105,3 @@ // *****************************************************************************

* @param {number} [pollInterval=1000] - Interval in milliseconds to use when polling the cluster nodes.
* @param {Client~doneCallback} [callback] - The function to call when the operation completes.
* @param {doneCallback} [callback] - The function to call when the operation completes.
*

@@ -108,0 +108,0 @@ * @return {?Promise} If no callback function is passed, the function returns a

38

lib/policies/command_queue_policy.js

@@ -32,2 +32,32 @@ // *****************************************************************************

* not use the command queue and will always be executed immediately.
*
* @see {@link module:aerospike.setupGlobalCommandQueue
* Aerospike.setupGlobalCommandQueue} - function used to initialize the global
* command queue.
*
* @example
*
* const Aerospike = require('aerospike')
*
* const policy = {
* maxCommandsInProcess: 50,
* maxCommandsInQueue: 150
* }
* Aerospike.setupGlobalCommandQueue(policy)
*
* Aerospike.connect()
* .then(client => {
* let commands = []
* for (var i = 0; i < 100; i++) {
* let cmd = client.put(new Aerospike.Key('test', 'test', i), {i: i})
* commands.push(cmd)
* }
*
* // First 50 commands will be executed immediately,
* // remaining commands will be queued and executed once the client frees up.
* Promise.all(commands)
* .then(() => console.info('All commands executed successfully'))
* .catch(error => console.error('Error:', error))
* .then(() => client.close())
* })
*/

@@ -39,2 +69,6 @@ class CommandQueuePolicy {

* @param {Object} [props] - Policy values
* @param {number} [props.maxCommandsInProcess] - Maximum number of async
* commands that can be processed at any point in time.
* @param {number} [props.maxCommandsInQueue] - Maximum number of commands that can be queued for later execution.
* @param {number} [props.queueInitialCapacty] - Initial capacity of the command queue.
*/

@@ -66,3 +100,3 @@ constructor (props) {

/**
* Maximum number of commands that can be stored in the client's command
* Maximum number of commands that can be stored in the global command
* queue for later execution. Queued commands consume memory, but they do

@@ -86,3 +120,3 @@ * not consume sockets. This limit should be defined when it's possible

/**
* Initial capacity of the client's command queue. The command queue can resize
* Initial capacity of the command queue. The command queue can resize
* beyond this initial capacity.

@@ -89,0 +123,0 @@ *

5

lib/policy.js

@@ -187,2 +187,7 @@ // *****************************************************************************

* and one prole.
* @property PREFER_RACK - Try node on the same rack as the client first. If
* there are no nodes on the same rack, use <code>SEQUENCE</code> instead.
* {@link Config#rackAware rackAware} config, {@link Config#rackId rackId}
* config, and server rack configuration must also be set to enable this
* functionality.
*/

@@ -189,0 +194,0 @@ exports.replica = as.policy.replica

2

lib/query.js

@@ -509,3 +509,3 @@ // *****************************************************************************

* randomly if zero or undefined.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -512,0 +512,0 @@ * @returns {?Promise} If no callback function is passed, the function returns

2

lib/scan.js

@@ -199,3 +199,3 @@ // *****************************************************************************

* randomly if zero or undefined.
* @param {Client~jobCallback} [callback] - The function to call when the operation completes.
* @param {jobCallback} [callback] - The function to call when the operation completes.
*

@@ -202,0 +202,0 @@ * @returns {?Promise} If no callback function is passed, the function returns

18

lib/status.js

@@ -130,8 +130,2 @@ // *****************************************************************************

/**
* Bin already exists.
* @const {number}
*/
exports.ERR_BIN_EXISTS = exports.AEROSPIKE_ERR_BIN_EXISTS = as.status.AEROSPIKE_ERR_BIN_EXISTS
/**
* A cluster state change occurred during the request.

@@ -200,8 +194,2 @@ * @const {number}

/**
* Bin-level replace-only supported on server but not on client.
* @const {number}
*/
exports.ERR_BIN_NOT_FOUND = exports.AEROSPIKE_ERR_BIN_NOT_FOUND = as.status.AEROSPIKE_ERR_BIN_NOT_FOUND
/**
* The server node's storage device(s) can't keep up with the write load.

@@ -522,5 +510,2 @@ * @const {number}

case exports.ERR_BIN_EXISTS:
return 'Bin already exists.'
case exports.ERR_CLUSTER_CHANGE:

@@ -556,5 +541,2 @@ return 'A cluster state change occurred during the request.'

case exports.ERR_BIN_NOT_FOUND:
return 'Bin-level replace-only supported on server but not on client.'
case exports.ERR_DEVICE_OVERLOAD:

@@ -561,0 +543,0 @@ return 'The server node\'s storage device(s) can\'t keep up with the write load.'

2

lib/udf_job.js

@@ -93,3 +93,3 @@ // *****************************************************************************

* @param {number} [pollInterval=1000] - Interval in milliseconds to use when polling the cluster nodes.
* @param {Client~doneCallback} [callback] - The function to call when the operation completes.
* @param {doneCallback} [callback] - The function to call when the operation completes.
*

@@ -96,0 +96,0 @@ * @return {?Promise} If no callback function is passed, the function returns a

2

package.json
{
"name": "aerospike",
"version": "3.7.2",
"version": "3.8.0",
"description": "Aerospike Client Library",

@@ -5,0 +5,0 @@ "keywords": [

8

README.md

@@ -97,7 +97,2 @@ # Aerospike Node.js Client [![travis][travis-image]][travis-url] [![codecov][codecov-image]][codecov-url] [![npm][npm-image]][npm-url] [![downloads][downloads-image]][downloads-url]

More examples illustrating the use of the API are located in the
[`examples`](examples) directory.
Details about the API are available in the [`docs`](docs) directory.
<a name="Prerequisites"></a>

@@ -344,3 +339,4 @@ ## Prerequisites

The list of [backward incompatible API changes](docs/api-changes.md) by release.
Backward incompatible API changes by release are documented at
https://www.aerospike.com/docs/client/nodejs/usage/incompatible.html.

@@ -347,0 +343,0 @@ ### API Versioning

10

test/config.js

@@ -64,3 +64,5 @@ // *****************************************************************************

modlua: { userPath: '/user/path' },
port: 3333
port: 3333,
rackAware: true,
rackId: 42
}

@@ -82,2 +84,4 @@

expect(config).to.have.property('policies')
expect(config).to.have.property('rackAware')
expect(config).to.have.property('rackId')

@@ -131,3 +135,4 @@ let policies = config.policies

password: 12345,
sharedMemory: true
sharedMemory: true,
rackId: 'myRack'
}

@@ -141,2 +146,3 @@ var config = new Config(obj)

expect(config).to.not.have.property('sharedMemory')
expect(config).to.not.have.property('rackId')
expect(config.policies).to.be.empty()

@@ -143,0 +149,0 @@ })

5

test/test_helper.js

@@ -209,2 +209,7 @@ // *****************************************************************************

.then(() => serverInfoHelper.fetch_namespace_config(options.namespace))
.catch(error => {
console.error('ERROR:', error)
console.error('CONFIG:', client.config)
throw error
})
)

@@ -211,0 +216,0 @@ }

benchmarks/build/config.gypi
aerospike-client-c.ini

Sorry, the diff of this file is not supported yet

aerospike-client-c.sha256

Sorry, the diff of this file is not supported yet

binding.gyp

Sorry, the diff of this file is not supported yet

src/include/client.h

Sorry, the diff of this file is not supported yet

src/main/client.cc

Sorry, the diff of this file is not supported yet

src/main/config.cc

Sorry, the diff of this file is not supported yet

src/main/enums/policy_enum.cc

Sorry, the diff of this file is not supported yet

src/main/enums/status.cc

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc