Beekeeper
view release on metacpan or search on metacpan
bin/bkpr-top view on Meta::CPAN
Filters --host, --pool and --class can be combined.The metrics displayed are:nps: number of received notifications per secondcps: number of processed calls per seconderr: number of errors per secondmem: resident non shared memory size in KiBcpu: percentage of CPU loadload: percentage of busytimeChange sorting pressing (N)otifications, (C)alls, (M)emory, cp(U) or (L)oad.";if($opt_help) {$Help;exit;}
bin/bkpr-top view on Meta::CPAN
Filters --host, --pool and --class can be combined.The metrics displayed are:nps: number of received notifications per secondcps: number of processed calls per seconderr: number of errors per secondmem: resident memory size in KiBcpu: percentage of CPU loadload: percentage of busytimeChange sorting field pressing (N)otifications, (C)alls, (M)emory, cp(U) or (L)oad.=head1 DESCRIPTIONDisplay real-time performance metrics of running workers in a C<top> fashion.Sorting order can be changed pressing keys N, C, M, U and L.Pressing Q quits the program.
bin/bkpr-top view on Meta::CPAN
=item cpuPercentage of CPU load (100 indicates a full utilization of one core thread).For example, supposing that there are 4 core threads available, a service thatshows a C<cpu> load of 200 is using half of the CPU resources.=item loadPercentage of busy time (100% indicates that there are no idle workers).Note that workers can have a high load with very little CPU usage when beingblocked by synchronous operations (like slow SQL queries).For example, supposing that there are 10 workers running, a service that shows aC<load> of 50% is working at half capacity. Spawning 10 additional workers willlower the load to 25%.Due to inaccuracies of measurement the actual maximum may be slightly below 100%.
lib/Beekeeper/MQTT.pm view on Meta::CPAN
0x19=>'Re-authenticate',# AUTH0x80=>'Unspecified error',# CONNACK, PUBACK, PUBREC, SUBACK, UNSUBACK, DISCONNECT0x81=>'Malformed Packet',# CONNACK, DISCONNECT0x82=>'Protocol Error',# CONNACK, DISCONNECT0x83=>'Implementation specific error',# CONNACK, PUBACK, PUBREC, SUBACK, UNSUBACK, DISCONNECT0x84=>'Unsupported Protocol Version',# CONNACK0x85=>'Client Identifier not valid',# CONNACK0x86=>'Bad User Name or Password',# CONNACK0x87=>'Not authorized',# CONNACK, PUBACK, PUBREC, SUBACK, UNSUBACK, DISCONNECT0x88=>'Server unavailable',# CONNACK0x89=>'Server busy',# CONNACK, DISCONNECT0x8A=>'Banned',# CONNACK0x8B=>'Server shutting down',# DISCONNECT0x8C=>'Bad authentication method',# CONNACK, DISCONNECT0x8D=>'Keep Alive timeout',# DISCONNECT0x8E=>'Session taken over',# DISCONNECT0x8F=>'Topic Filter invalid',# SUBACK, UNSUBACK, DISCONNECT0x90=>'Topic Name invalid',# CONNACK, PUBACK, PUBREC, DISCONNECT0x91=>'Packet Identifier in use',# PUBACK, PUBREC, SUBACK, UNSUBACK0x92=>'Packet Identifier not found',# PUBREL, PUBCOMP0x93=>'Receive Maximum exceeded',# DISCONNECT
lib/Beekeeper/Service/Supervisor.pm view on Meta::CPAN
Resident non shared memory size in KiB. This is roughly equivalent to the valueof C<RES> minus C<SHR> displayed by C<top>.=item cpuPercentage of CPU load (100 indicates a full utilization of one core thread).=item loadPercentage of busy time (100 indicates no idle time).Note that workers can have a high load with very little CPU usage when beingblocked by synchronous operations (like slow SQL queries, for example).Due to inaccuracies of measurement the actual maximum may be slightly below 100.=back=head1 METHODS
lib/Beekeeper/Service/Supervisor/Worker.pm view on Meta::CPAN
Resident non shared memory size in KiB. This is roughly equivalent to the valueof C<RES> minus C<SHR> displayed by C<top>.=item cpuPercentage of CPU load (100 indicates a full utilization of one core thread).=item loadPercentage of busy time (100 indicates no idle time).Note that workers can have a high load with very little CPU usage when beingblocked by synchronous operations (like slow SQL queries, for example).Due to inaccuracies of measurement the actual maximum may be slightly below 100.=back=head1 SEE ALSO
lib/Beekeeper/Worker.pm view on Meta::CPAN
stop_cv=>undef,callbacks=> {},task_queue_high=> [],task_queue_low=> [],queued_tasks=> 0,in_progress=> 0,last_report=> 0,call_count=> 0,notif_count=> 0,error_count=> 0,busy_time=> 0,};$JSON= JSON::XS->new;$JSON->utf8;# encode result as utf8$JSON->allow_blessed;# encode blessed references as null$JSON->convert_blessed;# use TO_JSON methods to serialize objects$DEFLATE= Compress::Raw::Zlib::Deflate->new(-AppendOutput=> 1 );if(defined$SIG{TERM} &&$SIG{TERM} eq'DEFAULT') {
lib/Beekeeper/Worker.pm view on Meta::CPAN
delete$worker->{callbacks}->{$_}foreach@cb_keys;delete$worker->{subscriptions}->{$service};undef$unsub_tmr;returnunless$worker->{shutting_down};if($worker->{in_progress} > 0) {# The task queue is empty now, but an asynchronous method handler is# still busy processing some requests received previously. Wait for# these requests to be completed before telling _work_forever to stopmy$wait_time= 60;$worker->{stop_cv}->begin;my$busy_tmr;$busy_tmr= AnyEvent->timer(after=> 1,interval=> 1,cb=>sub{unless($worker->{in_progress} > 0 && --$wait_time> 0) {undef$busy_tmr;$worker->{stop_cv}->end;}});}# Tell _work_forever to stop$worker->{stop_cv}->end;});};
lib/Beekeeper/Worker.pm view on Meta::CPAN
$worker->{call_count} = 0;# Average notifications per secondmy$nps=sprintf("%.2f",$worker->{notif_count} /$period);$worker->{notif_count} = 0;# Average errors per secondmy$err=sprintf("%.2f",$worker->{error_count} /$period);$worker->{error_count} = 0;# Average load as percentage of wall clock busy time (not cpu usage)my$load=sprintf("%.2f", ($BUSY_TIME-$worker->{busy_time}) /$period* 100);$worker->{busy_time} =$BUSY_TIME;# Queuesmy%queues;foreachmy$queue(keys%{$worker->{callbacks}}) {nextunless$queue=~ m/^req\.(?!_sync)(.*)\./;$queues{$1} = 1;}local$client->{auth_data} =$AUTH_TOKENS{'BKPR_SYSTEM'};local$client->{caller_id};
( run in 0.466 second using v1.01-cache-2.11-cpan-709fd43a63f )