charcoal / queue
Queue, Queue items and Queueable objects for Charcoal
Installs: 18
Dependents: 1
Suggesters: 0
Security: 0
Stars: 0
Watchers: 2
Forks: 0
pkg:composer/charcoal/queue
Requires
- php: ^7.4 || ^8.0
- charcoal/core: ^5.0
- charcoal/factory: ^5.0
- psr/log: ^1.0
Requires (Dev)
- php-coveralls/php-coveralls: ^2.2
- phpunit/phpunit: ^9.5
- squizlabs/php_codesniffer: ^3.5
Replaces
README
The Queue package provides an abstract queue service to defer the processing of time consuming tasks.
Installation
composer require charcoal/queue
Usage
Queueing System
Queue managers loop queue items. Queue items represent actions to be performed (as defined by the process() method).
Queue Manager
The queue manager is available as an abstract class: AbstractQueueManager.
This class implements the QueueManagerInterface.
The processing speed (throttle) can be controlled via the rate property, in items per second.
The batch limit (number of items to process per iteration) can be controlled with the limit property.
The queue can be identified with the queue_id. It can be set with setQueueId().
The queue can be processed with processQueue().
If for any reason the items need to be loaded, it can be done with loadQueueItems().
There are 4 callbacks that can be defined:
setProcessedCallback()setItemCallback()setItemSuccessCallbak()setItemFailureCallback()
There are only 1 abstract method:
queueItemProto()which must returns aQueueItemInterfaceinstance
Queue Items
Queue Items should implement the QueueItemInterface. This can be helped via the QueueItemTrait.
Queue items can be identified with a queue_id. (The same queue_id used by the queue manager).
Items can be processed with process($callback, $successCallback, $failureCallback).
The queue item properties are:
queue_idqueue_item_dataqueued_dateprocessing_dateprocessed_dateprocessed
Queuable Objects
The QueueableInterface defines objects that can be queued. This interface is really simple and only provides:
setQueueId()which can be inherited fromQueueableTraitqueueId()(queue_idgetter) which can be inherited fromQueueableTraitqueue($ts = null)which is abstract and must be written inside class which implement the queueable interface