package Zing::Logic::Kernel;
use 5.014;
use strict;
use warnings;
use registry 'Zing::Types';
use routines;
use Data::Object::Class;
use Data::Object::ClassHas;
extends 'Zing::Logic::Watcher';
our $VERSION = '0.27'; # VERSION
# METHODS
method flow() {
my $step_0 = $self->next::method;
my $step_1 = Zing::Flow->new(
name => 'on_purge',
code => fun($step, $loop) { $self->trace('handle_purge_event') }
);
$step_0->append($step_1);
$step_0
}
method handle_purge_event() {
my $process = $self->process;
return $self if !$process->env->debug;
return $self if !$process->can('journal');
# check every minute (60 secs) not every tick
if ($self->{purge_at}) {
return $self if $self->{purge_at} > time;
}
else {
$self->{purge_at} = time+60;
return $self;
}
$process->journal->drop if $process->journal->size > 10_000;
$self->{purge_at} = time+60;
return $self;
}
1;
=encoding utf8
=head1 NAME
Zing::Logic::Kernel - Kernel Logic
=cut
=head1 ABSTRACT
Kernel Process Logic Chain
=cut
=head1 SYNOPSIS
use Zing::Kernel;
use Zing::Logic::Kernel;
my $logic = Zing::Logic::Kernel->new(
process => Zing::Kernel->new(
scheme => ['MyApp', [], 1]
)
);
# $logic->execute;
=cut
=head1 DESCRIPTION
This package provides the logic (or logic chain) to be executed by the kernel
process event-loop.
=cut
=head1 INHERITS
This package inherits behaviors from:
L<Zing::Logic::Watcher>
=cut
=head1 LIBRARIES
This package uses type constraints from:
L<Zing::Types>
=cut
=head1 ATTRIBUTES
This package has the following attributes:
=cut
=head2 interupt
interupt(Interupt)
This attribute is read-only, accepts C<(Interupt)> values, and is optional.
=cut
=head2 on_perform
on_perform(CodeRef)
This attribute is read-only, accepts C<(CodeRef)> values, and is optional.
=cut
=head2 on_receive
on_receive(CodeRef)
This attribute is read-only, accepts C<(CodeRef)> values, and is optional.
=cut
=head2 on_register
on_register(CodeRef)
This attribute is read-only, accepts C<(CodeRef)> values, and is optional.
=cut
=head2 on_reset
on_reset(CodeRef)
This attribute is read-only, accepts C<(CodeRef)> values, and is optional.
=cut
=head2 on_suicide
on_suicide(CodeRef)
This attribute is read-only, accepts C<(CodeRef)> values, and is optional.
=cut
=head2 process
process(Process)
This attribute is read-only, accepts C<(Process)> values, and is required.
=cut
=head1 METHODS
This package implements the following methods:
=cut
=head2 flow
flow() : Flow
The flow method builds and returns the logic flow for the process event-loop.
=over 4
=item flow example #1
# given: synopsis
my $flow = $logic->flow;
=back
=cut
=head2 signals
signals() : HashRef
The signals method builds and returns the process signal handlers.
=over 4
=item signals example #1
# given: synopsis
my $signals = $logic->signals;
=back
=cut
=head1 AUTHOR
Al Newkirk, C<awncorp@cpan.org>
=head1 LICENSE
Copyright (C) 2011-2019, Al Newkirk, et al.
This is free software; you can redistribute it and/or modify it under the terms
of the The Apache License, Version 2.0, as elucidated in the L<"license
file"|https://github.com/cpanery/zing/blob/master/LICENSE>.
=head1 PROJECT
L<Wiki|https://github.com/cpanery/zing/wiki>
L<Project|https://github.com/cpanery/zing>
L<Initiatives|https://github.com/cpanery/zing/projects>
L<Milestones|https://github.com/cpanery/zing/milestones>
L<Contributing|https://github.com/cpanery/zing/blob/master/CONTRIBUTE.md>
L<Issues|https://github.com/cpanery/zing/issues>
=cut