| blib/lib/EV/Kafka.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| subroutine | 21 | 92 | 22.8 |
| pod | 1 | 1 | 100.0 |
| line | count | pod | subroutine |
|---|---|---|---|
| 2 | 21 | n/a | BEGIN |
| 3 | 21 | n/a | BEGIN |
| 4 | 21 | n/a | BEGIN |
| 7 | 21 | n/a | BEGIN |
| 8 | 21 | n/a | BEGIN |
| 13 | 12 | Yes | new |
| 35 | 0 | n/a | __ANON__ |
| 87 | 21 | n/a | BEGIN |
| 88 | 21 | n/a | BEGIN |
| 91 | 1 | n/a | _any_conn |
| 101 | 0 | n/a | _get_or_create_conn |
| 114 | 0 | n/a | __ANON__ |
| 122 | 0 | n/a | _configure_conn |
| 133 | 0 | n/a | __ANON__ |
| 138 | 0 | n/a | _bootstrap_connect |
| 144 | 0 | n/a | __ANON__ |
| 178 | 0 | n/a | connect |
| 183 | 0 | n/a | _merge_metadata |
| 198 | 1 | n/a | _refresh_metadata |
| 207 | 0 | n/a | __ANON__ |
| 243 | 0 | n/a | _arm_metadata_timer |
| 250 | 0 | n/a | __ANON__ |
| 256 | 11 | n/a | _disarm_metadata_timer |
| 261 | 1 | n/a | _refresh_metadata_for_topic |
| 291 | 0 | n/a | __ANON__ |
| 335 | 0 | n/a | _init_idempotent |
| 339 | 0 | n/a | __ANON__ |
| 359 | 0 | n/a | __ANON__ |
| 392 | 0 | n/a | _drain_pending_for |
| 406 | 0 | n/a | _drain_all_pending |
| 425 | 1 | n/a | _get_leader |
| 430 | 0 | n/a | _num_partitions |
| 439 | 0 | n/a | _select_partition |
| 456 | 1 | n/a | produce |
| 469 | 0 | n/a | __ANON__ |
| 483 | 0 | n/a | __ANON__ |
| 493 | 0 | n/a | __ANON__ |
| 518 | 0 | n/a | __ANON__ |
| 525 | 0 | n/a | _flush_batch |
| 561 | 0 | n/a | __ANON__ |
| 643 | 1 | n/a | _flush_all_batches |
| 659 | 0 | n/a | __ANON__ |
| 666 | 2 | n/a | produce_many |
| 685 | 0 | n/a | __ANON__ |
| 697 | 0 | n/a | flush |
| 708 | 0 | n/a | __ANON__ |
| 728 | 0 | n/a | __ANON__ |
| 738 | 0 | n/a | assign |
| 744 | 0 | n/a | seek |
| 757 | 0 | n/a | __ANON__ |
| 775 | 0 | n/a | poll |
| 781 | 0 | n/a | __ANON__ |
| 823 | 0 | n/a | __ANON__ |
| 854 | 0 | n/a | offsets_for |
| 875 | 0 | n/a | __ANON__ |
| 891 | 0 | n/a | lag |
| 904 | 0 | n/a | __ANON__ |
| 924 | 0 | n/a | error_name |
| 931 | 0 | n/a | subscribe |
| 969 | 0 | n/a | __ANON__ |
| 979 | 0 | n/a | _group_start |
| 988 | 0 | n/a | __ANON__ |
| 1017 | 0 | n/a | _group_join |
| 1026 | 0 | n/a | __ANON__ |
| 1083 | 7 | n/a | _assign_partitions |
| 1168 | 0 | n/a | _group_sync |
| 1175 | 0 | n/a | __ANON__ |
| 1247 | 0 | n/a | _fetch_committed_offsets |
| 1264 | 0 | n/a | __ANON__ |
| 1312 | 0 | n/a | _start_heartbeat |
| 1317 | 0 | n/a | __ANON__ |
| 1355 | 11 | n/a | _stop_heartbeat |
| 1361 | 0 | n/a | _start_fetch_loop |
| 1369 | 0 | n/a | __ANON__ |
| 1379 | 11 | n/a | _stop_fetch_loop |
| 1387 | 0 | n/a | commit |
| 1411 | 0 | n/a | __ANON__ |
| 1417 | 0 | n/a | unsubscribe |
| 1426 | 0 | n/a | __ANON__ |
| 1440 | 0 | n/a | __ANON__ |
| 1449 | 0 | n/a | begin_transaction |
| 1458 | 0 | n/a | _txn_conn |
| 1466 | 0 | n/a | _add_txn_partition |
| 1479 | 0 | n/a | __ANON__ |
| 1484 | 0 | n/a | commit_transaction |
| 1490 | 0 | n/a | __ANON__ |
| 1504 | 0 | n/a | send_offsets_to_transaction |
| 1540 | 0 | n/a | __ANON__ |
| 1547 | 0 | n/a | abort_transaction |
| 1572 | 0 | n/a | __ANON__ |
| 1580 | 11 | n/a | close |
| 1600 | 11 | n/a | DESTROY |