/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_metadata.h | 89 rd_kafka_metadata_new_topic_mock (const rd_kafka_metadata_topic_t *topics, 105 rd_kafka_metadata_topic_t rkmce_mtopic; /* Cached topic metadata */ 149 const rd_kafka_metadata_topic_t *mdt, 170 const rd_kafka_metadata_topic_t * 175 const rd_kafka_metadata_topic_t **mtopicp,
|
H A D | rdkafka_metadata_cache.c | 201 const rd_kafka_metadata_topic_t *mtopic, in rd_kafka_metadata_cache_insert() 330 const rd_kafka_metadata_topic_t *mdt, in rd_kafka_metadata_cache_topic_update() 462 rd_kafka_metadata_topic_t mtopic = { in rd_kafka_metadata_cache_hint() 648 const rd_kafka_metadata_topic_t * 679 const rd_kafka_metadata_topic_t **mtopicp, in rd_kafka_metadata_cache_topic_partition_get() 683 const rd_kafka_metadata_topic_t *mtopic; in rd_kafka_metadata_cache_topic_partition_get()
|
H A D | rdkafka_assignor.h | 90 const rd_kafka_metadata_topic_t *metadata;
|
H A D | rdkafka_metadata.c | 476 rd_kafka_metadata_topic_t *mdt = &md->topics[i]; in rd_kafka_parse_Metadata() 796 const rd_kafka_metadata_topic_t *mtopic; in rd_kafka_metadata_topic_filter() 1296 rd_kafka_metadata_new_topic_mock (const rd_kafka_metadata_topic_t *topics, in rd_kafka_metadata_new_topic_mock() 1372 rd_kafka_metadata_topic_t *topics; in rd_kafka_metadata_new_topic_mockv()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_metadata.h | 89 rd_kafka_metadata_new_topic_mock (const rd_kafka_metadata_topic_t *topics, 105 rd_kafka_metadata_topic_t rkmce_mtopic; /* Cached topic metadata */ 149 const rd_kafka_metadata_topic_t *mdt, 170 const rd_kafka_metadata_topic_t * 175 const rd_kafka_metadata_topic_t **mtopicp,
|
H A D | rdkafka_metadata_cache.c | 201 const rd_kafka_metadata_topic_t *mtopic, in rd_kafka_metadata_cache_insert() 330 const rd_kafka_metadata_topic_t *mdt, in rd_kafka_metadata_cache_topic_update() 462 rd_kafka_metadata_topic_t mtopic = { in rd_kafka_metadata_cache_hint() 648 const rd_kafka_metadata_topic_t * 679 const rd_kafka_metadata_topic_t **mtopicp, in rd_kafka_metadata_cache_topic_partition_get() 683 const rd_kafka_metadata_topic_t *mtopic; in rd_kafka_metadata_cache_topic_partition_get()
|
H A D | rdkafka_assignor.h | 90 const rd_kafka_metadata_topic_t *metadata;
|
H A D | rdkafka_metadata.c | 476 rd_kafka_metadata_topic_t *mdt = &md->topics[i]; 796 const rd_kafka_metadata_topic_t *mtopic; 1296 rd_kafka_metadata_new_topic_mock (const rd_kafka_metadata_topic_t *topics, 1372 rd_kafka_metadata_topic_t *topics;
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_metadata.h | 90 rd_kafka_metadata_topic_t rkmce_mtopic; /* Cached topic metadata */ 124 const rd_kafka_metadata_topic_t *mdt); 141 const rd_kafka_metadata_topic_t * 146 const rd_kafka_metadata_topic_t **mtopicp,
|
H A D | rdkafka_metadata_cache.c | 197 const rd_kafka_metadata_topic_t *mtopic, in rd_kafka_metadata_cache_insert() 315 const rd_kafka_metadata_topic_t *mdt) { in rd_kafka_metadata_cache_topic_update() 436 rd_kafka_metadata_topic_t mtopic = { in rd_kafka_metadata_cache_hint() 574 const rd_kafka_metadata_topic_t * 602 const rd_kafka_metadata_topic_t **mtopicp, in rd_kafka_metadata_cache_topic_partition_get() 606 const rd_kafka_metadata_topic_t *mtopic; in rd_kafka_metadata_cache_topic_partition_get()
|
H A D | rdkafka_assignor.h | 57 const rd_kafka_metadata_topic_t *metadata;
|
H A D | rdkafka_metadata.c | 453 rd_kafka_metadata_topic_t *mdt = &md->topics[i]; in rd_kafka_parse_Metadata() 711 const rd_kafka_metadata_topic_t *mtopic; in rd_kafka_metadata_topic_filter()
|
H A D | rdkafka_assignor.c | 166 const rd_kafka_metadata_topic_t *topic_metadata, in rd_kafka_member_subscription_match()
|
/dports/net/pecl-rdkafka/rdkafka-4.0.4/ |
H A D | metadata_topic.c | 39 const rd_kafka_metadata_topic_t *metadata_topic; 217 rd_kafka_metadata_topic_t *metadata_topic = (rd_kafka_metadata_topic_t*)data; in kafka_metadata_topic_ctor()
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | MetadataImpl.cpp | 102 TopicMetadataImpl(const rd_kafka_metadata_topic_t *topic_metadata) in TopicMetadataImpl() 123 const rd_kafka_metadata_topic_t *topic_metadata_;
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
H A D | MetadataImpl.cpp | 102 TopicMetadataImpl(const rd_kafka_metadata_topic_t *topic_metadata) in TopicMetadataImpl() 123 const rd_kafka_metadata_topic_t *topic_metadata_;
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
H A D | MetadataImpl.cpp | 102 TopicMetadataImpl(const rd_kafka_metadata_topic_t *topic_metadata) in TopicMetadataImpl() 123 const rd_kafka_metadata_topic_t *topic_metadata_;
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0081-admin.c | 54 rd_kafka_metadata_topic_t exp_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 57 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 308 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 311 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 499 rd_kafka_metadata_topic_t exp_mdtopics[MY_CRP_TOPICS_CNT] = {{0}}; in do_test_CreatePartitions() 1192 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_RECORDS_CNT] = {{0}}; in do_test_DeleteRecords() 1484 rd_kafka_metadata_topic_t exp_mdtopic = {0}; in do_test_DeleteGroups() 1652 rd_kafka_metadata_topic_t exp_mdtopics[MY_TOPIC_CNT] = {{0}}; in do_test_DeleteConsumerGroupOffsets()
|
H A D | test.h | 626 rd_kafka_metadata_topic_t *topics, 628 rd_kafka_metadata_topic_t *not_topics,
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0081-admin.c | 54 rd_kafka_metadata_topic_t exp_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 57 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 308 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 311 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 499 rd_kafka_metadata_topic_t exp_mdtopics[MY_CRP_TOPICS_CNT] = {{0}}; in do_test_CreatePartitions() 1192 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_RECORDS_CNT] = {{0}}; in do_test_DeleteRecords() 1484 rd_kafka_metadata_topic_t exp_mdtopic = {0}; in do_test_DeleteGroups() 1652 rd_kafka_metadata_topic_t exp_mdtopics[MY_TOPIC_CNT] = {{0}}; in do_test_DeleteConsumerGroupOffsets()
|
H A D | test.h | 622 rd_kafka_metadata_topic_t *topics, 624 rd_kafka_metadata_topic_t *not_topics,
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0081-admin.c | 54 rd_kafka_metadata_topic_t exp_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 57 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_NEW_TOPICS_CNT] = {{0}}; in do_test_CreateTopics() 300 rd_kafka_metadata_topic_t exp_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 303 rd_kafka_metadata_topic_t exp_not_mdtopics[MY_DEL_TOPICS_CNT] = {{0}}; in do_test_DeleteTopics() 486 rd_kafka_metadata_topic_t exp_mdtopics[MY_CRP_TOPICS_CNT] = {{0}}; in do_test_CreatePartitions()
|
H A D | test.h | 579 rd_kafka_metadata_topic_t *topics, 581 rd_kafka_metadata_topic_t *not_topics,
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | types.rs | 37 pub type RDKafkaMetadataTopic = bindings::rd_kafka_metadata_topic_t;
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
H A D | Metadata.c | 123 c_topics_to_py (Handle *self, const rd_kafka_metadata_topic_t *c_topics, in c_topics_to_py()
|