/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
H A D | ConsumerImpl.cpp | 83 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 D | ProducerImpl.cpp | 102 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 D | TopicImpl.cpp | 123 topic->rkt_ = rkt; in create()
|
H A D | rdkafkacpp_int.h | 1005 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 D | HandleImpl.cpp | 187 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | ConsumerImpl.cpp | 83 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 D | ProducerImpl.cpp | 103 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 D | TopicImpl.cpp | 123 topic->rkt_ = rkt; in create()
|
H A D | rdkafkacpp_int.h | 1037 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 D | HandleImpl.cpp | 189 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 D | ConsumerImpl.cpp | 83 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 D | ProducerImpl.cpp | 103 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 D | TopicImpl.cpp | 123 topic->rkt_ = rkt; in create()
|
H A D | rdkafkacpp_int.h | 1037 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 D | HandleImpl.cpp | 189 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 D | connection.rkt | 585 (format "rkt_~a_~a" process-id n)))
|