File Coverage

lib/Kafka/Message.pm

Criterion	Covered	Total	%
statement	16	16	100.0
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod	1	1	100.0
total	23	23	100.0

package Kafka::Message;

=head1 NAME

Kafka::Message - Interface to the Kafka message properties.

=head1 VERSION

This documentation refers to C version 1.06 .

=cut



use 5.010;
use strict;
use warnings;



our $VERSION = '1.06';





our @_standard_fields = qw(
    Attributes
    Timestamp
    error
    HighwaterMarkOffset
    key
    MagicByte
    next_offset
    payload
    offset
    valid
);

#-- constructor ----------------------------------------------------------------

sub new {
    my ( $class, $self ) = @_;

    bless $self, $class;

    return $self;
}

#-- public attributes ----------------------------------------------------------

{
    no strict 'refs';   ## no critic

    # getters
    foreach my $method ( @_standard_fields )
    {
        *{ __PACKAGE__.'::'.$method } = sub {
            my ( $self ) = @_;
            return $self->{ $method };
        };
    }
}

#-- public methods -------------------------------------------------------------

#-- private attributes ---------------------------------------------------------

#-- private methods ------------------------------------------------------------



1;

__END__