| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0104-fetch_from_follower_mock.c | 104 TEST_SAY(_C_GRN "[ Test FFF auto.offset.reset=%s PASSED ]\n", in do_test_offset_reset()
174 TEST_SAY(_C_GRN "[ Test lagging FFF offset reset PASSED ]\n"); in do_test_offset_reset_lag()
241 TEST_SAY(_C_GRN "[ Test unknown follower PASSED ]\n"); in do_test_unknown_follower()
314 TEST_SAY(_C_GRN "[ Test REPLICA_NOT_AVAIALBLE PASSED ]\n"); in do_test_replica_not_available()
|
| H A D | 0091-max_poll_interval_timeout.c | 195 TEST_SAY(_C_GRN in do_test_with_subscribe()
241 TEST_SAY(_C_GRN in do_test_with_assign()
285 TEST_SAY(_C_GRN in do_test_no_poll()
|
| H A D | 0004-conf.c | 173 TEST_SAY(_C_GRN "Ok: %s\n", errstr); in do_test_kafka_new_failures()
200 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
215 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
223 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
605 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in main_0004_conf()
|
| H A D | 0002-unkpart.c | 160 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart()
227 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart_timeout_nobroker()
|
| H A D | 0076-produce_retry.c | 154 TEST_SAY(_C_GRN "Test produce retries " in do_test_produce_retries()
307 TEST_SAY(_C_GRN "Test produce retries by disconnect " in do_test_produce_retries_disconnect()
|
| H A D | 0121-clusterid.c | 51 matched ? _C_GRN : "", in log_cb()
|
| H A D | 0016-client_swname.c | 104 TEST_SAY(_C_GRN "[ Test client.software.name=%s, " in do_test_swname()
|
| H A D | 0111-delay_create_topics.cpp | 119 Test::Say(tostr() << _C_GRN << "[ Test with timeout_too_short=" << in do_test_producer()
|
| H A D | 0090-idempotence.c | 153 TEST_SAY(_C_GRN "[ Test implicit ack: %s : PASS ]\n", what); in do_test_implicit_ack()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0104-fetch_from_follower_mock.c | 104 TEST_SAY(_C_GRN "[ Test FFF auto.offset.reset=%s PASSED ]\n", in do_test_offset_reset()
174 TEST_SAY(_C_GRN "[ Test lagging FFF offset reset PASSED ]\n"); in do_test_offset_reset_lag()
241 TEST_SAY(_C_GRN "[ Test unknown follower PASSED ]\n"); in do_test_unknown_follower()
314 TEST_SAY(_C_GRN "[ Test REPLICA_NOT_AVAIALBLE PASSED ]\n"); in do_test_replica_not_available()
|
| H A D | 0091-max_poll_interval_timeout.c | 195 TEST_SAY(_C_GRN in do_test_with_subscribe()
241 TEST_SAY(_C_GRN in do_test_with_assign()
285 TEST_SAY(_C_GRN in do_test_no_poll()
|
| H A D | 0117-mock_errors.c | 96 TEST_SAY(_C_GRN "[ %s%s PASS ]\n", __FUNCTION__, in push_assignment()
185 TEST_SAY(_C_GRN "[ %s PASS ]\n", __FUNCTION__);
|
| H A D | 0004-conf.c | 173 TEST_SAY(_C_GRN "Ok: %s\n", errstr); in do_test_kafka_new_failures()
200 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
215 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
223 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
605 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in main_0004_conf()
|
| H A D | 0002-unkpart.c | 160 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart()
227 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart_timeout_nobroker()
|
| H A D | 0076-produce_retry.c | 154 TEST_SAY(_C_GRN "Test produce retries " in do_test_produce_retries()
307 TEST_SAY(_C_GRN "Test produce retries by disconnect " in do_test_produce_retries_disconnect()
|
| H A D | 0121-clusterid.c | 51 matched ? _C_GRN : "",
|
| H A D | 0016-client_swname.c | 104 TEST_SAY(_C_GRN "[ Test client.software.name=%s, "
|
| H A D | 0111-delay_create_topics.cpp | 119 Test::Say(tostr() << _C_GRN << "[ Test with timeout_too_short=" << in do_test_producer()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0104-fetch_from_follower_mock.c | 104 TEST_SAY(_C_GRN "[ Test FFF auto.offset.reset=%s PASSED ]\n", in do_test_offset_reset()
174 TEST_SAY(_C_GRN "[ Test lagging FFF offset reset PASSED ]\n"); in do_test_offset_reset_lag()
232 TEST_SAY(_C_GRN "[ Test unknown follower PASSED ]\n"); in do_test_unknown_follower()
|
| H A D | 0105-transactions_mock.c | 206 TEST_SAY(_C_GRN "[ %s PASS ]\n", __FUNCTION__); in do_test_txn_recoverable_errors()
349 TEST_SAY(_C_GRN "[ %s PASS ]\n", __FUNCTION__); in do_test_txn_requires_abort_errors()
426 TEST_SAY(_C_GRN "[ Test %s down: PASS ]\n", down_what); in do_test_txn_broker_down_in_txn()
517 TEST_SAY(_C_GRN "[ Test switching coordinators: PASS ]\n"); in do_test_txn_switch_coordinator()
580 TEST_SAY(_C_GRN "[ %s: PASS ]\n", __FUNCTION__); in do_test_txns_not_supported()
|
| H A D | 0091-max_poll_interval_timeout.c | 195 TEST_SAY(_C_GRN in do_test_with_subscribe()
241 TEST_SAY(_C_GRN in do_test_with_assign()
285 TEST_SAY(_C_GRN in do_test_no_poll()
|
| H A D | 0004-conf.c | 173 TEST_SAY(_C_GRN "Ok: %s\n", errstr); in do_test_kafka_new_failures()
200 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
215 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
223 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in do_test_special_invalid_conf()
547 TEST_SAY(_C_GRN "Ok: %s\n" _C_CLR, errstr); in main_0004_conf()
|
| H A D | 0002-unkpart.c | 160 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart()
227 TEST_SAY(_C_GRN "%s PASSED\n" _C_CLR, __FUNCTION__); in do_test_unkpart_timeout_nobroker()
|
| H A D | 0076-produce_retry.c | 154 TEST_SAY(_C_GRN "Test produce retries " in do_test_produce_retries()
307 TEST_SAY(_C_GRN "Test produce retries by disconnect " in do_test_produce_retries_disconnect()
|
| H A D | 0016-client_swname.c | 104 TEST_SAY(_C_GRN "[ Test client.software.name=%s, " in do_test_swname()
|