| /dports/net/py-pyzmq/pyzmq-22.3.0/examples/pubsub/ |
| H A D | topics_pub.py | 34 all_topics = [
49 print(" %s" % all_topics)
57 for topic in itertools.cycle(all_topics):
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/coordinator/assignors/ |
| H A D | roundrobin.py | 53 all_topics = set()
55 all_topics.update(metadata.subscription)
58 for topic in all_topics:
|
| /dports/devel/py-cmd2/cmd2-2.3.2/examples/scripts/ |
| H A D | save_help_text.py | 91 all_topics = set(self.get_help_topics())
92 to_save = list(all_commands | all_topics)
|
| /dports/textproc/py-gensim/gensim-4.0.1/gensim/test/ |
| H A D | test_nmf.py | 134 all_topics = self.model.get_document_topics(common_corpus)
136 print(list(all_topics))
138 for topic in all_topics:
|
| H A D | test_ldamodel.py | 251 all_topics = model.get_document_topics(self.corpus, per_word_topics=True)
255 for topic in all_topics:
273 all_topics = model.get_document_topics(
279 for topic in all_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.c | 43 rd_kafka_metadata (rd_kafka_t *rk, int all_topics, in rd_kafka_metadata() argument
63 if (!all_topics) { in rd_kafka_metadata()
225 int all_topics = request->rkbuf_u.Metadata.all_topics; in rd_kafka_parse_Metadata() local
499 if (!all_topics) { in rd_kafka_parse_Metadata()
558 if (all_topics) { in rd_kafka_parse_Metadata()
589 if ((requested_topics || all_topics) && rkb->rkb_rk->rk_cgrp) in rd_kafka_parse_Metadata()
|
| H A D | rdkafka_topic.h | 182 rd_kafka_topics_leader_query_sync (rd_kafka_t *rk, int all_topics,
|
| H A D | rdkafka_buf.h | 690 int all_topics; /* Full/All topics requested */ member
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_metadata.c | 43 rd_kafka_metadata (rd_kafka_t *rk, int all_topics, in rd_kafka_metadata() argument
65 if (!all_topics) { in rd_kafka_metadata()
93 all_topics ? rd_true : rd_false, in rd_kafka_metadata()
242 rd_bool_t all_topics = request->rkbuf_u.Metadata.all_topics; in rd_kafka_parse_Metadata() local
515 if (!all_topics) { in rd_kafka_parse_Metadata()
597 if (all_topics) { in rd_kafka_parse_Metadata()
634 if (cgrp_update && (requested_topics || all_topics)) in rd_kafka_parse_Metadata()
|
| H A D | rdkafka_topic.h | 254 rd_kafka_topics_leader_query_sync (rd_kafka_t *rk, int all_topics,
|
| H A D | rdkafka_buf.h | 364 rd_bool_t all_topics; /**< Full/All topics requested */ member
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_metadata.c | 43 rd_kafka_metadata (rd_kafka_t *rk, int all_topics,
65 if (!all_topics) {
93 all_topics ? rd_true : rd_false,
242 rd_bool_t all_topics = request->rkbuf_u.Metadata.all_topics;
515 if (!all_topics) {
597 if (all_topics) {
634 if (cgrp_update && (requested_topics || all_topics))
|
| H A D | rdkafka_topic.h | 254 rd_kafka_topics_leader_query_sync (rd_kafka_t *rk, int all_topics,
|
| H A D | rdkafka_buf.h | 311 rd_bool_t all_topics; /**< Full/All topics requested */
|
| /dports/shells/fish/fish-3.3.1/src/ |
| H A D | topic_monitor.cpp | 168 for (topic_t topic : all_topics()) { in updated_gens_in_data()
261 for (topic_t topic : all_topics()) { in check()
|
| H A D | topic_monitor.h | 51 inline std::array<topic_t, 3> all_topics() { in all_topics() function
|
| /dports/net/pecl-rdkafka/rdkafka-4.0.4/ |
| H A D | kafka_consumer.c | 543 ZEND_ARG_INFO(0, all_topics)
550 zend_bool all_topics; in ZEND_END_ARG_INFO() local
558 …if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "bO!l", &all_topics, &only_zrkt, ce_kafka_top… in ZEND_END_ARG_INFO()
574 …err = rd_kafka_metadata(intern->rk, all_topics, only_orkt ? only_orkt->rkt : NULL, &metadata, time… in ZEND_END_ARG_INFO()
|
| H A D | rdkafka.c | 356 ZEND_ARG_INFO(0, all_topics)
363 zend_bool all_topics; in ZEND_END_ARG_INFO() local
371 …if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "bO!l", &all_topics, &only_zrkt, ce_kafka_top… in ZEND_END_ARG_INFO()
387 …err = rd_kafka_metadata(intern->rk, all_topics, only_orkt ? only_orkt->rkt : NULL, &metadata, time… in ZEND_END_ARG_INFO()
|
| /dports/textproc/py-orange3-text/orange3-text-1.3.1/orangecontrib/text/widgets/ |
| H A D | owtopicmodeling.py | 115 all_topics = Output("All Topics", Table) variable in OWTopicModeling.Outputs
226 self.Outputs.all_topics.send(None)
234 self.Outputs.all_topics.send(self.model.get_all_topics_table())
|
| /dports/textproc/py-orange3-text/orange3-text-1.3.1/orangecontrib/text/widgets/tests/ |
| H A D | test_owtopicmodeling.py | 64 output = self.get_output(self.widget.Outputs.all_topics)
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | HandleImpl.cpp | 181 RdKafka::ErrorCode RdKafka::HandleImpl::metadata (bool all_topics, in metadata() argument
191 const rd_kafka_resp_err_t rc = rd_kafka_metadata(rk_, all_topics, topic, in metadata()
|
| /dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/cloud/amazon/ |
| H A D | sns_topic.py | 279 all_topics = self._list_topics()
281 for topic in all_topics:
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/aws/plugins/modules/ |
| H A D | sns_topic.py | 283 all_topics = self._list_topics()
285 for topic in all_topics:
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | HandleImpl.cpp | 179 RdKafka::ErrorCode RdKafka::HandleImpl::metadata (bool all_topics, in metadata() argument
189 const rd_kafka_resp_err_t rc = rd_kafka_metadata(rk_, all_topics, topic, in metadata()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | HandleImpl.cpp | 181 RdKafka::ErrorCode RdKafka::HandleImpl::metadata (bool all_topics, in metadata() argument
191 const rd_kafka_resp_err_t rc = rd_kafka_metadata(rk_, all_topics, topic, in metadata()
|