Home
last modified time | relevance | path

Searched refs:ConfImpl (Results 1 – 25 of 26) sorted by relevance

12

/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A DConfImpl.cpp37 RdKafka::ConfImpl::ConfResult RdKafka::ConfImpl::set(const std::string &name, in set()
59 std::list<std::string> *RdKafka::ConfImpl::dump () { in dump()
79 ConfImpl *conf = new ConfImpl(type); in create()
H A DTopicImpl.cpp81 const RdKafka::ConfImpl *confimpl = static_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DProducerImpl.cpp56 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DKafkaConsumerImpl.cpp39 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DConsumerImpl.cpp41 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DMakefile5 CXXSRCS= RdKafka.cpp ConfImpl.cpp HandleImpl.cpp \
H A Drdkafkacpp_int.h468 class ConfImpl : public Conf {
470 ConfImpl(ConfType conf_type) in ConfImpl() function
486 ~ConfImpl () { in ~ConfImpl()
548 const ConfImpl *tconf_impl = in set()
549 dynamic_cast<const RdKafka::ConfImpl *>(topic_conf); in set()
903 void set_common_config (const RdKafka::ConfImpl *confimpl);
H A DHandleImpl.cpp264 void RdKafka::HandleImpl::set_common_config (const RdKafka::ConfImpl *confimpl) { in set_common_config()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A DConfImpl.cpp37 RdKafka::ConfImpl::ConfResult RdKafka::ConfImpl::set(const std::string &name, in set()
59 std::list<std::string> *RdKafka::ConfImpl::dump () { in dump()
79 ConfImpl *conf = new ConfImpl(); in create()
H A DTopicImpl.cpp81 RdKafka::ConfImpl *confimpl = static_cast<RdKafka::ConfImpl *>(conf); in create()
H A DProducerImpl.cpp55 RdKafka::ConfImpl *confimpl = dynamic_cast<RdKafka::ConfImpl *>(conf); in create()
H A DConsumerImpl.cpp41 RdKafka::ConfImpl *confimpl = dynamic_cast<RdKafka::ConfImpl *>(conf); in create()
H A DKafkaConsumerImpl.cpp39 RdKafka::ConfImpl *confimpl = dynamic_cast<RdKafka::ConfImpl *>(conf); in create()
H A DMakefile5 CXXSRCS= RdKafka.cpp ConfImpl.cpp HandleImpl.cpp \
H A Drdkafkacpp_int.h457 class ConfImpl : public Conf {
459 ConfImpl() in ConfImpl() function
473 ~ConfImpl () { in ~ConfImpl()
535 const ConfImpl *tconf_impl = in set()
536 dynamic_cast<const RdKafka::ConfImpl *>(topic_conf); in set()
878 void set_common_config (RdKafka::ConfImpl *confimpl);
H A DHandleImpl.cpp262 void RdKafka::HandleImpl::set_common_config (RdKafka::ConfImpl *confimpl) { in set_common_config()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A DConfImpl.cpp37 RdKafka::ConfImpl::ConfResult RdKafka::ConfImpl::set(const std::string &name, in set()
59 std::list<std::string> *RdKafka::ConfImpl::dump () { in dump()
79 ConfImpl *conf = new ConfImpl(type); in create()
H A DTopicImpl.cpp81 const RdKafka::ConfImpl *confimpl = static_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DProducerImpl.cpp56 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf);
H A DConsumerImpl.cpp41 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DKafkaConsumerImpl.cpp39 const RdKafka::ConfImpl *confimpl = dynamic_cast<const RdKafka::ConfImpl *>(conf); in create()
H A DMakefile5 CXXSRCS= RdKafka.cpp ConfImpl.cpp HandleImpl.cpp \
H A Drdkafkacpp_int.h468 class ConfImpl : public Conf {
470 ConfImpl(ConfType conf_type) in ConfImpl() function
486 ~ConfImpl () { in ~ConfImpl()
548 const ConfImpl *tconf_impl = in set()
549 dynamic_cast<const RdKafka::ConfImpl *>(topic_conf); in set()
903 void set_common_config (const RdKafka::ConfImpl *confimpl);
/dports/devel/libserdes/libserdes-6.0.2/src-cpp/
H A Dserdescpp_int.h38 class ConfImpl : public Conf {
40 ~ConfImpl () { in ~ConfImpl()
47 ConfImpl (): conf_(NULL), log_cb_(NULL) { } in ConfImpl() function
H A DSerdes.cpp74 const ConfImpl *confimpl = conf ? dynamic_cast<const ConfImpl*>(conf) : NULL; in create_serdes()
120 ConfImpl *conf = new ConfImpl(); in create()

12