mentat.dirq module
Implementation of filesystem directory based queue for universal messages.
- class mentat.dirq.DirectoryQueue(dir_queue, **kwargs)[source]
Bases:
object
Implementation of filesystem directory based queue for universal messages.
- CONFIG_DIR_NEXT_QUEUE = 'dir_next_queue'
- CONFIG_DIR_QUEUE = 'dir_queue'
- CONFIG_GROUP = 'group'
- CONFIG_QUEUE_PERMS = 'queue_perms'
- CONFIG_USER = 'user'
- STAT_CNT_CANCELS = 'cnt_cancels'
- STAT_CNT_COMMITS = 'cnt_commits'
- STAT_CNT_DEQUEUED = 'cnt_dequeued'
- STAT_CNT_DISPATCHED = 'cnt_dispatched'
- STAT_CNT_DUPLICATED = 'cnt_duplicated'
- STAT_CNT_ERRORS = 'cnt_errors'
- STAT_CNT_QUEUED = 'cnt_queued'
- STAT_CNT_SKIPS = 'cnt_skips'
- STAT_CNT_UPDATES = 'cnt_updates'
- SUBDIR_ERRORS = 'errors'
- SUBDIR_INCOMING = 'incoming'
- SUBDIR_PENDING = 'pending'
- SUBDIR_TMP = 'tmp'
- cancel(itemid)[source]
Cancel given message (remove it from processing without moving to error folder).
- dispatch(itemid, target_folder, metadata=None)[source]
Dispatch given message into designated target folder.