GSP
Quick Navigator

Search Site

Unix VPS
A - Starter
B - Basic
C - Preferred
D - Commercial
MPS - Dedicated
Previous VPSs
* Sign Up! *

Support
Contact Us
Online Help
Handbooks
Domain Status
Man Pages

FAQ
Virtual Servers
Pricing
Billing
Technical

Network
Facilities
Connectivity
Topology Map

Miscellaneous
Server Agreement
Year 2038
Credits
 

USA Flag

 

 

Man Pages


Manual Reference Pages  -  QUDO (3)

.ds Aq ’

NAME

Qudo - simple and extensible job queue manager

CONTENTS

SYNOPSIS



    # enqueue job:
    use Qudo;
    my $qudo = Qudo->new(
        driver_class => Skinny, # optional.
        databases => [+{
            dsn      => dbi:SQLite:/tmp/qudo.db,
            username => ,
            password => ,
        }],
    );
    $qudo->enqueue("Worker::Test", { arg => arg, uniqkey => uniqkey});
   
    # do work:
    use Qudo;
    my $qudo2 = Qudo->new(
        driver_class => Skinny, # optional.
        databases => [+{
            dsn      => dbi:SQLite:/tmp/qudo.db,
            username => ,
            password => ,
        }],
        manager_abilities => [qw/Worker::Test/],
    );
    $qudo2->work(); # boot manager
    # work work work!



DESCRIPTION

Qudo is simple and extensible job queue manager system.

Your application can insert job into DB ,that is managed by Qudo. And Your application can get & execute job by Qudo worker. Qudo corresponds to deal with DB as MySQL and SQLite.

If you add Hook Point around job’s working method , you can add it easily and many point of work milestone. Qudo is consided about adding Hook Point Flexibility.

USEAGE

CWQudo->new( %args )

Optional members of %args are:
o driver_class

set Qudo::Driver::(Skinny|DBI). default driver_class is Skinny.

o databases

An arrayref of database information. Qudo can use multiple databases, such that if any of them are unavailable, the worker will search for appropriate jobs in the other databases automatically.

Each member of the databases value should be a hashref containing either:
o dsn

The database DSN for this database.

o username

The username to use when connecting to this database.

o password

The password to use when connecting to this database.

o manager_abilities

An arrayref of worker class name. please specify it when moving it by the usage of worker. it is not necessary to specify it for the usage of enqueue client.

o find_job_limit_size

The maximum number in which it looks for job by one processing. Qudo default limit 30. please specify it when moving it by the usage of worker. it is not necessary to specify it for the usage of enqueue client.

o retry_seconds

The number of seconds after which to try reconnecting to apparently dead databases. If not given, Qudo will retry connecting to databases after 30 seconds.

o default_hooks

An arrayref of hook class name.

o default_plugins

An arrayref of plugin class name.

CWQudo->manager

get Qudo::Manager instance. see Qudo::Manager

CWQudo->enqueue( %args )

see Qudo::Manager enqueue method.

CWQudo->work( %args )

Find and perform any jobs $manager can do, forever.

When no job is available, the working process will sleep for $delay seconds (or 5, if not specified) before looking again.

CWQudo->job_count( $funcname, $dsn )

Returns a job count infomations. The required arguments :
o funcname

the name of the function or a reference to an array of functions.

o dsn

The database DSN for job count target database.

CWQudo->exception_list( $args, $dsn )

Returns a job exception infomations. Optional members of $args are:
o args
o limit

get exception log limit size. default by 10.

o offset

get exception log offset size. default by 0.

o dsn

The database DSN for job count target database.

CWQudo->job_status_list( $args, $dsn )

Returns a job exception infomations. Optional members of $args are:
o args
o limit

get job_status log limit size. default by 10.

o offset

get job_status log offset size. default by 0.

o dsn

The database DSN for job count target database.

REPOS

http://github.com/nekokak/qudo/tree/master

AUTHOR

Atsushi Kobayashi <nekokak _at_ gmail dot com>

Masaru Hoshino <masartz _at_ gmail dot com>

COPYRIGHT

This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself.

The full text of the license can be found in the LICENSE file included with this module.

Search for    or go to Top of page |  Section 3 |  Main Index


perl v5.20.3 QUDO (3) 2011-01-17

Powered by GSP Visit the GSP FreeBSD Man Page Interface.
Output converted with manServer 1.07.