Constructor
new DynamoReadQueue(dynamoCredentials, dynamoRegion, tableName)
Constructor for DynamoReadQueue
Parameters:
| Name | Type | Description |
|---|---|---|
dynamoCredentials |
module:dynamo.DynamoCredentials | The credentials for a Dynamo table |
dynamoRegion |
string | The region of the Dynamo table we're using |
tableName |
string | The name of the table we want to store data in |
- Source:
Methods
push(item, callback)
Pushes item to be read into the queue
Parameters:
| Name | Type | Description |
|---|---|---|
item |
module:DynamoReadQueue.ReadItem | An item to be read from Dynamo |
callback |
function | The method to be called once the item has been read |
- Source:
pushBatch(batch, callback) → {void}
Method to push items to our queue
Parameters:
| Name | Type | Description |
|---|---|---|
batch |
Array.<module:DynamoReadQueue.ReadItem> | A batch of items to push into the queue |
callback |
function | A method to be called for each read item |
- Source:
Returns:
Nothing
- Type
- void