Class: RequestItemStore
| Defined in: | src/kermit/QueueSystem.coffee |
Overview
Provides access to a queue like system that allows to access RequestItems and URLs.
Instance Method Summary
- # (void) insert(item) Insert a item into the queue
- # (void) update(item) Update a known item
- # (void) remove(item) Remove an item from the store
- # (Array<RequestItem.state>) spooled() Retrieve the next batch of SPOOLED items
- # (void) waiting() Retrieve a set of all items with phases defined as "WAITING"
- # (void) fetching() Retrieve a set of all items with phases defined as "WAITING"
- # (void) unfinished() Retrieve all unfinished (INITIAL, SPOOLED, READY, FETCHING, FETCHED) items
- # (void) inPhases(phases) Retrieve all items in the specified {ProcessingPhases}s
- # (void) processing(pattern) Retrieve items in phase FETCHING with url matching the given pattern
- # (void) save() Private Save the current state to file
Constructor Details
#
(void)
constructor(options)
Construct a new QueueSystem with its own data file
Instance Method Details
#
(void)
insert(item)
Insert a item into the queue
#
(void)
update(item)
Update a known item
#
(void)
remove(item)
Remove an item from the store
#
(Array<RequestItem.state>)
spooled()
Retrieve the next batch of SPOOLED items
#
(void)
waiting()
Retrieve a set of all items with phases defined as "WAITING"
#
(void)
fetching()
Retrieve a set of all items with phases defined as "WAITING"
#
(void)
inPhases(phases)
Retrieve all items in the specified {ProcessingPhases}s
#
(void)
processing(pattern)
Retrieve items in phase FETCHING with url matching the given pattern
#
(void)
save()
Private
Save the current state to file