Home
last modified time | relevance | path

Searched refs:rkt_ (Results 1 – 16 of 16) sorted by relevance

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A DConsumerImpl.cpp83 if (rd_kafka_consume_start(topicimpl->rkt_, partition, offset) == -1) in start()
97 if (rd_kafka_consume_start_queue(topicimpl->rkt_, partition, offset, in start()
109 if (rd_kafka_consume_stop(topicimpl->rkt_, partition) == -1) in stop()
121 if (rd_kafka_seek(topicimpl->rkt_, partition, offset, timeout_ms) == -1) in seek()
133 rkmessage = rd_kafka_consume(topicimpl->rkt_, partition, timeout_ms); in consume()
173 return rd_kafka_consume_callback(topicimpl->rkt_, partition, timeout_ms, in consume_callback()
H A DProducerImpl.cpp102 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags, in produce()
121 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags, in produce()
138 if (rd_kafka_produce(topicimpl->rkt_, partition, RD_KAFKA_MSG_F_COPY, in produce()
H A DTopicImpl.cpp123 topic->rkt_ = rkt; in create()
H A Drdkafkacpp_int.h1005 rd_kafka_topic_destroy(rkt_); in ~TopicImpl()
1009 return rd_kafka_topic_name(rkt_); in name()
1013 return !!rd_kafka_topic_partition_available(rkt_, partition); in partition_available()
1018 rd_kafka_offset_store(rkt_, partition, offset)); in offset_store()
1025 return rkt_; in c_ptr()
1028 rd_kafka_topic_t *rkt_; variable
H A DHandleImpl.cpp187 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A DConsumerImpl.cpp83 if (rd_kafka_consume_start(topicimpl->rkt_, partition, offset) == -1) in start()
97 if (rd_kafka_consume_start_queue(topicimpl->rkt_, partition, offset, in start()
109 if (rd_kafka_consume_stop(topicimpl->rkt_, partition) == -1) in stop()
121 if (rd_kafka_seek(topicimpl->rkt_, partition, offset, timeout_ms) == -1) in seek()
133 rkmessage = rd_kafka_consume(topicimpl->rkt_, partition, timeout_ms); in consume()
174 return rd_kafka_consume_callback(topicimpl->rkt_, partition, timeout_ms, in consume_callback()
H A DProducerImpl.cpp103 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags, in produce()
122 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags, in produce()
139 if (rd_kafka_produce(topicimpl->rkt_, partition, RD_KAFKA_MSG_F_COPY, in produce()
H A DTopicImpl.cpp123 topic->rkt_ = rkt; in create()
H A Drdkafkacpp_int.h1037 rd_kafka_topic_destroy(rkt_); in ~TopicImpl()
1041 return rd_kafka_topic_name(rkt_); in name()
1045 return !!rd_kafka_topic_partition_available(rkt_, partition); in partition_available()
1050 rd_kafka_offset_store(rkt_, partition, offset)); in offset_store()
1057 return rkt_; in c_ptr()
1060 rd_kafka_topic_t *rkt_; variable
H A DHandleImpl.cpp189 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A DConsumerImpl.cpp83 if (rd_kafka_consume_start(topicimpl->rkt_, partition, offset) == -1) in start()
97 if (rd_kafka_consume_start_queue(topicimpl->rkt_, partition, offset, in start()
109 if (rd_kafka_consume_stop(topicimpl->rkt_, partition) == -1) in stop()
121 if (rd_kafka_seek(topicimpl->rkt_, partition, offset, timeout_ms) == -1) in seek()
133 rkmessage = rd_kafka_consume(topicimpl->rkt_, partition, timeout_ms); in consume()
174 return rd_kafka_consume_callback(topicimpl->rkt_, partition, timeout_ms, in consume_callback()
H A DProducerImpl.cpp103 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags,
122 if (rd_kafka_produce(topicimpl->rkt_, partition, msgflags,
139 if (rd_kafka_produce(topicimpl->rkt_, partition, RD_KAFKA_MSG_F_COPY,
H A DTopicImpl.cpp123 topic->rkt_ = rkt; in create()
H A Drdkafkacpp_int.h1037 rd_kafka_topic_destroy(rkt_); in ~TopicImpl()
1041 return rd_kafka_topic_name(rkt_); in name()
1045 return !!rd_kafka_topic_partition_available(rkt_, partition); in partition_available()
1050 rd_kafka_offset_store(rkt_, partition, offset)); in offset_store()
1057 return rkt_; in c_ptr()
1060 rd_kafka_topic_t *rkt_; variable
H A DHandleImpl.cpp189 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
/dports/lang/racket/racket-8.3/share/pkgs/db-lib/db/private/postgresql/
H A Dconnection.rkt585 (format "rkt_~a_~a" process-id n)))