config.pl.example

#!/usr/bin/perl
package HogeHoge::Worker::Gearman::Double;
use strict;
use warnings;

sub work_job {
    my ($class, $job) = @_;
    my $ret = $job->arg * $job->arg;
    return "$ret (pid $$)";
}

package HogeHoge::Worker::Gearman::Sqrt;
use strict;
use warnings;

sub work_job {
    my ($class, $job) = @_;
    my $ret = sqrt($job->arg);
    return $ret;
}

1;

package main;
use strict;
use warnings;
use Getopt::Long;
use Pod::Usage;
use lib 'lib';
use Dainamo;
use Dainamo::Profile::Gearman;

my $dainamo = Dainamo->new(
    max_workers => 10,
    log_level => 'info',
    # daemonize => 1,
    # log_path => "| /opt/local/sbin/cronolog /tmp/dainamo_log/daimano.%Y%m%d.log",
);

$dainamo->add_profile(
    profile => Dainamo::Profile::Gearman->new(
        name => 'hogehoge',
        max_requests_per_child => 100,
        weight => 1.0,
        config => +{
            job_servers => ['127.0.0.1'],
            workers => [qw( HogeHoge::Worker::Gearman::Double )],
        },
    ),
);

$dainamo->add_profile(
    profile => Dainamo::Profile::Gearman->new(
        name => 'hogehoge',
        max_requests_per_child => 150,
        weight => 1.0,
        config => +{
            job_servers => ['127.0.0.1'],
            workers => [qw( HogeHoge::Worker::Gearman::Double )],
        },
    ),
);

$dainamo->add_profile(
    profile => Dainamo::Profile::Gearman->new(
        name => 'fugafuga',
        max_requests_per_child => 60,
        weight => 1.0,
        config => +{
            job_servers => ['127.0.0.1'],
            workers => [qw( HogeHoge::Worker::Gearman::Sqrt )],
        }
    ),
);

sub {
    $dainamo; # last line
}->();