Home
last modified time | relevance | path

Searched refs:broker_name (Results 1 – 25 of 56) sorted by relevance

123

/dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/kuberun/core/brokers/
H A Ddelete.py69 broker_name = args.BROKER
72 message='Broker [{}] will be deleted.'.format(broker_name),
77 client.DeleteBroker(namespace_ref.Name(), broker_name)
79 log.DeletedResource(broker_name, 'broker')
H A Ddescribe.py72 broker_name = args.BROKER
73 broker_full_name = namespace_ref.RelativeName() + '/brokers/' + broker_name
80 'Broker [{}] not found.'.format(broker_name))
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/
H A D__init__.py35 def __init__(self, broker_name, argument
39 self.broker_name = broker_name
44 …return "{}/{} throttled for {} ms".format(self.broker_name, self.broker_id, int(self.throttle_time…
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/events/brokers/
H A Ddelete.py73 broker_name = args.BROKER
76 message='Broker [{}] will be deleted.'.format(broker_name),
84 client.DeleteBroker(namespace_ref.Name(), broker_name)
86 log.DeletedResource(broker_name, 'broker')
H A Ddescribe.py75 broker_name = args.BROKER
76 broker_full_name = namespace_ref.RelativeName() + '/brokers/' + broker_name
83 'Broker [{}] not found.'.format(broker_name))
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/command_lib/events/
H A Danthosevents_operations.py342 target_service, broker_name): argument
372 trigger_obj.broker = broker_name
479 broker_name, parameters): argument
508 source_obj.set_sink(broker_name, self._api_version)
611 def CreateBroker(self, namespace_name, broker_name): argument
617 broker_obj.name = broker_name
630 'Broker [{}] already exists.'.format(broker_name))
666 def DeleteBroker(self, namespace_name, broker_name): argument
673 namespace_name, broker_name)
681 'Broker [{}] not found.'.format(broker_name))
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/api_lib/events/
H A Dsource.py51 def set_sink(self, broker_name, api_version): argument
56 self._m.spec.sink.ref.name = broker_name
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0101-fetch-from-follower.cpp100 std::string broker_name = itr->name.GetString(); in event_cb() local
101 size_t broker_id_idx = broker_name.rfind('/'); in event_cb()
104 …std::string broker_id = broker_name.substr(broker_id_idx + 1, broker_name.size() - broker_id_idx -… in event_cb()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0101-fetch-from-follower.cpp100 std::string broker_name = itr->name.GetString(); in event_cb() local
101 size_t broker_id_idx = broker_name.rfind('/'); in event_cb()
104 …std::string broker_id = broker_name.substr(broker_id_idx + 1, broker_name.size() - broker_id_idx -… in event_cb()
H A D0097-ssl_verify.cpp57 bool ssl_cert_verify_cb (const std::string &broker_name, in ssl_cert_verify_cb() argument
67 ": broker_name=" << broker_name << in ssl_cert_verify_cb()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0101-fetch-from-follower.cpp100 std::string broker_name = itr->name.GetString();
101 size_t broker_id_idx = broker_name.rfind('/');
104 …std::string broker_id = broker_name.substr(broker_id_idx + 1, broker_name.size() - broker_id_idx -…
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/
H A Dtest_misc.py127 assert isinstance(throttle_event.broker_name, str) and throttle_event.broker_name == "broker"
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A DHandleImpl.cpp92 void RdKafka::throttle_cb_trampoline (rd_kafka_t *rk, const char *broker_name, in throttle_cb_trampoline() argument
99 event.str_ = broker_name; in throttle_cb_trampoline()
150 const char *broker_name, in ssl_cert_verify_cb_trampoline() argument
161 ssl_cert_verify_cb(std::string(broker_name), broker_id, in ssl_cert_verify_cb_trampoline()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A DHandleImpl.cpp91 void RdKafka::throttle_cb_trampoline (rd_kafka_t *rk, const char *broker_name, in throttle_cb_trampoline() argument
98 event.str_ = broker_name; in throttle_cb_trampoline()
148 const char *broker_name, in ssl_cert_verify_cb_trampoline() argument
159 ssl_cert_verify_cb(std::string(broker_name), broker_id, in ssl_cert_verify_cb_trampoline()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A DHandleImpl.cpp92 void RdKafka::throttle_cb_trampoline (rd_kafka_t *rk, const char *broker_name, in throttle_cb_trampoline() argument
99 event.str_ = broker_name; in throttle_cb_trampoline()
150 const char *broker_name, in ssl_cert_verify_cb_trampoline() argument
161 ssl_cert_verify_cb(std::string(broker_name), broker_id, in ssl_cert_verify_cb_trampoline()
/dports/net/librdkafka/librdkafka-1.8.2/examples/
H A Dopenssl_engine_example.cpp73 bool ssl_cert_verify_cb (const std::string &broker_name, in ssl_cert_verify_cb() argument
81 ": broker_name=" << broker_name << in ssl_cert_verify_cb()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/
H A Dopenssl_engine_example.cpp73 bool ssl_cert_verify_cb (const std::string &broker_name, in ssl_cert_verify_cb() argument
81 ": broker_name=" << broker_name << in ssl_cert_verify_cb()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/mojo/core/
H A Dnode_controller.cc539 ports::NodeName broker_name; in GetBrokerChannel() local
542 broker_name = broker_name_; in GetBrokerChannel()
544 return GetPeerChannel(broker_name); in GetBrokerChannel()
939 const ports::NodeName& broker_name, in OnAcceptBrokerClient() argument
960 broker_name_ = broker_name; in OnAcceptBrokerClient()
964 DCHECK(broker_name != ports::kInvalidNodeName); in OnAcceptBrokerClient()
969 if (broker_name == inviter_name) { in OnAcceptBrokerClient()
979 AddPeer(broker_name, broker, true /* start_channel */); in OnAcceptBrokerClient()
1018 DVLOG(1) << "Client " << name_ << " accepted by broker " << broker_name; in OnAcceptBrokerClient()
H A Dnode_channel.cc96 ports::NodeName broker_name; member
325 void NodeChannel::AcceptBrokerClient(const ports::NodeName& broker_name, in AcceptBrokerClient() argument
335 data->broker_name = broker_name; in AcceptBrokerClient()
581 delegate_->OnAcceptBrokerClient(remote_node_name_, data->broker_name, in OnChannelMessage()
H A Dnode_channel.h50 const ports::NodeName& broker_name,
132 void AcceptBrokerClient(const ports::NodeName& broker_name,
/dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/core/
H A Dnode_controller.cc537 ports::NodeName broker_name; in GetBrokerChannel() local
540 broker_name = broker_name_; in GetBrokerChannel()
542 return GetPeerChannel(broker_name); in GetBrokerChannel()
944 const ports::NodeName& broker_name, in OnAcceptBrokerClient() argument
965 broker_name_ = broker_name; in OnAcceptBrokerClient()
969 DCHECK(broker_name != ports::kInvalidNodeName); in OnAcceptBrokerClient()
974 if (broker_name == inviter_name) { in OnAcceptBrokerClient()
984 AddPeer(broker_name, broker, true /* start_channel */); in OnAcceptBrokerClient()
1020 DVLOG(1) << "Client " << name_ << " accepted by broker " << broker_name; in OnAcceptBrokerClient()
H A Dnode_channel.cc98 ports::NodeName broker_name; member
329 void NodeChannel::AcceptBrokerClient(const ports::NodeName& broker_name, in AcceptBrokerClient() argument
339 data->broker_name = broker_name; in AcceptBrokerClient()
585 delegate_->OnAcceptBrokerClient(remote_node_name_, data->broker_name, in OnChannelMessage()
H A Dnode_channel.h50 const ports::NodeName& broker_name,
132 void AcceptBrokerClient(const ports::NodeName& broker_name,
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_conf.h244 const char *broker_name,
438 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name,
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_conf.h257 const char *broker_name,
450 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name,

123