tqueues 0.1.7

Features

• Accepts coroutines as jobs

• Distributed

• Handles everything in a rethinkdb database object that can be reused at the worker

• Exposes changes via websockets

• Uses rethinkdb streaming “changes” method, wich is pretty efficient

• Uses asyncio, implements an async context manager for jobs and async iterator for the workers

                        +--> Worker
                        |
Rethindb --> Dispatcher ---> Worker
                        |
                        +--> Worker

TQueues worker

Usage:
    tqueues_worker -h | --help
    tqueues_worker --version
    tqueues_worker --endpoint_url <endpoint_url>
    tqueues_worker --queue <queue>

Options:
    -h --help                        Show this screen
    -v --version                     Show version
    --endpoint_url <ENDPOINT_URL>    TQueues dispatcher endpoint
    --queue        <QUEUE>           Endpoint queue to listen on

Examples:
    tqueues_worker --endpoint_url http://127.0.0.1:800/ --queue testqueue

TQueues job dispatcher

Usage:
    tqueues_dispatcher --db "db" --host "127.0.0.1" --port 28015
    tqueues_dispatcher --db "db" --host "127.0.0.1"
    tqueues_dispatcher --db "db" --port 28015
    tqueues_dispatcher --db "db" --user 'user'
    tqueues_dispatcher --db "db" --password 'password'
    tqueues_dispatcher -h | --help
    tqueues_dispatcher --version

Options:
    --host "127.0.0.1"                          Rethinkdb host
    --db "db"                                   Rethinkdb databaes
    --port 28015                                Rethinkdb port
    --user 'user'                               Rethinkdb user
    --password 'password'                       Rethinkdb password
    --allowed_domains 'foo.com,bar.com'         Allowed domains
    --loglevel (DEBUG|INFO)                     Loglevel
    -h   --help                                 Show this screen
    --version                                   Show version

Examples:
    tqueues_dispatcher --host localhost --db foo --port 28015 --user foo --password bar --loglevel INFO --allowed_domains 'foo.com,bar.com'