| blib/lib/EV/Kafka.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| subroutine | 16 | 88 | 18.1 |
| pod | 1 | 1 | 100.0 |
| line | count | pod | subroutine |
|---|---|---|---|
| 2 | 15 | n/a | BEGIN |
| 3 | 15 | n/a | BEGIN |
| 4 | 15 | n/a | BEGIN |
| 7 | 15 | n/a | BEGIN |
| 8 | 15 | n/a | BEGIN |
| 13 | 5 | Yes | new |
| 36 | 0 | n/a | __ANON__ |
| 77 | 15 | n/a | BEGIN |
| 78 | 15 | n/a | BEGIN |
| 81 | 1 | n/a | _any_conn |
| 91 | 0 | n/a | _get_or_create_conn |
| 104 | 0 | n/a | __ANON__ |
| 112 | 0 | n/a | _configure_conn |
| 123 | 0 | n/a | __ANON__ |
| 128 | 0 | n/a | _bootstrap_connect |
| 134 | 0 | n/a | __ANON__ |
| 164 | 0 | n/a | connect |
| 169 | 0 | n/a | _merge_metadata |
| 184 | 1 | n/a | _refresh_metadata |
| 193 | 0 | n/a | __ANON__ |
| 226 | 0 | n/a | _refresh_metadata_for_topic |
| 235 | 0 | n/a | __ANON__ |
| 266 | 0 | n/a | _init_idempotent |
| 270 | 0 | n/a | __ANON__ |
| 290 | 0 | n/a | __ANON__ |
| 323 | 0 | n/a | _drain_pending_for |
| 337 | 0 | n/a | _drain_all_pending |
| 356 | 0 | n/a | _get_leader |
| 361 | 0 | n/a | _num_partitions |
| 370 | 0 | n/a | _select_partition |
| 387 | 1 | n/a | produce |
| 400 | 0 | n/a | __ANON__ |
| 414 | 0 | n/a | __ANON__ |
| 424 | 0 | n/a | __ANON__ |
| 449 | 0 | n/a | __ANON__ |
| 456 | 0 | n/a | _flush_batch |
| 483 | 0 | n/a | __ANON__ |
| 519 | 0 | n/a | _flush_all_batches |
| 535 | 0 | n/a | __ANON__ |
| 542 | 0 | n/a | produce_many |
| 554 | 0 | n/a | __ANON__ |
| 566 | 0 | n/a | flush |
| 592 | 0 | n/a | __ANON__ |
| 613 | 0 | n/a | assign |
| 619 | 0 | n/a | seek |
| 632 | 0 | n/a | __ANON__ |
| 650 | 0 | n/a | poll |
| 656 | 0 | n/a | __ANON__ |
| 694 | 0 | n/a | __ANON__ |
| 725 | 0 | n/a | offsets_for |
| 746 | 0 | n/a | __ANON__ |
| 762 | 0 | n/a | lag |
| 775 | 0 | n/a | __ANON__ |
| 795 | 0 | n/a | error_name |
| 802 | 0 | n/a | subscribe |
| 840 | 0 | n/a | __ANON__ |
| 850 | 0 | n/a | _group_start |
| 859 | 0 | n/a | __ANON__ |
| 888 | 0 | n/a | _group_join |
| 897 | 0 | n/a | __ANON__ |
| 942 | 7 | n/a | _assign_partitions |
| 1027 | 0 | n/a | _group_sync |
| 1034 | 0 | n/a | __ANON__ |
| 1097 | 0 | n/a | _fetch_committed_offsets |
| 1114 | 0 | n/a | __ANON__ |
| 1162 | 0 | n/a | _start_heartbeat |
| 1167 | 0 | n/a | __ANON__ |
| 1187 | 4 | n/a | _stop_heartbeat |
| 1193 | 0 | n/a | _start_fetch_loop |
| 1199 | 0 | n/a | __ANON__ |
| 1205 | 4 | n/a | _stop_fetch_loop |
| 1212 | 0 | n/a | commit |
| 1236 | 0 | n/a | __ANON__ |
| 1242 | 0 | n/a | unsubscribe |
| 1251 | 0 | n/a | __ANON__ |
| 1265 | 0 | n/a | __ANON__ |
| 1274 | 0 | n/a | begin_transaction |
| 1283 | 0 | n/a | _txn_conn |
| 1291 | 0 | n/a | _add_txn_partition |
| 1304 | 0 | n/a | __ANON__ |
| 1309 | 0 | n/a | commit_transaction |
| 1315 | 0 | n/a | __ANON__ |
| 1329 | 0 | n/a | send_offsets_to_transaction |
| 1365 | 0 | n/a | __ANON__ |
| 1372 | 0 | n/a | abort_transaction |
| 1386 | 0 | n/a | __ANON__ |
| 1394 | 4 | n/a | close |
| 1413 | 4 | n/a | DESTROY |