Home
last modified time | relevance | path

Searched refs:cgmetadata (Results 1 – 25 of 25) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0105-transactions_mock.c190 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local
283 cgmetadata, -1)); in do_test_txn_recoverable_errors()
1105 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_req_cnt() local
1146 cgmetadata, -1)); in do_test_txn_req_cnt()
1171 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local
1487 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_switch_coordinator_refresh() local
1610 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_send_offsets_concurrent_is_retried() local
1677 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_no_timeout_crash() local
1802 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_flush_timeout() local
1889 cgmetadata, -1)); in do_test_txn_flush_timeout()
[all …]
H A D0103-transactions.c1010 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_empty_txn() local
1017 cgmetadata = rd_kafka_consumer_group_metadata(c); in do_test_empty_txn()
1018 TEST_ASSERT(cgmetadata != NULL, in do_test_empty_txn()
1023 p, offsets, cgmetadata, -1)); in do_test_empty_txn()
1025 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_empty_txn()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0105-transactions_mock.c190 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local
283 cgmetadata, -1)); in do_test_txn_recoverable_errors()
285 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_recoverable_errors()
1105 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_req_cnt() local
1146 cgmetadata, -1)); in do_test_txn_req_cnt()
1171 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local
1549 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_send_offsets_concurrent_is_retried() local
1616 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_no_timeout_crash() local
1741 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_flush_timeout() local
1828 cgmetadata, -1)); in do_test_txn_flush_timeout()
[all …]
H A D0103-transactions.c1010 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_empty_txn() local
1017 cgmetadata = rd_kafka_consumer_group_metadata(c); in do_test_empty_txn()
1018 TEST_ASSERT(cgmetadata != NULL, in do_test_empty_txn()
1023 p, offsets, cgmetadata, -1)); in do_test_empty_txn()
1025 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_empty_txn()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0105-transactions_mock.c99 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local
180 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_recoverable_errors()
184 cgmetadata, -1)); in do_test_txn_recoverable_errors()
186 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_recoverable_errors()
220 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local
256 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_requires_abort_errors()
259 cgmetadata, -1); in do_test_txn_requires_abort_errors()
261 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_requires_abort_errors()
323 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_requires_abort_errors()
326 cgmetadata, -1); in do_test_txn_requires_abort_errors()
[all …]
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_cgrp.c5619 return cgmetadata; in rd_kafka_consumer_group_metadata_new()
5630 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new_with_genid()
5637 return cgmetadata; in rd_kafka_consumer_group_metadata_new_with_genid()
5653 cgmetadata = rko->rko_u.cg_metadata; in rd_kafka_consumer_group_metadata()
5657 return cgmetadata; in rd_kafka_consumer_group_metadata()
5663 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy()
5664 rd_free(cgmetadata->member_id); in rd_kafka_consumer_group_metadata_destroy()
5665 if (cgmetadata->group_instance_id) in rd_kafka_consumer_group_metadata_destroy()
5667 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy()
5675 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup()
[all …]
H A Drdkafka_txnmgr.c1645 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_handle_TxnOffsetCommit()
1692 const rd_kafka_consumer_group_metadata_t *cgmetadata = in rd_kafka_txn_send_TxnOffsetCommitRequest() local
1693 rko->rko_u.txn.cgmetadata; in rd_kafka_txn_send_TxnOffsetCommitRequest()
1741 rd_kafka_buf_write_i32(rkbuf, cgmetadata->generation_id); in rd_kafka_txn_send_TxnOffsetCommitRequest()
1743 rd_kafka_buf_write_str(rkbuf, cgmetadata->member_id, -1); in rd_kafka_txn_send_TxnOffsetCommitRequest()
1947 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_handle_AddOffsetsToTxn()
2020 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_op_send_offsets_to_transaction()
2050 const rd_kafka_consumer_group_metadata_t *cgmetadata, in rd_kafka_send_offsets_to_transaction() argument
2059 if (!cgmetadata || !offsets) in rd_kafka_send_offsets_to_transaction()
2079 rko->rko_u.txn.cgmetadata = in rd_kafka_send_offsets_to_transaction()
[all …]
H A Drdkafka_cgrp.h363 const rd_kafka_consumer_group_metadata_t *cgmetadata);
H A Drdkafka_op.h576 rd_kafka_consumer_group_metadata_t *cgmetadata; member
H A Drdkafka_op.c404 RD_IF_FREE(rko->rko_u.txn.cgmetadata, in rd_kafka_op_destroy()
H A Drdkafka.h7642 const rd_kafka_consumer_group_metadata_t *cgmetadata,
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_cgrp.c5471 return cgmetadata; in rd_kafka_consumer_group_metadata_new()
5482 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new_with_genid()
5489 return cgmetadata; in rd_kafka_consumer_group_metadata_new_with_genid()
5505 cgmetadata = rko->rko_u.cg_metadata; in rd_kafka_consumer_group_metadata()
5509 return cgmetadata; in rd_kafka_consumer_group_metadata()
5515 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy()
5516 rd_free(cgmetadata->member_id); in rd_kafka_consumer_group_metadata_destroy()
5517 if (cgmetadata->group_instance_id) in rd_kafka_consumer_group_metadata_destroy()
5519 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy()
5527 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup()
[all …]
H A Drdkafka_txnmgr.c1645 rko->rko_u.txn.cgmetadata->group_id,
1692 const rd_kafka_consumer_group_metadata_t *cgmetadata =
1693 rko->rko_u.txn.cgmetadata;
1741 rd_kafka_buf_write_i32(rkbuf, cgmetadata->generation_id);
1743 rd_kafka_buf_write_str(rkbuf, cgmetadata->member_id, -1);
1940 rko->rko_u.txn.cgmetadata->group_id,
2013 rko->rko_u.txn.cgmetadata->group_id,
2043 const rd_kafka_consumer_group_metadata_t *cgmetadata,
2052 if (!cgmetadata || !offsets)
2072 rko->rko_u.txn.cgmetadata =
[all …]
H A Drdkafka_cgrp.h360 const rd_kafka_consumer_group_metadata_t *cgmetadata);
H A Drdkafka_op.h565 rd_kafka_consumer_group_metadata_t *cgmetadata;
H A Drdkafka_op.c404 RD_IF_FREE(rko->rko_u.txn.cgmetadata, in rd_kafka_op_destroy()
H A Drdkafka.h7636 const rd_kafka_consumer_group_metadata_t *cgmetadata,
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A Drdkafkacpp_int.h1123 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument
1124 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl()
1214 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local
1216 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata()
1217 if (!cgmetadata) in groupMetadata()
1220 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A Drdkafkacpp_int.h1091 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument
1092 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl()
1174 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local
1176 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata()
1177 if (!cgmetadata) in groupMetadata()
1180 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A Drdkafkacpp_int.h1123 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument
1124 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl()
1214 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local
1216 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata()
1217 if (!cgmetadata) in groupMetadata()
1220 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_cgrp.c3634 rd_kafka_consumer_group_metadata_t *cgmetadata; in rd_kafka_consumer_group_metadata_new() local
3639 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new()
3640 cgmetadata->group_id = rd_strdup(group_id); in rd_kafka_consumer_group_metadata_new()
3642 return cgmetadata; in rd_kafka_consumer_group_metadata_new()
3656 rd_kafka_consumer_group_metadata_t *cgmetadata) { in rd_kafka_consumer_group_metadata_destroy() argument
3657 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy()
3658 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy()
3663 const rd_kafka_consumer_group_metadata_t *cgmetadata) { in rd_kafka_consumer_group_metadata_dup() argument
3666 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup()
3667 ret->group_id = rd_strdup(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_dup()
H A Drdkafka_cgrp.h317 const rd_kafka_consumer_group_metadata_t *cgmetadata);
H A Drdkafka_txnmgr.c1813 const rd_kafka_consumer_group_metadata_t *cgmetadata, in rd_kafka_send_offsets_to_transaction() argument
1822 if (!cgmetadata || !offsets) in rd_kafka_send_offsets_to_transaction()
1842 rko->rko_u.txn.group_id = rd_strdup(cgmetadata->group_id); in rd_kafka_send_offsets_to_transaction()
H A Drdkafka.h6795 const rd_kafka_consumer_group_metadata_t *cgmetadata,
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/
H A Dbindings.rs2166 cgmetadata: *const rd_kafka_consumer_group_metadata_t, in rd_kafka_send_offsets_to_transaction()