BundleQueuesManager

ancient-cursor. BundleQueuesManager

Queue of bundles execution for multiple cursors. You must descrobe adapter-methods for store bundles and queue informatation per each cursor. You can see example of adapters in generateAdapterForBundleQueuesManager function.

Constructor

new BundleQueuesManager(getCursor, getBundle, setBundle, unsetBundle, getNextBundleId, setNextBundleId)

Source:
Parameters:
Name Type Description
getCursor BundleQueuesManager~getCursor
getBundle BundleQueuesManager~getBundle
setBundle BundleQueuesManager~setBundle
unsetBundle BundleQueuesManager~unsetBundle
getNextBundleId BundleQueuesManager~getNextBundleId
setNextBundleId BundleQueuesManager~setNextBundleId

Methods

executeBundle(bundle, callback)

Execute bundle without queue. Not for manual usage. After execution, try to execute next bandle in queue, if it exists.

Source:
Parameters:
Name Type Description
bundle Bundle
callback function

Calls after all executable bundles did executed, and next bundle not founded.

useBundle(bundle, callback)

Receive bundle object. If it bundle is next in queue, then execute it, else just save into storage within adapter methods.

Source:
Parameters:
Name Type Description
bundle Bundle
callback function

Calls after all executable bundles did executed, and next bundle not founded.

Type Definitions

getBundle(cursorId, bundleId, callback)

Source:
Parameters:
Name Type Description
cursorId
bundleId
callback function

(bundle) => {}

getCursor(cursorId, callback)

Source:
Parameters:
Name Type Description
cursorId
callback function

(cursor) => {}

getNextBundleId(cursorId, callback)

Source:
Parameters:
Name Type Description
cursorId
callback function

(nextBundleId) => {}

setBundle(bundle)

Source:
Parameters:
Name Type Description
bundle Bundle

setNextBundleId(cursorId, nextBundleId)

Source:
Parameters:
Name Type Description
cursorId
nextBundleId

unsetBundle(bundle)

Source:
Parameters:
Name Type Description
bundle Bundle