/dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/kuberun/core/brokers/ |
H A D | delete.py | 69 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 D | describe.py | 72 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__.py | 35 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 D | delete.py | 73 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 D | describe.py | 75 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 D | anthosevents_operations.py | 342 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 D | source.py | 51 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 D | 0101-fetch-from-follower.cpp | 100 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 D | 0101-fetch-from-follower.cpp | 100 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 D | 0097-ssl_verify.cpp | 57 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 D | 0101-fetch-from-follower.cpp | 100 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 D | test_misc.py | 127 assert isinstance(throttle_event.broker_name, str) and throttle_event.broker_name == "broker"
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | HandleImpl.cpp | 92 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 D | HandleImpl.cpp | 91 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 D | HandleImpl.cpp | 92 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 D | openssl_engine_example.cpp | 73 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 D | openssl_engine_example.cpp | 73 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 D | node_controller.cc | 539 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 D | node_channel.cc | 96 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 D | node_channel.h | 50 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 D | node_controller.cc | 537 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 D | node_channel.cc | 98 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 D | node_channel.h | 50 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 D | rdkafka_conf.h | 244 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 D | rdkafka_conf.h | 257 const char *broker_name, 450 void (*throttle_cb) (rd_kafka_t *rk, const char *broker_name,
|