Branch Coverage

blib/lib/Metabrik/Client/Kafka.pm
Criterion Covered Total %
branch 0 66 0.0


line true false branch
74 0 0 unless $self->brik_help_run_undef_arg('create_connection', $host)
75 0 0 unless $self->brik_help_run_invalid_arg('create_connection', $host, 'ARRAY')
76 0 0 unless $self->brik_help_run_empty_array_arg('create_connection', $host)
85 0 0 unless (defined $server and defined Kafka::Connection::_STRING($server) and $server =~ /^[^:]+:\d+$/)
118 0 0 if ($@)
131 0 0 unless my $kc = $self->create_connection
145 0 0 if ($@)
157 0 0 unless my $kc = $self->create_connection
163 0 0 if ($@)
176 0 0 unless $self->brik_help_run_undef_arg('create_producer', $kcli)
178 0 0 unless $self->brik_help_run_undef_arg('send', $topic)
179 0 0 unless $self->brik_help_run_undef_arg('send', $partition)
180 0 0 unless $self->brik_help_run_undef_arg('send', $messages)
181 0 0 unless $self->brik_help_run_invalid_arg('send', $messages, 'ARRAY', 'SCALAR')
189 0 0 if ($@)
212 0 0 if ($@ =~ /^$no_ack_for_request/i) { }
0 0 elsif ($@ =~ /^$cant_connect/i) { }
0 0 elsif ($@ =~ /^$cant_get_metadata/i) { }
0 0 elsif ($@ =~ /^$unable_to_write/i) { }
0 0 elsif ($@ =~ /^$no_known_broker/i) { }
0 0 elsif ($@ =~ /^$too_big/i) { }
0 0 elsif ($@ =~ /^$invalid_arg_messages/i) { }
247 0 0 unless $self->brik_help_run_undef_arg('create_consumer', $kcli)
248 0 0 unless $self->brik_help_run_undef_arg('loop_consumer_fetch', $topic)
270 0 0 if ($message->valid) { }
287 0 0 if ($self->_kcli)
291 0 0 if ($self->_kc)
305 0 0 unless $self->brik_help_run_undef_arg('create_topic', $topic)
323 0 0 unless $self->brik_help_run_undef_arg('alter_topic', $topic)
340 0 0 unless $self->brik_help_run_undef_arg('delete_topic', $topic)
370 0 0 unless $self->brik_help_run_undef_arg('describe_topic', $topic)
392 0 0 unless $self->brik_help_run_undef_arg('run_console_producer', $topic)
408 0 0 unless $self->brik_help_run_undef_arg('run_console_consumer', $topic)