[SCM] libmessage-passing-perl Debian packaging branch, master, updated. debian/0.111-3-14-g44f6e88
Tomas Doran
bobtfish at bobtfish.net
Mon May 6 11:56:59 UTC 2013
The following commit has been merged in the master branch:
commit 1677d9c6b8be2b028446f3ae960b032a1c23d28f
Author: Tomas Doran <bobtfish at bobtfish.net>
Date: Sat May 26 15:25:32 2012 +0100
Rename
diff --git a/Makefile.PL b/Makefile.PL
index ada05d4..e839ffc 100644
--- a/Makefile.PL
+++ b/Makefile.PL
@@ -5,7 +5,7 @@ use Module::Install::AuthorRequires;
use Module::Install::AuthorTests;
use Module::Install::Authority;
-all_from 'lib/Log/Stash.pm';
+all_from 'lib/Message/Passing.pm';
license 'AGPL_3';
authority 'GHENRY';
@@ -33,7 +33,7 @@ author_requires 'Test::Spelling';
author_tests 't/author';
if ($Module::Install::AUTHOR) {
- system("pod2text lib/Log/Stash.pm > README")
+ system("pod2text lib/Message/Passing.pm > README")
and die $!;
}
diff --git a/README b/README
index 2d4493c..78e5581 100644
--- a/README
+++ b/README
@@ -1,5 +1,5 @@
NAME
- Log::Stash - a perl subset of Logstash <http://logstash.net>
+ Message::Passing - a perl subset of Logstash <http://logstash.net>
SYNOPSIS
logstash --input STDIN --output STDOUT
@@ -40,12 +40,14 @@ DESCRIPTION
Getting started is really easy - you can just use the "logstash" command
installed by the distribution. If you have a common config that you want
to repeat, or you want to write your own server which does something
- more flexible than the normal script allows, then see Log::Stash::DSL.
+ more flexible than the normal script allows, then see
+ Message::Passing::DSL.
To dive straight in, see the documentation for the command line utility
- logstash, and see the examples in Log::Stash::Manual::Cookbook.
+ logstash, and see the examples in Message::Passing::Manual::Cookbook.
- For more about how the system works, see Log::Stash::Manual::Concepts.
+ For more about how the system works, see
+ Message::Passing::Manual::Concepts.
COMPONENTS
Below is a non-exhaustive list of components available.
@@ -58,25 +60,26 @@ COMPONENTS
Inputs include:
- Log::Stash::Input::STDIN
- Log::Stash::Input::ZeroMQ
- Log::Stash::Input::Test
+ Message::Passing::Input::STDIN
+ Message::Passing::Input::ZeroMQ
+ Message::Passing::Input::Test
You can easily write your own input, just use AnyEvent, and consume
- Log::Stash::Role::Input.
+ Message::Passing::Role::Input.
FILTER
Filters can transform a message in any way.
Examples include:
- Log::Stash::Filter::Null - Returns the input unchanged.
- Log::Stash::Filter::All - Stops any messages it receives from being
- passed to the output. I.e. literally filters all input out.
- Log::Stash::Filter::T - Splits the incoming message to multiple outputs.
+ Message::Passing::Filter::Null - Returns the input unchanged.
+ Message::Passing::Filter::All - Stops any messages it receives from
+ being passed to the output. I.e. literally filters all input out.
+ Message::Passing::Filter::T - Splits the incoming message to multiple
+ outputs.
You can easily write your own filter, just consume
- Log::Stash::Role::Filter.
+ Message::Passing::Role::Filter.
Note that filters can be chained, and a filter can return undef to stop
a message being passed to the output.
@@ -84,16 +87,17 @@ COMPONENTS
OUTPUTS
Outputs send data to somewhere, i.e. they consume messages.
- Log::Stash::Output::STDOUT
- Log::Stash::Output::AMQP
- Log::Stash::Output::ZeroMQ
- Log::Stash::Output::WebHooks
- Log::Stash::Output::ElasticSearch
- Log::Stash::Output::Test
+ Message::Passing::Output::STDOUT
+ Message::Passing::Output::AMQP
+ Message::Passing::Output::ZeroMQ
+ Message::Passing::Output::WebHooks
+ Message::Passing::Output::ElasticSearch
+ Message::Passing::Output::Test
SEE ALSO
Log::Message::Structured - For creating your log messages.
- Log::Dispatch::Log::Stash - use Log::Stash outputs from Log::Dispatch.
+ Log::Dispatch::Message::Passing - use Message::Passing outputs from
+ Log::Dispatch.
THIS MODULE
This is a simple MooseX::Getopt script, with one input, one filter and
diff --git a/lib/Log/Stash/Manual.pod b/lib/Log/Stash/Manual.pod
deleted file mode 100644
index 3857f59..0000000
--- a/lib/Log/Stash/Manual.pod
+++ /dev/null
@@ -1,28 +0,0 @@
-=head1 NAME
-
-Log::Stash::Manual - table of contents for Log::Stash documentation
-
-=head1 CONTENTS
-
-=over
-
-=item L<Log::Stash::Manual::Concepts>
-
-How (and why) logstash works.
-
-=item L<Log::Stash::Manual::Cookbook>
-
-Practical examplesof things you can do with the framework.
-
-=item L<Log::Stash::Manual::Components>
-
-Writing your own inputs, filters and outputs.
-
-=back
-
-=head1 AUTHOR & COPYRIGHT
-
-See L<Log::Stash>.
-
-=cut
-
diff --git a/lib/Log/Stash.pm b/lib/Message/Passing.pm
similarity index 75%
rename from lib/Log/Stash.pm
rename to lib/Message/Passing.pm
index 1a10d4e..779acb5 100644
--- a/lib/Log/Stash.pm
+++ b/lib/Message/Passing.pm
@@ -1,17 +1,17 @@
-package Log::Stash;
+package Message::Passing;
use Moose;
use Getopt::Long qw(:config pass_through);
use namespace::autoclean;
use 5.8.4;
-use Log::Stash::DSL;
+use Message::Passing::DSL;
with
'MooseX::Getopt',
- 'Log::Stash::Role::CLIComponent' => { name => 'input' },
- 'Log::Stash::Role::CLIComponent' => { name => 'output' },
- 'Log::Stash::Role::CLIComponent' => { name => 'filter', default => 'Null' },
- 'Log::Stash::Role::Script';
+ 'Message::Passing::Role::CLIComponent' => { name => 'input' },
+ 'Message::Passing::Role::CLIComponent' => { name => 'output' },
+ 'Message::Passing::Role::CLIComponent' => { name => 'filter', default => 'Null' },
+ 'Message::Passing::Role::Script';
our $VERSION = '0.002';
$VERSION = eval $VERSION;
@@ -41,7 +41,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash - a perl subset of Logstash <http://logstash.net>
+Message::Passing - a perl subset of Logstash <http://logstash.net>
=head1 SYNOPSIS
@@ -85,12 +85,12 @@ Getting started is really easy - you can just use the C<logstash>
command installed by the distribution. If you have a common config
that you want to repeat, or you want to write your own server
which does something more flexible than the normal script allows,
-then see L<Log::Stash::DSL>.
+then see L<Message::Passing::DSL>.
To dive straight in, see the documentation for the command line utility
-L<logstash>, and see the examples in L<Log::Stash::Manual::Cookbook>.
+L<logstash>, and see the examples in L<Message::Passing::Manual::Cookbook>.
-For more about how the system works, see L<Log::Stash::Manual::Concepts>.
+For more about how the system works, see L<Message::Passing::Manual::Concepts>.
=head1 COMPONENTS
@@ -107,16 +107,16 @@ Inputs include:
=over
-=item L<Log::Stash::Input::STDIN>
+=item L<Message::Passing::Input::STDIN>
-=item L<Log::Stash::Input::ZeroMQ>
+=item L<Message::Passing::Input::ZeroMQ>
-=item L<Log::Stash::Input::Test>
+=item L<Message::Passing::Input::Test>
=back
You can easily write your own input, just use L<AnyEvent>, and
-consume L<Log::Stash::Role::Input>.
+consume L<Message::Passing::Role::Input>.
=head2 FILTER
@@ -126,16 +126,16 @@ Examples include:
=over
-=item L<Log::Stash::Filter::Null> - Returns the input unchanged.
+=item L<Message::Passing::Filter::Null> - Returns the input unchanged.
-=item L<Log::Stash::Filter::All> - Stops any messages it receives from being passed to the output. I.e. literally filters all input out.
+=item L<Message::Passing::Filter::All> - Stops any messages it receives from being passed to the output. I.e. literally filters all input out.
-=item L<Log::Stash::Filter::T> - Splits the incoming message to multiple outputs.
+=item L<Message::Passing::Filter::T> - Splits the incoming message to multiple outputs.
=back
You can easily write your own filter, just consume
-L<Log::Stash::Role::Filter>.
+L<Message::Passing::Role::Filter>.
Note that filters can be chained, and a filter can return undef to
stop a message being passed to the output.
@@ -146,17 +146,17 @@ Outputs send data to somewhere, i.e. they consume messages.
=over
-=item L<Log::Stash::Output::STDOUT>
+=item L<Message::Passing::Output::STDOUT>
-=item L<Log::Stash::Output::AMQP>
+=item L<Message::Passing::Output::AMQP>
-=item L<Log::Stash::Output::ZeroMQ>
+=item L<Message::Passing::Output::ZeroMQ>
-=item L<Log::Stash::Output::WebHooks>
+=item L<Message::Passing::Output::WebHooks>
-=item L<Log::Stash::Output::ElasticSearch>
+=item L<Message::Passing::Output::ElasticSearch>
-=item L<Log::Stash::Output::Test>
+=item L<Message::Passing::Output::Test>
=back
@@ -166,7 +166,7 @@ Outputs send data to somewhere, i.e. they consume messages.
=item L<Log::Message::Structured> - For creating your log messages.
-=item L<Log::Dispatch::Log::Stash> - use Log::Stash outputs from L<Log::Dispatch>.
+=item L<Log::Dispatch::Message::Passing> - use Message::Passing outputs from L<Log::Dispatch>.
=back
diff --git a/lib/Log/Stash/DSL.pm b/lib/Message/Passing/DSL.pm
similarity index 88%
rename from lib/Log/Stash/DSL.pm
rename to lib/Message/Passing/DSL.pm
index fb80cb5..3ae5a63 100644
--- a/lib/Log/Stash/DSL.pm
+++ b/lib/Message/Passing/DSL.pm
@@ -1,8 +1,8 @@
-package Log::Stash::DSL;
+package Message::Passing::DSL;
use Moose ();
use Moose::Exporter;
-use Log::Stash::DSL::Factory;
+use Message::Passing::DSL::Factory;
use Carp qw/ confess /;
use Scalar::Util qw/weaken/;
use AnyEvent;
@@ -22,20 +22,20 @@ sub log_chain (&) {
if ($FACTORY) {
confess("Cannot chain within a chain");
}
- local $FACTORY = Log::Stash::DSL::Factory->new;
+ local $FACTORY = Message::Passing::DSL::Factory->new;
$code->();
my %items = $FACTORY->registry;
$FACTORY->clear_registry;
weaken($items{$_}) for
- grep { does_role($items{$_}, 'Log::Stash::Role::Output') }
+ grep { does_role($items{$_}, 'Message::Passing::Role::Output') }
keys %items;
foreach my $name (keys %items) {
next if $items{$name};
warn "Unused output or filter $name in chain\n";
}
return [
- grep { !does_role($_, 'Log::Stash::Role::Output') }
- grep { does_role($_, 'Log::Stash::Role::Input') }
+ grep { !does_role($_, 'Message::Passing::Role::Output') }
+ grep { does_role($_, 'Message::Passing::Role::Input') }
values %items
];
}
@@ -79,12 +79,12 @@ sub run_log_server {
=head1 NAME
-Log::Stash::DSL - An easy way to make chains of logstash objects.
+Message::Passing::DSL - An easy way to make chains of logstash objects.
=head1 SYNOPSIS
package mylogcollectorscript;
- use Log::Stash::DSL;
+ use Message::Passing::DSL;
with 'MooseX::GetOpt';
@@ -114,7 +114,7 @@ Log::Stash::DSL - An easy way to make chains of logstash objects.
=head1 DESCRIPTION
This module provides a simple to use helper system for writing
-scripts which implement a L<Log::Stash> server, like
+scripts which implement a L<Message::Passing> server, like
the built in logstash script.
Your script can just be a script, however if it's a class with a
@@ -187,7 +187,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/DSL/Factory.pm b/lib/Message/Passing/DSL/Factory.pm
similarity index 89%
rename from lib/Log/Stash/DSL/Factory.pm
rename to lib/Message/Passing/DSL/Factory.pm
index 4d0bf53..a462aa1 100644
--- a/lib/Log/Stash/DSL/Factory.pm
+++ b/lib/Message/Passing/DSL/Factory.pm
@@ -1,4 +1,4 @@
-package Log::Stash::DSL::Factory;
+package Message::Passing::DSL::Factory;
use Moose;
use String::RewritePrefix;
use namespace::autoclean;
@@ -6,7 +6,7 @@ use namespace::autoclean;
sub expand_class_name {
my ($self, $type, $name) = @_;
String::RewritePrefix->rewrite({
- '' => 'Log::Stash::' . $type . '::',
+ '' => 'Message::Passing::' . $type . '::',
'+' => ''
}, $name);
}
@@ -68,11 +68,11 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::DSL::Factory - Build a set of logstash chains using symbolic names
+Message::Passing::DSL::Factory - Build a set of logstash chains using symbolic names
=head1 DESCRIPTION
-No user serviceable parts inside. See L<Log::Stash::DSL>.
+No user serviceable parts inside. See L<Message::Passing::DSL>.
=head1 SPONSORSHIP
@@ -84,7 +84,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Filter/All.pm b/lib/Message/Passing/Filter/All.pm
similarity index 81%
rename from lib/Log/Stash/Filter/All.pm
rename to lib/Message/Passing/Filter/All.pm
index 5b54742..86a1c13 100644
--- a/lib/Log/Stash/Filter/All.pm
+++ b/lib/Message/Passing/Filter/All.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Filter::All;
+package Message::Passing::Filter::All;
use Moose;
use namespace::autoclean;
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
sub filter {
return;
@@ -13,7 +13,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Filter::All - Filter all messages out.
+Message::Passing::Filter::All - Filter all messages out.
=head1 DESCRIPTION
@@ -38,7 +38,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Filter/Delay.pm b/lib/Message/Passing/Filter/Delay.pm
similarity index 85%
rename from lib/Log/Stash/Filter/Delay.pm
rename to lib/Message/Passing/Filter/Delay.pm
index 4ad3adc..26f77d3 100644
--- a/lib/Log/Stash/Filter/Delay.pm
+++ b/lib/Message/Passing/Filter/Delay.pm
@@ -1,12 +1,12 @@
-package Log::Stash::Filter::Delay;
+package Message::Passing::Filter::Delay;
use Moose;
use AnyEvent;
use Scalar::Util qw/ weaken /;
use namespace::autoclean;
with qw/
- Log::Stash::Role::Input
- Log::Stash::Role::Output
+ Message::Passing::Role::Input
+ Message::Passing::Role::Output
/;
has delay_for => (
@@ -32,7 +32,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Filter::Null - Filter no messages out.
+Message::Passing::Filter::Null - Filter no messages out.
=head1 DESCRIPTION
@@ -57,7 +57,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Filter/Key.pm b/lib/Message/Passing/Filter/Key.pm
similarity index 92%
rename from lib/Log/Stash/Filter/Key.pm
rename to lib/Message/Passing/Filter/Key.pm
index d0538bf..0c67a51 100644
--- a/lib/Log/Stash/Filter/Key.pm
+++ b/lib/Message/Passing/Filter/Key.pm
@@ -1,9 +1,9 @@
-package Log::Stash::Filter::Key;
+package Message::Passing::Filter::Key;
use Moose;
use Moose::Util::TypeConstraints;
use namespace::autoclean;
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
has key => (
isa => 'Str',
@@ -56,7 +56,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Filter::Key - Filter a subset of messages out.
+Message::Passing::Filter::Key - Filter a subset of messages out.
=head1 DESCRIPTION
@@ -93,7 +93,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Filter/Null.pm b/lib/Message/Passing/Filter/Null.pm
similarity index 82%
rename from lib/Log/Stash/Filter/Null.pm
rename to lib/Message/Passing/Filter/Null.pm
index 6f9c40b..7d1607f 100644
--- a/lib/Log/Stash/Filter/Null.pm
+++ b/lib/Message/Passing/Filter/Null.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Filter::Null;
+package Message::Passing::Filter::Null;
use Moose;
use namespace::autoclean;
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
sub filter {
my ($self, $message) = @_;
@@ -14,7 +14,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Filter::Null - Filter no messages out.
+Message::Passing::Filter::Null - Filter no messages out.
=head1 DESCRIPTION
@@ -39,7 +39,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Filter/T.pm b/lib/Message/Passing/Filter/T.pm
similarity index 69%
rename from lib/Log/Stash/Filter/T.pm
rename to lib/Message/Passing/Filter/T.pm
index 1a9731e..0bfe284 100644
--- a/lib/Log/Stash/Filter/T.pm
+++ b/lib/Message/Passing/Filter/T.pm
@@ -1,14 +1,14 @@
-package Log::Stash::Filter::T;
+package Message::Passing::Filter::T;
use Moose;
use MooseX::Types::Moose qw/ ArrayRef /;
use Moose::Util::TypeConstraints;
use namespace::autoclean;
-with 'Log::Stash::Role::Input';
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Input';
+with 'Message::Passing::Role::Output';
has '+output_to' => (
- isa => ArrayRef[role_type('Log::Stash::Role::Output')],
+ isa => ArrayRef[role_type('Message::Passing::Role::Output')],
is => 'ro',
required => 1,
);
@@ -25,20 +25,20 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Filter::T - Send a message stream to multiple outputs.
+Message::Passing::Filter::T - Send a message stream to multiple outputs.
=head1 DESCRIPTION
This filter is used to duplicate a message stream to two or more outputs.
All messages are duplicated to all output streams, so you may want to follow
-this with L<Log::Stash::Filter::Key> to one or more of those streams.
+this with L<Message::Passing::Filter::Key> to one or more of those streams.
=head1 ATTRIBUTES
=head2 output_to
-Just like a normal L<Log::Stash::Role::Input> class, except takes an array of outputs.
+Just like a normal L<Message::Passing::Role::Input> class, except takes an array of outputs.
=head1 METHODS
@@ -56,7 +56,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Input/FileTail.pm b/lib/Message/Passing/Input/FileTail.pm
similarity index 91%
rename from lib/Log/Stash/Input/FileTail.pm
rename to lib/Message/Passing/Input/FileTail.pm
index de2b065..b6cdb11 100644
--- a/lib/Log/Stash/Input/FileTail.pm
+++ b/lib/Message/Passing/Input/FileTail.pm
@@ -1,11 +1,11 @@
-package Log::Stash::Input::FileTail;
+package Message::Passing::Input::FileTail;
use Moose;
use AnyEvent;
use Try::Tiny;
use Scalar::Util qw/ weaken /;
use namespace::autoclean;
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
has filename => (
is => 'ro',
@@ -51,7 +51,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Input::FileTail - File tailing input
+Message::Passing::Input::FileTail - File tailing input
=head1 SYNOPSIS
@@ -63,7 +63,7 @@ Log::Stash::Input::FileTail - File tailing input
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 AUTHOR
diff --git a/lib/Log/Stash/Input/Null.pm b/lib/Message/Passing/Input/Null.pm
similarity index 85%
rename from lib/Log/Stash/Input/Null.pm
rename to lib/Message/Passing/Input/Null.pm
index 607d645..220c2b3 100644
--- a/lib/Log/Stash/Input/Null.pm
+++ b/lib/Message/Passing/Input/Null.pm
@@ -1,17 +1,17 @@
-package Log::Stash::Input::Null;
+package Message::Passing::Input::Null;
use Moose;
use AnyEvent;
use Try::Tiny;
use namespace::autoclean;
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
__PACKAGE__->meta->make_immutable;
1;
=head1 NAME
-Log::Stash::Input::Null - Null input
+Message::Passing::Input::Null - Null input
=head1 SYNOPSIS
@@ -23,7 +23,7 @@ Does nothing (for testing).
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 AUTHOR
diff --git a/lib/Log/Stash/Input/STDIN.pm b/lib/Message/Passing/Input/STDIN.pm
similarity index 89%
rename from lib/Log/Stash/Input/STDIN.pm
rename to lib/Message/Passing/Input/STDIN.pm
index 4e3fd12..5ff0541 100644
--- a/lib/Log/Stash/Input/STDIN.pm
+++ b/lib/Message/Passing/Input/STDIN.pm
@@ -1,10 +1,10 @@
-package Log::Stash::Input::STDIN;
+package Message::Passing::Input::STDIN;
use Moose;
use AnyEvent;
use Try::Tiny;
use namespace::autoclean;
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
sub BUILD {
my $self = shift;
@@ -25,7 +25,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Input::STDIN - STDIN input
+Message::Passing::Input::STDIN - STDIN input
=head1 SYNOPSIS
@@ -37,7 +37,7 @@ Log::Stash::Input::STDIN - STDIN input
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 AUTHOR
diff --git a/lib/Message/Passing/Manual.pod b/lib/Message/Passing/Manual.pod
new file mode 100644
index 0000000..43242cc
--- /dev/null
+++ b/lib/Message/Passing/Manual.pod
@@ -0,0 +1,28 @@
+=head1 NAME
+
+Message::Passing::Manual - table of contents for Message::Passing documentation
+
+=head1 CONTENTS
+
+=over
+
+=item L<Message::Passing::Manual::Concepts>
+
+How (and why) logstash works.
+
+=item L<Message::Passing::Manual::Cookbook>
+
+Practical examplesof things you can do with the framework.
+
+=item L<Message::Passing::Manual::Components>
+
+Writing your own inputs, filters and outputs.
+
+=back
+
+=head1 AUTHOR & COPYRIGHT
+
+See L<Message::Passing>.
+
+=cut
+
diff --git a/lib/Log/Stash/Manual/Concepts.pod b/lib/Message/Passing/Manual/Concepts.pod
similarity index 80%
rename from lib/Log/Stash/Manual/Concepts.pod
rename to lib/Message/Passing/Manual/Concepts.pod
index 199d5e4..99f6187 100644
--- a/lib/Log/Stash/Manual/Concepts.pod
+++ b/lib/Message/Passing/Manual/Concepts.pod
@@ -1,6 +1,6 @@
=head1 NAME
-Log::Stash::Manual::Concepts - The concepts behind the framework
+Message::Passing::Manual::Concepts - The concepts behind the framework
=head1 DESCRIPTION
@@ -22,7 +22,7 @@ as it's only parameter, like this:
$output->consume($message);
-Outputs are expected to compose L<Log::Stash::Role::Output>.
+Outputs are expected to compose L<Message::Passing::Role::Output>.
=head2 INPUTS
@@ -31,7 +31,7 @@ method on it's output, like this:
$self->output_to->consume($message);
-Outputs are expected to compose L<Log::Stash::Role::Input> which provides this attribute, and
+Outputs are expected to compose L<Message::Passing::Role::Input> which provides this attribute, and
use the C<BUILD> method from Moose to do any work needed to start listening for events.
=head2 FILTER
@@ -39,10 +39,10 @@ use the C<BUILD> method from Moose to do any work needed to start listening for
A filter is just a combination of an output and input. Some (or all) of the messages consumed
by the input are sent on to the output.
-An optional L<Log::Stash::Role::Filter> is supplied, allowing you to provide a simple filter
+An optional L<Message::Passing::Role::Filter> is supplied, allowing you to provide a simple filter
method:
- with 'Log::Stash::Role::Filter';
+ with 'Message::Passing::Role::Filter';
sub filter {
my ($self, $message) = @_;
@@ -52,8 +52,8 @@ method:
However, if you want or need to, you can however write a filter manually, as:
with qw/
- Log::Stash::Role::Input
- Log::Stash::Role::Output
+ Message::Passing::Role::Input
+ Message::Passing::Role::Output
/;
sub consume {
@@ -69,12 +69,12 @@ an output.
So, this is all pretty easy, and you already know enough to pick up some components and use them! For example:
- use Log::Stash::Input::FileTail;
- use Log::Stash::Output::STDOUT;
+ use Message::Passing::Input::FileTail;
+ use Message::Passing::Output::STDOUT;
- Log::Stash::Input::FileTail->new(
+ Message::Passing::Input::FileTail->new(
filename => $ARGV[0],
- output_to => Log::Stash::Output::STDOUT->new,
+ output_to => Message::Passing::Output::STDOUT->new,
);
AnyEvent->condvar->recv; # Enter event loop
@@ -87,7 +87,7 @@ you have several inputs being multiplexed into one output, then the code gets ug
To make it easy to build chains of processing, and your own scripts, a simple DSL is provided.
The example above becomes:
- use Log::Stash::DSL;
+ use Message::Passing::DSL;
run_log_server log_chain {
input file => (
@@ -107,17 +107,17 @@ be noted that doing any long operation (non trivial database queries) will block
no events will be processed.
In cases such as these, running a pool of worker processes to distribute the blocking jobs is more appropriate,
-and easy to wire up (on one or more hosts). This is documented more fully in L<Log::Stash::Manual::Workers>.
+and easy to wire up (on one or more hosts). This is documented more fully in L<Message::Passing::Manual::Workers>.
=head1 ZeroMQ
-L<ZeroMQ> is the recommended transport for logstash messages, and L<Log::Stash::Output::ZeroMQ> is designed to work
+L<ZeroMQ> is the recommended transport for logstash messages, and L<Message::Passing::Output::ZeroMQ> is designed to work
inside a traditional synchronous application. This means that you can emit messages into ZeroMQ without blocking your
application, or having to use or run the AnyEvent event loop.
=head1 SEE ALSO
-=head2 L<Log::Stash::Manual::Cookbook>
+=head2 L<Message::Passing::Manual::Cookbook>
Recipies for achieving common tasks
diff --git a/lib/Log/Stash/Manual/Cookbook.pod b/lib/Message/Passing/Manual/Cookbook.pod
similarity index 91%
rename from lib/Log/Stash/Manual/Cookbook.pod
rename to lib/Message/Passing/Manual/Cookbook.pod
index 01efdf0..9526877 100644
--- a/lib/Log/Stash/Manual/Cookbook.pod
+++ b/lib/Message/Passing/Manual/Cookbook.pod
@@ -1,6 +1,6 @@
=head1 NAME
-Log::Stash::Manual::Cookbook - Common recipies
+Message::Passing::Manual::Cookbook - Common recipies
=head1 Aggregating logs
@@ -9,12 +9,12 @@ Log::Stash::Manual::Cookbook - Common recipies
You can use L<Log::Dispatch>, or any log system which will output into L<Log::Dispatch>.
use Log::Dispatch;
- use Log::Dispatch::Log::Stash;
- use Log::Stash::DSL;
+ use Log::Dispatch::Message::Passing;
+ use Message::Passing::DSL;
my $log = Log::Dispatch->new;
- $log->add(Log::Dispatch::Log::Stash->new(
+ $log->add(Log::Dispatch::Message::Passing->new(
name => 'myapp_aggregate_log',
min_level => 'debug',
output => log_chain {
diff --git a/lib/Log/Stash/Output/Callback.pm b/lib/Message/Passing/Output/Callback.pm
similarity index 73%
rename from lib/Log/Stash/Output/Callback.pm
rename to lib/Message/Passing/Output/Callback.pm
index dc12b6a..c63aaea 100644
--- a/lib/Log/Stash/Output/Callback.pm
+++ b/lib/Message/Passing/Output/Callback.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Output::Callback;
+package Message::Passing::Output::Callback;
use Moose;
use namespace::autoclean;
@@ -12,18 +12,18 @@ sub consume {
$self->cb->($msg);
}
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
__PACKAGE__->meta->make_immutable;
1;
=head1 NAME
-Log::Stash::Output::Callback - Output to call back into your code
+Message::Passing::Output::Callback - Output to call back into your code
=head1 SYNOPSIS
- Log::Stash::Output::Callback->new(
+ Message::Passing::Output::Callback->new(
cb => sub {
my $message = shift;
},
@@ -31,7 +31,7 @@ Log::Stash::Output::Callback - Output to call back into your code
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 SPONSORSHIP
@@ -43,7 +43,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Output/File.pm b/lib/Message/Passing/Output/File.pm
similarity index 89%
rename from lib/Log/Stash/Output/File.pm
rename to lib/Message/Passing/Output/File.pm
index aa6a7a4..f806df2 100644
--- a/lib/Log/Stash/Output/File.pm
+++ b/lib/Message/Passing/Output/File.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::File;
+package Message::Passing::Output::File;
use Moose;
use namespace::autoclean;
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
has filename => (
isa => 'Str',
@@ -50,7 +50,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Output::File - File output
+Message::Passing::Output::File - File output
=head1 SYNOPSIS
@@ -70,7 +70,7 @@ Consumes a message by JSON encoding it and printing it, followed by \n
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 SPONSORSHIP
@@ -82,7 +82,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Output/Null.pm b/lib/Message/Passing/Output/Null.pm
similarity index 79%
rename from lib/Log/Stash/Output/Null.pm
rename to lib/Message/Passing/Output/Null.pm
index a655e6a..3a03197 100644
--- a/lib/Log/Stash/Output/Null.pm
+++ b/lib/Message/Passing/Output/Null.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::Null;
+package Message::Passing::Output::Null;
use Moose;
use namespace::autoclean;
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
sub consume {}
@@ -11,7 +11,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Output::Null - /dev/null for logstash messages
+Message::Passing::Output::Null - /dev/null for logstash messages
=head1 SYNOPSIS
@@ -32,7 +32,7 @@ Takes a message and discards it silently.
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 SPONSORSHIP
@@ -44,7 +44,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Output/STDOUT.pm b/lib/Message/Passing/Output/STDOUT.pm
similarity index 82%
rename from lib/Log/Stash/Output/STDOUT.pm
rename to lib/Message/Passing/Output/STDOUT.pm
index 3e7116f..320947f 100644
--- a/lib/Log/Stash/Output/STDOUT.pm
+++ b/lib/Message/Passing/Output/STDOUT.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::STDOUT;
+package Message::Passing::Output::STDOUT;
use Moose;
use namespace::autoclean;
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
sub consume {
my $self = shift;
@@ -15,7 +15,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Output::STDOUT - STDOUT output
+Message::Passing::Output::STDOUT - STDOUT output
=head1 SYNOPSIS
@@ -35,7 +35,7 @@ Consumes a message by JSON encoding it and printing it, followed by \n
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 SPONSORSHIP
@@ -47,7 +47,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Output/Test.pm b/lib/Message/Passing/Output/Test.pm
similarity index 83%
rename from lib/Log/Stash/Output/Test.pm
rename to lib/Message/Passing/Output/Test.pm
index b8658f6..5769076 100644
--- a/lib/Log/Stash/Output/Test.pm
+++ b/lib/Message/Passing/Output/Test.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::Test;
+package Message::Passing::Output::Test;
use Moose;
use namespace::autoclean;
-extends 'Log::Stash::Output::Callback';
+extends 'Message::Passing::Output::Callback';
has '+cb' => (
default => sub { sub {} },
@@ -30,7 +30,7 @@ __PACKAGE__->meta->make_immutable;
=head1 NAME
-Log::Stash::Output::Test - Output for use in unit tests
+Message::Passing::Output::Test - Output for use in unit tests
=head1 SYNOPSIS
@@ -39,7 +39,7 @@ Log::Stash::Output::Test - Output for use in unit tests
=head1 SEE ALSO
-L<Log::Stash>
+L<Message::Passing>
=head1 SPONSORSHIP
@@ -51,7 +51,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Role/CLIComponent.pm b/lib/Message/Passing/Role/CLIComponent.pm
similarity index 85%
rename from lib/Log/Stash/Role/CLIComponent.pm
rename to lib/Message/Passing/Role/CLIComponent.pm
index e953321..1335f90 100644
--- a/lib/Log/Stash/Role/CLIComponent.pm
+++ b/lib/Message/Passing/Role/CLIComponent.pm
@@ -1,7 +1,7 @@
-package Log::Stash::Role::CLIComponent;
+package Message::Passing::Role::CLIComponent;
use MooseX::Role::Parameterized;
use Moose::Util::TypeConstraints;
-use Log::Stash::Types;
+use Message::Passing::Types;
use namespace::autoclean;
parameter name => (
@@ -29,7 +29,7 @@ role {
);
has "${name}_options" => (
- isa => "Log::Stash::Types::FromJSON",
+ isa => "Message::Passing::Types::FromJSON",
traits => ['Hash'],
default => sub { {} },
handles => {
diff --git a/lib/Log/Stash/Role/ConnectionManager.pm b/lib/Message/Passing/Role/ConnectionManager.pm
similarity index 91%
rename from lib/Log/Stash/Role/ConnectionManager.pm
rename to lib/Message/Passing/Role/ConnectionManager.pm
index f5a9b31..ffbbdb5 100644
--- a/lib/Log/Stash/Role/ConnectionManager.pm
+++ b/lib/Message/Passing/Role/ConnectionManager.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::ConnectionManager;
+package Message::Passing::Role::ConnectionManager;
use Moose::Role;
use Scalar::Util qw/ blessed weaken /;
use namespace::autoclean;
@@ -63,7 +63,7 @@ after _set_connected => sub {
=head1 NAME
-Log::Stash::Role::ConnectionManager - A simple manager for inputs and outputs that need to make network connections.
+Message::Passing::Role::ConnectionManager - A simple manager for inputs and outputs that need to make network connections.
=head1 DESCRIPTION
@@ -105,7 +105,7 @@ If the manager is already connected when you subscribe, it will immediately call
C<< connected >> method, if it is not already connected then this will happen at a later point
once the connection is established.
-See L<Log::Stash::Role::HasAConnection> for a role to help with dealing with a connection manager.
+See L<Message::Passing::Role::HasAConnection> for a role to help with dealing with a connection manager.
=head1 ATTRIBUTES
diff --git a/lib/Log/Stash/Role/Filter.pm b/lib/Message/Passing/Role/Filter.pm
similarity index 82%
rename from lib/Log/Stash/Role/Filter.pm
rename to lib/Message/Passing/Role/Filter.pm
index ec1ec00..8aff19a 100644
--- a/lib/Log/Stash/Role/Filter.pm
+++ b/lib/Message/Passing/Role/Filter.pm
@@ -1,12 +1,12 @@
-package Log::Stash::Role::Filter;
+package Message::Passing::Role::Filter;
use Moose::Role;
use namespace::autoclean;
requires 'filter';
with qw/
- Log::Stash::Role::Input
- Log::Stash::Role::Output
+ Message::Passing::Role::Input
+ Message::Passing::Role::Output
/;
sub consume {
@@ -20,7 +20,7 @@ sub consume {
=head1 NAME
-Log::Stash::Mixin::Filter
+Message::Passing::Mixin::Filter
=head1 DESCRIPTION
@@ -40,7 +40,7 @@ for filtering out unwanted messages.
=head2 output_to
-From L<Log::Stash::Role::Input>.
+From L<Message::Passing::Role::Input>.
=head1 METHODS
@@ -54,9 +54,9 @@ In the case where the filter returns a message, outputs the message to the next
=over
-=item L<Log::Stash>
+=item L<Message::Passing>
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
=back
@@ -70,7 +70,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Role/HasAConnection.pm b/lib/Message/Passing/Role/HasAConnection.pm
similarity index 87%
rename from lib/Log/Stash/Role/HasAConnection.pm
rename to lib/Message/Passing/Role/HasAConnection.pm
index 760ae63..879d339 100644
--- a/lib/Log/Stash/Role/HasAConnection.pm
+++ b/lib/Message/Passing/Role/HasAConnection.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::HasAConnection;
+package Message::Passing::Role::HasAConnection;
use Moose::Role;
use namespace::autoclean;
@@ -21,7 +21,7 @@ after BUILD => sub {
=head1 NAME
-Log::Stash::Role::HasAConnection - Role for components which have a connection
+Message::Passing::Role::HasAConnection - Role for components which have a connection
=head1 DESCRIPTION
@@ -29,7 +29,7 @@ Provides a standard ->connection_manager attribute for inputs or outputs which n
make a network connection before they can send or receive messages.
The connection manager object is assumed to have the C<< ->subscribe_to_connect >> method
-(from L<Log::Stash::Role::Connection>).
+(from L<Message::Passing::Role::Connection>).
=head1 REQUIRED METHODS
diff --git a/lib/Log/Stash/Role/Input.pm b/lib/Message/Passing/Role/Input.pm
similarity index 71%
rename from lib/Log/Stash/Role/Input.pm
rename to lib/Message/Passing/Role/Input.pm
index 2289ac2..4e14de9 100644
--- a/lib/Log/Stash/Role/Input.pm
+++ b/lib/Message/Passing/Role/Input.pm
@@ -1,13 +1,13 @@
-package Log::Stash::Role::Input;
+package Message::Passing::Role::Input;
use Moose::Role;
use JSON qw/ from_json /;
-use Log::Stash::Types;
+use Message::Passing::Types;
use namespace::autoclean;
sub decode { from_json( $_[1], { utf8 => 1 } ) }
has output_to => (
- isa => 'Log::Stash::Types::Output',
+ isa => 'Message::Passing::Types::Output',
is => 'ro',
required => 1,
coerce => 1,
@@ -17,7 +17,7 @@ has output_to => (
=head1 NAME
-Log::Stash::Role::Input
+Message::Passing::Role::Input
=head1 DESCRIPTION
@@ -27,7 +27,7 @@ Produces messages.
=head2 output_to
-Required, must perform the L<Log::Stash::Role::Output> role.
+Required, must perform the L<Message::Passing::Role::Output> role.
=head1 METHODS
@@ -39,9 +39,9 @@ JSON decodes a message supplied as a parameter.
=over
-=item L<Log::Stash>
+=item L<Message::Passing>
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
=back
@@ -55,7 +55,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Role/Output.pm b/lib/Message/Passing/Role/Output.pm
similarity index 76%
rename from lib/Log/Stash/Role/Output.pm
rename to lib/Message/Passing/Role/Output.pm
index a3299c7..f935ff5 100644
--- a/lib/Log/Stash/Role/Output.pm
+++ b/lib/Message/Passing/Role/Output.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::Output;
+package Message::Passing::Role::Output;
use Moose::Role;
use JSON qw/ to_json /;
use Scalar::Util qw/ blessed /;
@@ -22,11 +22,11 @@ requires 'consume';
=head1 NAME
-Log::Stash::Role::Output - Consumes messages
+Message::Passing::Role::Output - Consumes messages
=head1 DESCRIPTION
-This is a role for classes which consumer messages (e.g. a Log::Stash output)
+This is a role for classes which consumer messages (e.g. a Message::Passing output)
=head1 REQUIRED METHODS
@@ -38,9 +38,9 @@ Consume a message
=over
-=item L<Log::Stash>
+=item L<Message::Passing>
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
=back
@@ -54,7 +54,7 @@ the SureVoIP API -
=head1 AUTHOR, COPYRIGHT AND LICENSE
-See L<Log::Stash>.
+See L<Message::Passing>.
=cut
diff --git a/lib/Log/Stash/Role/Script.pm b/lib/Message/Passing/Role/Script.pm
similarity index 95%
rename from lib/Log/Stash/Role/Script.pm
rename to lib/Message/Passing/Role/Script.pm
index fa07074..0baa9ac 100644
--- a/lib/Log/Stash/Role/Script.pm
+++ b/lib/Message/Passing/Role/Script.pm
@@ -1,9 +1,9 @@
-package Log::Stash::Role::Script;
+package Message::Passing::Role::Script;
use Moose::Role;
use Getopt::Long qw(:config pass_through);
use POSIX qw(setuid setgid);
use Moose::Util::TypeConstraints;
-use Log::Stash::DSL;
+use Message::Passing::DSL;
use namespace::autoclean;
requires 'build_chain';
@@ -91,7 +91,7 @@ sub start {
=head1 NAME
-Log::Stash:Role::Script - Handy role for scripts.
+Message::Passing:Role::Script - Handy role for scripts.
=head1 AUTHOR
diff --git a/lib/Log/Stash/Types.pm b/lib/Message/Passing/Types.pm
similarity index 52%
rename from lib/Log/Stash/Types.pm
rename to lib/Message/Passing/Types.pm
index 130feb8..f6faf9f 100644
--- a/lib/Log/Stash/Types.pm
+++ b/lib/Message/Passing/Types.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Types;
+package Message::Passing::Types;
use MooseX::Types ();
use Moose::Util::TypeConstraints;
use JSON ();
@@ -7,11 +7,11 @@ use MooseX::Getopt;
use Try::Tiny;
use namespace::autoclean;
-role_type 'Log::Stash::Types::Input', { role => 'Log::Stash::Role::Input' };
-role_type 'Log::Stash::Types::Output', { role => 'Log::Stash::Role::Output' };
-role_type 'Log::Stash::Types::Filter', { role => 'Log::Stash::Role::Filter' };
+role_type 'Message::Passing::Types::Input', { role => 'Message::Passing::Role::Input' };
+role_type 'Message::Passing::Types::Output', { role => 'Message::Passing::Role::Output' };
+role_type 'Message::Passing::Types::Filter', { role => 'Message::Passing::Role::Filter' };
-coerce 'Log::Stash::Types::Output',
+coerce 'Message::Passing::Types::Output',
from 'HashRef',
via {
my %stuff = %$_;
@@ -20,15 +20,15 @@ coerce 'Log::Stash::Types::Output',
$class->new(%stuff);
};
-subtype 'Log::Stash::Types::FromJSON',
+subtype 'Message::Passing::Types::FromJSON',
as "HashRef";
-coerce 'Log::Stash::Types::FromJSON',
+coerce 'Message::Passing::Types::FromJSON',
from NonEmptySimpleStr,
via { try { JSON->new->relaxed->decode($_) } };
MooseX::Getopt::OptionTypeMap->add_option_type_to_map(
- 'Log::Stash::Types::FromJSON' => '=s'
+ 'Message::Passing::Types::FromJSON' => '=s'
);
1;
diff --git a/script/logstash b/script/logstash
index 8b51a6d..63bfadd 100755
--- a/script/logstash
+++ b/script/logstash
@@ -3,7 +3,7 @@ use FindBin qw/ $Bin /;
use lib "$Bin/../lib"; # FIXME
use strict;
use warnings;
-use Log::Stash;
+use Message::Passing;
-Log::Stash->start;
+Message::Passing->start;
diff --git a/t/00_compile.t b/t/00_compile.t
index a6cf762..10de0ce 100644
--- a/t/00_compile.t
+++ b/t/00_compile.t
@@ -3,19 +3,19 @@ use warnings;
use Test::More;
-use_ok('Log::Stash::Role::HasAConnection');
-use_ok('Log::Stash::Role::ConnectionManager');
-use_ok('Log::Stash');
-use_ok('Log::Stash::Output::STDOUT');
-use_ok('Log::Stash::Input::STDIN');
-use_ok('Log::Stash::Input::FileTail');
-use_ok('Log::Stash::Output::Null');
-use_ok('Log::Stash::Output::Callback');
-use_ok('Log::Stash::Output::Test');
-use_ok('Log::Stash::Output::File');
-use_ok('Log::Stash::Filter::Null');
-use_ok('Log::Stash::Filter::All');
-use_ok('Log::Stash::Filter::Delay');
+use_ok('Message::Passing::Role::HasAConnection');
+use_ok('Message::Passing::Role::ConnectionManager');
+use_ok('Message::Passing');
+use_ok('Message::Passing::Output::STDOUT');
+use_ok('Message::Passing::Input::STDIN');
+use_ok('Message::Passing::Input::FileTail');
+use_ok('Message::Passing::Output::Null');
+use_ok('Message::Passing::Output::Callback');
+use_ok('Message::Passing::Output::Test');
+use_ok('Message::Passing::Output::File');
+use_ok('Message::Passing::Filter::Null');
+use_ok('Message::Passing::Filter::All');
+use_ok('Message::Passing::Filter::Delay');
done_testing;
diff --git a/t/author/podcoverage.t b/t/author/podcoverage.t
index 4d703ed..70dacbe 100644
--- a/t/author/podcoverage.t
+++ b/t/author/podcoverage.t
@@ -8,7 +8,7 @@ use Test::Pod::Coverage 1.04;
my @modules = all_modules;
our @private = ( 'BUILD' );
foreach my $module (@modules) {
- local @private = (@private, 'expand_class_name', 'make') if $module =~ /^Log::Stash::DSL::Factory$/;
+ local @private = (@private, 'expand_class_name', 'make') if $module =~ /^Message::Passing::DSL::Factory$/;
pod_coverage_ok($module, {
also_private => \@private,
diff --git a/t/dsl.t b/t/dsl.t
index 5f119ce..46e4ed5 100644
--- a/t/dsl.t
+++ b/t/dsl.t
@@ -2,7 +2,7 @@ use strict;
use warnings;
use Test::More;
-use Log::Stash::DSL;
+use Message::Passing::DSL;
my $c = log_chain {
output test => (
@@ -21,10 +21,10 @@ my $c = log_chain {
output_to => 'null',
);
};
-isa_ok $c->[0], 'Log::Stash::Input::STDIN';
-isa_ok $c->[0]->output_to, 'Log::Stash::Filter::Null';
-isa_ok $c->[0]->output_to->output_to, 'Log::Stash::Filter::T';
-isa_ok $c->[0]->output_to->output_to->output_to->[0], 'Log::Stash::Output::Test';
+isa_ok $c->[0], 'Message::Passing::Input::STDIN';
+isa_ok $c->[0]->output_to, 'Message::Passing::Filter::Null';
+isa_ok $c->[0]->output_to->output_to, 'Message::Passing::Filter::T';
+isa_ok $c->[0]->output_to->output_to->output_to->[0], 'Message::Passing::Output::Test';
$c->[0]->output_to->consume({foo => 'bar'});
my $test = $c->[0]->output_to->output_to->output_to->[0];
is $test->message_count, 1;
@@ -46,10 +46,10 @@ $c = log_chain {
is ref($c), 'ARRAY';
is scalar(@$c), 2;
-isa_ok $c->[0], 'Log::Stash::Input::Null';
-isa_ok $c->[1], 'Log::Stash::Input::STDIN';
-isa_ok $c->[0]->output_to, 'Log::Stash::Output::STDOUT';
-isa_ok $c->[1]->output_to, 'Log::Stash::Output::STDOUT';
+isa_ok $c->[0], 'Message::Passing::Input::Null';
+isa_ok $c->[1], 'Message::Passing::Input::STDIN';
+isa_ok $c->[0]->output_to, 'Message::Passing::Output::STDOUT';
+isa_ok $c->[1]->output_to, 'Message::Passing::Output::STDOUT';
is $c->[0]->output_to, $c->[1]->output_to;
done_testing;
diff --git a/t/filter.t b/t/filter.t
index a3fd031..c87520f 100644
--- a/t/filter.t
+++ b/t/filter.t
@@ -3,21 +3,21 @@ use warnings;
use Test::More;
use Try::Tiny;
-use Log::Stash::Filter::Null;
-use Log::Stash::Output::Test;
-use Log::Stash::Filter::All;
-use Log::Stash::Filter::T;
-use Log::Stash::Filter::Key;
-use Log::Stash::Filter::Delay;
+use Message::Passing::Filter::Null;
+use Message::Passing::Output::Test;
+use Message::Passing::Filter::All;
+use Message::Passing::Filter::T;
+use Message::Passing::Filter::Key;
+use Message::Passing::Filter::Delay;
my $called = 0;
my $test;
my $ob = try {
- $test = Log::Stash::Output::Test->new(
+ $test = Message::Passing::Output::Test->new(
cb => sub { $called++ }
);
- Log::Stash::Filter::Null->new(output_to => $test)
+ Message::Passing::Filter::Null->new(output_to => $test)
}
catch { fail "Failed to construct $_" };
ok $test;
@@ -36,10 +36,10 @@ is $test->message_count, 0;
is_deeply [$test->messages], [];
$ob = try {
- $test = Log::Stash::Output::Test->new(
+ $test = Message::Passing::Output::Test->new(
cb => sub { $called++ }
);
- Log::Stash::Filter::All->new(output_to => $test)
+ Message::Passing::Filter::All->new(output_to => $test)
}
catch { fail "Failed to construct $_" };
ok $test;
@@ -54,13 +54,13 @@ my $called2 = 0;
my $test2;
$ob = try {
- $test = Log::Stash::Output::Test->new(
+ $test = Message::Passing::Output::Test->new(
cb => sub { $called++ }
);
- $test2 = Log::Stash::Output::Test->new(
+ $test2 = Message::Passing::Output::Test->new(
cb => sub { $called2++ }
);
- Log::Stash::Filter::T->new(output_to => [$test, $test2])
+ Message::Passing::Filter::T->new(output_to => [$test, $test2])
}
catch { fail "Failed to construct $_" };
ok $test;
@@ -77,10 +77,10 @@ is_deeply [$test2->messages], ['message'];
is $called2, 1;
$ob = try {
- $test = Log::Stash::Output::Test->new(
+ $test = Message::Passing::Output::Test->new(
cb => sub { $called++ }
);
- Log::Stash::Filter::Key->new(
+ Message::Passing::Filter::Key->new(
output_to => $test,
key => 'foo',
match => 'bar',
@@ -97,10 +97,10 @@ try { $ob->consume({foo => 'blam', baz => 'quux'}) }
is_deeply [$test->messages], [{foo => 'bar', baz => 'quux'}];
$ob = try {
- $test = Log::Stash::Output::Test->new(
+ $test = Message::Passing::Output::Test->new(
cb => sub { $called++ }
);
- Log::Stash::Filter::Key->new(
+ Message::Passing::Filter::Key->new(
output_to => $test,
key => 'foo.inner.inner',
match => 'bar',
@@ -121,8 +121,8 @@ try { $ob->consume({foo => { inner => { inner => 'bar' } }, baz => 'quux'}) }
is_deeply [$test->messages], [{foo => { inner => { inner => 'bar' } }, baz => 'quux'}];
$ob = try {
- $test = Log::Stash::Output::Test->new();
- Log::Stash::Filter::Delay->new(
+ $test = Message::Passing::Output::Test->new();
+ Message::Passing::Filter::Delay->new(
delay_for => 0.1,
output_to => $test,
);
diff --git a/t/input_output_coerce.t b/t/input_output_coerce.t
index c507680..7ea77a0 100644
--- a/t/input_output_coerce.t
+++ b/t/input_output_coerce.t
@@ -2,16 +2,16 @@ use strict;
use warnings;
use Test::More 0.88;
-use Log::Stash::Input::STDIN;
+use Message::Passing::Input::STDIN;
-my $i = Log::Stash::Input::STDIN->new(
+my $i = Message::Passing::Input::STDIN->new(
output_to => {
- class => 'Log::Stash::Output::Test',
+ class => 'Message::Passing::Output::Test',
},
);
ok $i;
-isa_ok($i->output_to, 'Log::Stash::Output::Test');
+isa_ok($i->output_to, 'Message::Passing::Output::Test');
done_testing;
diff --git a/t/logstash_script.t b/t/logstash_script.t
index 34905da..eb6bf49 100644
--- a/t/logstash_script.t
+++ b/t/logstash_script.t
@@ -2,9 +2,9 @@ use strict;
use warnings;
use Test::More;
-use_ok 'Log::Stash';
+use_ok 'Message::Passing';
-my $i = Log::Stash->new(
+my $i = Message::Passing->new(
input => 'STDIN',
input_options => '{"foo":"bar"}',
filter_options => '{"baz":"quux"}',
diff --git a/t/output_encode.t b/t/output_encode.t
index ce42fb1..ff2f925 100644
--- a/t/output_encode.t
+++ b/t/output_encode.t
@@ -11,9 +11,9 @@ use Try::Tiny;
sub pack { { foo => "bar" } }
}
-use Log::Stash::Output::Test;
+use Message::Passing::Output::Test;
-my $test = Log::Stash::Output::Test->new();
+my $test = Message::Passing::Output::Test->new();
my $packed = $test->encode(bless {}, 'Message');
is $packed, '{"foo":"bar"}';
diff --git a/t/output_null.t b/t/output_null.t
index 096a6c8..fb61dd0 100644
--- a/t/output_null.t
+++ b/t/output_null.t
@@ -3,9 +3,9 @@ use warnings;
use Test::More;
use Try::Tiny;
-use Log::Stash::Output::Null;
+use Message::Passing::Output::Null;
-my $test = try { Log::Stash::Output::Null->new() }
+my $test = try { Message::Passing::Output::Null->new() }
catch { fail "Failed to construct $_" };
ok $test;
diff --git a/t/output_test.t b/t/output_test.t
index 9b577ea..7f125fa 100644
--- a/t/output_test.t
+++ b/t/output_test.t
@@ -3,11 +3,11 @@ use warnings;
use Test::More;
use Try::Tiny;
-use Log::Stash::Output::Test;
+use Message::Passing::Output::Test;
my $called = 0;
-my $test = try { Log::Stash::Output::Test->new(cb => sub { $called++ }) }
+my $test = try { Message::Passing::Output::Test->new(cb => sub { $called++ }) }
catch { fail "Failed to construct $_" };
ok $test;
diff --git a/t/role_connectionmanager.t b/t/role_connectionmanager.t
index 51f7b84..343a35b 100644
--- a/t/role_connectionmanager.t
+++ b/t/role_connectionmanager.t
@@ -30,7 +30,7 @@ use Test::More;
use Scalar::Util qw/ weaken /;
use namespace::clean -except => 'meta';
- with 'Log::Stash::Role::ConnectionManager';
+ with 'Message::Passing::Role::ConnectionManager';
sub _build_connection {
my $self = shift;
diff --git a/t/role_hasaconnection.t b/t/role_hasaconnection.t
index f651f3e..e16684e 100644
--- a/t/role_hasaconnection.t
+++ b/t/role_hasaconnection.t
@@ -3,7 +3,7 @@ use warnings;
use Test::More;
BEGIN {
- use_ok('Log::Stash::Role::HasAConnection');
+ use_ok('Message::Passing::Role::HasAConnection');
}
{
@@ -23,7 +23,7 @@ BEGIN {
use Moose;
use namespace::clean -except => 'meta';
- with 'Log::Stash::Role::HasAConnection';
+ with 'Message::Passing::Role::HasAConnection';
sub connected {} # Callback API
--
libmessage-passing-perl Debian packaging
More information about the Pkg-perl-cvs-commits
mailing list