NAME

Disque - Perl client for Disque, an in-memory, distributed job queue

CONNECTION

    ## Connection:
    ## perl-disque will try to connect to any available server in the order
    ## is have been set, if there is any disque instance available,
    ## the client will generate a connection error and will abort.
    ## if you not spicify any server in conection `new()`
    ## by default will only connect to '127.0.0.1:7711'.

    use Disque;

    # Defaults disque connects to 127.0.0.1:7711
    my $disque = Disque->new;
    my $disque = Disque->new(servers => '127.0.0.1:7711');

    # Disque connects to multiple instances by default behaviour
    my $disque = Disque->new(servers => ["localhost:7711", "localhost:7712"]);

    # Use UNIX domain socket
    my $disque = Disque->new(unixsock => '/tmp/disque.sock');

    # Enable connection timeout (in seconds)
    my $disque = Disque->new(sock_timeout => 10);

    # Enable read timeout (in seconds)
    my $disque = Disque->new(read_timeout => 0.5);

    # Enable write timeout (in seconds)
    my $disque = Disque->new(write_timeout => 1.2);

ClUSTER

    #You can use this library with single or multi-node clusters.

    ## Connection:

    # When you invoke "new()" you can choose in which method you will connect to the cluster,
    # of course, this only will happen if ther is more than 1 node spicified.

    # By default, as Salvatore [specified](https://github.com/antirez/disque#client-libraries)
    # in the doc, the lib will try to connect to any available server in a randomly way.

    # But also if you won't to connect to the server randomly you can specify
    # the param "disable_random_connect => 1" in new() sub, for example:

    my $disque = Disque->new(
        servers => ['localhost:7711', 'localhost:7712', 'localhost:7713'],
        disable_random_connect => 1
    );

    # So you will connect into the cluster in the order that you have set the nodes.

STATUS

The commands that are allready available are: add_job get_job ack_job fast_ack qlen qpeek enqueue dequeue del_job show

DESCRIPTION

Disque is a client to Disque client library. This module must works on top of Redis lib, and uses some of the internal subs in Redis lib.

REPOSITORY

https://github.com/lovelle/perl-disque