/ 
AnyEvent-Gearman-0.11_02-TRIAL
River stage one • 4 direct dependents • 4 total dependents
/ AnyEvent::Gearman::Worker

NAME

AnyEvent::Gearman::Worker - Gearman worker for AnyEvent application

SYNOPSIS

use AnyEvent::Gearman::Worker;

# create gearman worker
my $worker = AnyEvent::Gearman::Worker->new(
    job_servers => ['127.0.0.1', '192.168.0.1:123'],
);

# add worker function
$worker->register_function( reverse => sub {
    my $job = shift;
    my $res = reverse $job->workload;
    $job->complete($res);
});

DESCRIPTION

This is Gearman worker module for AnyEvent applications.

METHODS

new(%options)

Create gearman worker object.

my $worker = AnyEvent::Gearman::Worker->new(
    job_servers => ['127.0.0.1', '192.168.0.1:123'],
);

Options are:

job_servers => 'ArrayRef'

List of gearman servers. 'host:port' or just 'host' formats are allowed. In latter case, gearman default port 4730 will be used.

You should set at least one job_server.

prefix => 'Str',

Sets the namespace / prefix for the function names. This is useful for sharing job servers between different applications or different instances of the same application (different development sandboxes for example).

The namespace is currently implemented as a simple tab separated concatenation of the prefix and the function name.

register_function( $function_name, $subref )

Register worker function.

$worker->register_function( reverse => sub {
    my $job = shift;
    my $res = reverse $job->workload;
    $job->complete($res);
});

$function_name is function name string to register.

$subref is worker CodeRef that will be executed when the worker received a request for this function. And it will be passed a AnyEvent::Gearman::Job object representing the job that has been received by the worker.

NOTE: Unlike Gearman::Worker, this module ignore $subref's return value. So you should call either $job->complete or $job->fail at least.

This is because this module stands AnyEvent's asynchronous way, and this way more flexible in AnyEvent world.

For example:

$worker->register_function( reverse => sub {
    my $job = shift;

    my $t; $t = AnyEvent->timer(
        after => 10,
        cb    => sub {
            undef $t;
            $job->complete('done!');
        },
    );
});

This is simplest and meaningless codes but you can write worker process with AnyEvent way. This is asynchronous worker.

unregister_function( $function_name )

Unregister worker function, notifying to server that this worker no longer handle $function_name.

AUTHOR

Daisuke Murase <typester@cpan.org>

Pedro Melo <melo@cpan.org>

COPYRIGHT AND LICENSE

Copyright (c) 2009 by KAYAC Inc.

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.