Masahiro Nagano > Proclet > Proclet

Download:
Proclet-0.35.tar.gz

Dependencies

Annotate this POD

Website

View/Report Bugs
Module Version: 0.35   Source  

NAME ^

Proclet - minimalistic Supervisor

SYNOPSIS ^

  use Proclet;

  my $proclet = Proclet->new(
      color => 1
  );

  # add service
  $proclet->service(
      code => sub {
          my $job = $jobqueue->grab;
          work($job);
      },
      worker => 2,
      tag => 'worker'
  );

  $proclet->service(
      code => sub {
          my $loader = Plack::Loader->load(
              'Starlet',
              port => $port,
              host => $host || 0,
              max_workers => 4,
          );
          $loader->run($app);
      },
      tag => 'web'
  );

  $proclet->service(
      code => sub {
          exec('/usr/bin/memcached','-p','11211');
      },
  );

  $proclet->service(
      code => sub {
          scheduled_work();
      },
      tag => 'cron',
      every => '0 12 * * *', #everyday at 12:00am
  );


  $proclet->run;

DESCRIPTION ^

Proclet is minimalistic Supervisor, fork and manage many services from one perl script.

LOG ^

Logs from services are Displayed with timestamp and tag.

  12:23:16 memcached.1 | <6 server listening (udp)
  12:23:16 memcached.1 | <7 send buffer was 9216, now 3728270
  12:23:16 memcached.1 | <7 server listening (udp)
  12:23:16 web.1       | 2012/08/31-12:23:16 Starman::Server (type Net::Server::PreFork) starting! pid(51516)
  12:23:16 web.1       | Resolved [*]:5432 to [0.0.0.0]:5432, IPv4
  12:23:16 web.1       | Binding to TCP port 5432 on host 0.0.0.0 with IPv4 
  12:23:16 web.1       | Setting gid to "20 20 20 401 204 100 98 81 80 79 61 12 402"

METHOD ^

new

Create instance of Proclet.

Attributes are as follows:

spawn_interval: Int

interval in seconds between spawning services unless a service exits abnormally (default: 0)

err_respawn_interval: Int

number of seconds to deter spawning of services after a service exits abnormally (default: 1)

color: Bool

colored log (default: 0)

logger: CodeRef
  my $logger = File::RotateLogs->new(...)
  my $proclet = Proclet->new(
      logger => sub { $logger->print(@_) }
  );

Sets a callback to print stdout/stderr. uses warn by default.

enable_log_worker: Bool

enable worker for format logs. (default: 1) If disabled this option, cannot use logger opt too.

exec_notice: Bool

enable start and exec notice message like

  16:38:12 worker.1 | Start callback: worker

(default: 1)

service

Add services to Proclet.

Attributes are as follows:

code: CodeRef|ArrayRef|Str

Code reference or commands of services.

CodeRef

  $proclet->service(
    code => sub {
        MyWorker->run();
    }
  );

ArrayRef

  $proclet->service(
    code => ['plackup','-a','app.psgi'],
  );

Str

  $proclet->service(
    code => '/usr/bin/memcached'
  );
worker: Int

Number of children to fork, default is "1"

tag: Str

Keyword for log. optional

every: Str

Crontab like format. optional

If every option exists, Proclet execute the job as cron(8)

  $proclet->service(
      code => sub {
          scheduled_work();
      },
      tag => 'cron',
      every => '0 12 * * *', #everyday at 12:00am
  );
run

run services. Proclet does start services by defined order

AUTHOR ^

Masahiro Nagano <kazeburo {at} gmail.com>

SEE ALSO ^

Proc::Launcher::Manager, related module Parallel::Prefork, Proclet used internally

LICENSE ^

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

syntax highlighting: