Home
last modified time | relevance | path

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

12

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_metadata.h89 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 Drdkafka_metadata_cache.c201 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 Drdkafka_assignor.h90 const rd_kafka_metadata_topic_t *metadata;
H A Drdkafka_metadata.c476 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 Drdkafka_metadata.h89 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 Drdkafka_metadata_cache.c201 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 Drdkafka_assignor.h90 const rd_kafka_metadata_topic_t *metadata;
H A Drdkafka_metadata.c476 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 Drdkafka_metadata.h90 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 Drdkafka_metadata_cache.c197 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 Drdkafka_assignor.h57 const rd_kafka_metadata_topic_t *metadata;
H A Drdkafka_metadata.c453 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 Drdkafka_assignor.c166 const rd_kafka_metadata_topic_t *topic_metadata, in rd_kafka_member_subscription_match()
/dports/net/pecl-rdkafka/rdkafka-4.0.4/
H A Dmetadata_topic.c39 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 DMetadataImpl.cpp102 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 DMetadataImpl.cpp102 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 DMetadataImpl.cpp102 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 D0081-admin.c54 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 Dtest.h626 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 D0081-admin.c54 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 Dtest.h622 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 D0081-admin.c54 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 Dtest.h579 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 Dtypes.rs37 pub type RDKafkaMetadataTopic = bindings::rd_kafka_metadata_topic_t;
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/
H A DMetadata.c123 c_topics_to_py (Handle *self, const rd_kafka_metadata_topic_t *c_topics, in c_topics_to_py()

12