Home
last modified time | relevance | path

Searched refs:brokers (Results 1 – 25 of 745) sorted by relevance

12345678910>>...30

/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/kafka_ex/
H A Dconfig_test.exs50 test "brokers with list of hosts" do
51 brokers = [{"example.com", 9092}]
52 Application.put_env(:kafka_ex, :brokers, brokers)
54 assert brokers == Config.brokers()
57 test "brokers with a csv of hosts" do
66 Application.put_env(:kafka_ex, :brokers, brokers)
67 assert parsed_brokers == Config.brokers()
73 Application.put_env(:kafka_ex, :brokers, brokers)
78 test "brokers with lazy configuration using fun" do
79 brokers = fn ->
[all …]
/dports/mail/bincimap/bincimap-1.2.13final/src/
H A Dbroker.cc50 brokers[Session::NONAUTHENTICATED] = new Broker(); in BrokerFactory()
51 brokers[Session::AUTHENTICATED] = new Broker(); in BrokerFactory()
52 brokers[Session::SELECTED] = new Broker(); in BrokerFactory()
58 for (map<int, Broker *>::iterator i = brokers.begin(); in ~BrokerFactory()
59 i != brokers.end(); ++i) in ~BrokerFactory()
74 i != brokers.end(); ++i) { in addCapability()
89 i != brokers.end(); ++i) in assign()
99 if (brokers.find(state) == brokers.end()) in getOperator()
102 return brokers.find(state)->second->get(name); in getOperator()
108 if (brokers.find(state) == brokers.end()) { in getBroker()
[all …]
/dports/www/bolt/bolt-2.2.24/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/www/pear-twig/Twig-1.29.0/lib/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/devel/gitlist/gitlist/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/www/limesurvey/limesurvey/application/third_party/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/www/ilias/ILIAS-5.4.25/libs/composer/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/www/itop/web/lib/silex/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php24 protected $brokers = array(); variable in Twig_TokenParserBroker
28 …* @param array|Traversable $brokers A Traversable of Twig_TokenParserBrokerInterfa…
31 …public function __construct($parsers = array(), $brokers = array(), $triggerDeprecationError = tru… argument
43 foreach ($brokers as $broker) {
47 $this->brokers[] = $broker;
66 $this->brokers[] = $broker;
71 if (false !== $pos = array_search($broker, $this->brokers)) {
72 unset($this->brokers[$pos]);
90 $broker = end($this->brokers);
96 $broker = prev($this->brokers);
[all …]
/dports/databases/phpmyadmin/phpMyAdmin-4.9.7-all-languages/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php26 protected $brokers = []; variable in Twig_TokenParserBroker
33 public function __construct($parsers = [], $brokers = [], $triggerDeprecationError = true) argument
45 foreach ($brokers as $broker) {
49 $this->brokers[] = $broker;
68 $this->brokers[] = $broker;
73 if (false !== $pos = array_search($broker, $this->brokers)) {
74 unset($this->brokers[$pos]);
92 $broker = end($this->brokers);
98 $broker = prev($this->brokers);
118 foreach ($this->brokers as $broker) {
/dports/www/drupal8/drupal-8.9.20/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php26 protected $brokers = []; variable in Twig_TokenParserBroker
33 public function __construct($parsers = [], $brokers = [], $triggerDeprecationError = true) argument
45 foreach ($brokers as $broker) {
49 $this->brokers[] = $broker;
68 $this->brokers[] = $broker;
73 if (false !== $pos = array_search($broker, $this->brokers)) {
74 unset($this->brokers[$pos]);
92 $broker = end($this->brokers);
98 $broker = prev($this->brokers);
118 foreach ($this->brokers as $broker) {
/dports/finance/prestashop/prestashop/vendor/twig/twig/lib/Twig/
H A DTokenParserBroker.php26 protected $brokers = []; variable in Twig_TokenParserBroker
33 public function __construct($parsers = [], $brokers = [], $triggerDeprecationError = true) argument
45 foreach ($brokers as $broker) {
49 $this->brokers[] = $broker;
68 $this->brokers[] = $broker;
73 if (false !== $pos = array_search($broker, $this->brokers)) {
74 unset($this->brokers[$pos]);
92 $broker = end($this->brokers);
98 $broker = prev($this->brokers);
118 foreach ($this->brokers as $broker) {
/dports/net/py-kafka-python/kafka-python-1.4.5/test/
H A Dtest_client.py121 brokers = [
148 TopicPartition('topic_1', 0): brokers[1],
151 TopicPartition('topic_3', 0): brokers[0],
172 brokers = [
203 brokers = [
237 brokers = [
264 self.assertEqual(brokers[0], leader)
275 brokers = [
303 brokers = [
350 brokers = [
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/
H A Dmetadata.ex44 brokers: [Broker.t()],
49 def broker_for_topic(metadata, brokers, topic, partition) do
55 find_lead_broker(metadata.brokers, topic_metadata, brokers, partition)
80 defp find_broker(lead_broker, metadata_brokers, brokers) do
199 brokers: brokers,
209 brokers: brokers,
215 defp parse_brokers(_api_version, 0, rest, brokers), do: {brokers, rest}
222 brokers
229 # defp parse_brokers_v1(0, rest, brokers), do: {brokers, rest}
243 brokers
[all …]
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/client/
H A Dstate.rs22 brokers: Vec<Broker>, field
159 state.brokers.get(self.broker.index()) in broker()
202 brokers: Vec::new(), in new()
254 self.brokers.clear(); in clear_metadata()
307 let mut brokers = HashMap::with_capacity(self.brokers.len() + md.brokers.len()); in update_brokers() localVariable
314 for broker in &md.brokers { in update_brokers()
329 self.brokers.push(Broker { in update_brokers()
338 brokers in update_brokers()
387 self.brokers.push(Broker { in set_group_coordinator()
428 brokers: vec![ in metadata_response_initial()
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dclient.go197 brokers := make([]*Broker, 0, len(client.brokers))
199 brokers = append(brokers, broker)
201 return brokers
207 broker, ok := client.brokers[brokerID]
258 client.brokers = nil
269 return client.brokers == nil
458 delete(client.brokers, broker.ID())
611 for _, broker := range brokers {
626 delete(client.brokers, id)
636 if client.brokers == nil {
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/protocol/
H A Dmetadata_test.exs35 brokers: [
64 brokers: [
93 brokers = [
125 brokers: [
154 brokers = [
180 brokers: [
209 brokers = [
238 brokers: [
267 brokers = [
293 brokers: [
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dclient.go192 brokers := make([]*Broker, 0, len(client.brokers))
194 brokers = append(brokers, broker)
196 return brokers
242 client.brokers = nil
253 return client.brokers == nil
568 for _, broker := range brokers {
583 delete(client.brokers, id)
593 if client.brokers == nil {
599 client.brokers[broker.ID()] = broker
603 client.brokers[broker.ID()] = broker
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dclient.go192 brokers := make([]*Broker, 0, len(client.brokers))
194 brokers = append(brokers, broker)
196 return brokers
242 client.brokers = nil
253 return client.brokers == nil
568 for _, broker := range brokers {
583 delete(client.brokers, id)
593 if client.brokers == nil {
599 client.brokers[broker.ID()] = broker
603 client.brokers[broker.ID()] = broker
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/
H A Dserver.ex31 brokers: [],
67 state.brokers,
604 brokers =
612 brokers: brokers,
619 brokers,
626 brokers,
638 brokers,
649 brokers,
752 brokers =
766 brokers: brokers,
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/
H A Drdkafka_zookeeper_example.c186 metadata->brokers[i].id, in metadata_print()
243 char *brokerptr = brokers; in set_brokerlist_from_zookeeper()
278 printf("Found brokers %s\n", brokers); in set_brokerlist_from_zookeeper()
285 char brokers[1024]; in watcher() local
288 brokers[0] = '\0'; in watcher()
289 set_brokerlist_from_zookeeper(zh, brokers); in watcher()
290 if (brokers[0] != '\0' && rk != NULL) in watcher()
292 rd_kafka_brokers_add(rk, brokers); in watcher()
324 char brokers[1024]; in main() local
336 memset(brokers, 0, sizeof(brokers)); in main()
[all …]
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dclient.go173 brokers := make([]*Broker, 0)
174 for _, broker := range client.brokers {
175 brokers = append(brokers, broker)
177 return brokers
196 for _, broker := range client.brokers {
204 client.brokers = nil
211 return client.brokers == nil
428 client.brokers[broker.ID()] = broker
432 client.brokers[broker.ID()] = broker
452 delete(client.brokers, broker.ID())
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/circonus-labs/circonus-gometrics/api/
H A Dbroker_test.go189 brokers, err := apih.FetchBrokers()
194 actualType := reflect.TypeOf(brokers)
217 brokers, err := apih.SearchBrokers(nil, nil)
222 actualType := reflect.TypeOf(brokers)
232 brokers, err := apih.SearchBrokers(&search, nil)
237 actualType := reflect.TypeOf(brokers)
247 brokers, err := apih.SearchBrokers(nil, &filter)
252 actualType := reflect.TypeOf(brokers)
263 brokers, err := apih.SearchBrokers(&search, &filter)
268 actualType := reflect.TypeOf(brokers)
/dports/www/fabio/fabio-1.5.14/vendor/github.com/circonus-labs/circonus-gometrics/circonus-gometrics-2.2.4/api/
H A Dbroker_test.go189 brokers, err := apih.FetchBrokers()
194 actualType := reflect.TypeOf(brokers)
217 brokers, err := apih.SearchBrokers(nil, nil)
222 actualType := reflect.TypeOf(brokers)
232 brokers, err := apih.SearchBrokers(&search, nil)
237 actualType := reflect.TypeOf(brokers)
247 brokers, err := apih.SearchBrokers(nil, &filter)
252 actualType := reflect.TypeOf(brokers)
263 brokers, err := apih.SearchBrokers(&search, &filter)
268 actualType := reflect.TypeOf(brokers)
/dports/security/vault/vault-1.8.2/vendor/github.com/circonus-labs/circonus-gometrics/api/
H A Dbroker_test.go189 brokers, err := apih.FetchBrokers()
194 actualType := reflect.TypeOf(brokers)
217 brokers, err := apih.SearchBrokers(nil, nil)
222 actualType := reflect.TypeOf(brokers)
232 brokers, err := apih.SearchBrokers(&search, nil)
237 actualType := reflect.TypeOf(brokers)
247 brokers, err := apih.SearchBrokers(nil, &filter)
252 actualType := reflect.TypeOf(brokers)
263 brokers, err := apih.SearchBrokers(&search, &filter)
268 actualType := reflect.TypeOf(brokers)
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/examples/
H A Dmetadata.rs13 fn print_metadata(brokers: &str, topic: Option<&str>, timeout: Duration, fetch_offsets: bool) { in print_metadata()
15 .set("bootstrap.servers", brokers) in print_metadata()
28 println!(" Broker count: {}", metadata.brokers().len()); in print_metadata()
34 for broker in metadata.brokers() { in print_metadata()
114 let brokers = matches.value_of("brokers").unwrap(); in main() localVariable
120 brokers, in main()

12345678910>>...30