| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_mock.h | 188 int32_t broker_id,
229 int32_t broker_id);
241 int32_t broker_id);
265 int32_t broker_id);
273 int32_t broker_id);
281 int32_t broker_id, int rtt_ms);
288 int32_t broker_id, const char *rack);
303 int32_t broker_id);
|
| H A D | rdkafka_mock.c | 49 int32_t broker_id) { in rd_kafka_mock_broker_find() argument
53 if (mrkb->id == broker_id) in rd_kafka_mock_broker_find()
1353 mrkb->id = broker_id; in rd_kafka_mock_broker_new()
1467 mcoord->broker_id = broker_id; in rd_kafka_mock_coord_set()
1729 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_leader()
1744 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_follower()
1772 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_down()
1785 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_up()
1798 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_rtt()
1811 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_rack()
[all …]
|
| H A D | rdkafka_admin.c | 1000 int32_t broker_id; in rd_kafka_admin_worker() local
1017 if (broker_id != -1) { in rd_kafka_admin_worker()
1022 name, broker_id, in rd_kafka_admin_worker()
1024 rko->rko_u.admin_request.broker_id = broker_id; in rd_kafka_admin_worker()
1357 int32_t broker_id, in rd_kafka_AdminOptions_set_broker() argument
1359 int ibroker_id = (int)broker_id; in rd_kafka_AdminOptions_set_broker()
2703 broker_id = r; in rd_kafka_ConfigResource_get_single_broker_id()
2709 *broker_idp = broker_id; in rd_kafka_ConfigResource_get_single_broker_id()
2888 &rko->rko_u.admin_request.broker_id, in rd_kafka_AlterConfigs()
3194 &rko->rko_u.admin_request.broker_id, in rd_kafka_DescribeConfigs()
[all …]
|
| H A D | rdkafka_op.h | 430 int32_t broker_id; /**< Requested broker id to member
547 int32_t broker_id; /**< For: member
669 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_mock.h | 184 int32_t broker_id,
225 int32_t broker_id);
237 int32_t broker_id);
261 int32_t broker_id);
269 int32_t broker_id);
277 int32_t broker_id, int rtt_ms);
284 int32_t broker_id, const char *rack);
299 int32_t broker_id);
|
| H A D | rdkafka_mock.c | 49 int32_t broker_id) { in rd_kafka_mock_broker_find() argument
53 if (mrkb->id == broker_id) in rd_kafka_mock_broker_find()
1353 mrkb->id = broker_id; in rd_kafka_mock_broker_new()
1467 mcoord->broker_id = broker_id; in rd_kafka_mock_coord_set()
1708 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_leader()
1723 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_follower()
1751 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_down()
1764 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_up()
1777 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_rtt()
1790 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_rack()
[all …]
|
| H A D | rdkafka_admin.c | 685 int32_t broker_id) {
991 int32_t broker_id;
1008 if (broker_id != -1) {
1013 name, broker_id,
1015 rko->rko_u.admin_request.broker_id = broker_id;
1348 int32_t broker_id,
1350 int ibroker_id = (int)broker_id;
2694 broker_id = r;
2700 *broker_idp = broker_id;
2879 &rko->rko_u.admin_request.broker_id,
[all …]
|
| H A D | rdkafka_op.h | 425 int32_t broker_id; /**< Requested broker id to
536 int32_t broker_id; /**< For:
658 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_mock.h | 175 int32_t broker_id);
187 int32_t broker_id);
211 int32_t broker_id);
219 int32_t broker_id);
228 int32_t broker_id, const char *rack);
243 int32_t broker_id);
|
| H A D | rdkafka_mock.c | 46 int32_t broker_id) { in rd_kafka_mock_broker_find() argument
50 if (mrkb->id == broker_id) in rd_kafka_mock_broker_find()
1289 mrkb->id = broker_id; in rd_kafka_mock_broker_new()
1389 int32_t broker_id) { in rd_kafka_mock_coord_set() argument
1402 mcoord->broker_id = broker_id; in rd_kafka_mock_coord_set()
1573 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_leader()
1588 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_partition_set_follower()
1616 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_down()
1629 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_up()
1642 rko->rko_u.mock.broker_id = broker_id; in rd_kafka_mock_broker_set_rack()
[all …]
|
| H A D | rdkafka_admin.c | 414 rko->rko_u.admin_request.broker_id = -1; in rd_kafka_admin_request_op_new()
702 int32_t broker_id; in rd_kafka_admin_worker() local
719 if (broker_id != -1) { in rd_kafka_admin_worker()
724 name, broker_id, in rd_kafka_admin_worker()
726 rko->rko_u.admin_request.broker_id = broker_id; in rd_kafka_admin_worker()
895 int32_t broker_id, in rd_kafka_AdminOptions_set_broker() argument
897 int ibroker_id = (int)broker_id; in rd_kafka_AdminOptions_set_broker()
2199 int32_t broker_id = -1; in rd_kafka_ConfigResource_get_single_broker_id() local
2208 if (broker_id != -1) { in rd_kafka_ConfigResource_get_single_broker_id()
2226 broker_id = r; in rd_kafka_ConfigResource_get_single_broker_id()
[all …]
|
| H A D | rdkafka_conf.h | 245 int32_t broker_id,
439 int32_t broker_id, int throttle_time_ms,
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/ |
| H A D | __init__.py | 36 broker_id, argument
40 self.broker_id = broker_id
44 …return "{}/{} throttled for {} ms".format(self.broker_name, self.broker_id, int(self.throttle_time…
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
| H A D | cluster.py | 86 def broker_metadata(self, broker_id): argument
95 if broker_id == 'bootstrap':
98 return self._brokers.get(broker_id)
137 def partitions_for_broker(self, broker_id): argument
147 return self._broker_partitions.get(broker_id)
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0039-event.c | 51 int32_t broker_id = rd_kafka_message_broker_id(rkmessage); in handle_drs() local
59 broker_id, in handle_drs()
74 TEST_ASSERT(broker_id >= 0, in handle_drs()
|
| H A D | 0034-offset_reset.c | 166 const int broker_id = 1; in offset_reset_errors() local
249 rd_kafka_mock_broker_set_down(mcluster, broker_id); in offset_reset_errors()
289 broker_id); in offset_reset_errors()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0039-event.c | 51 int32_t broker_id = rd_kafka_message_broker_id(rkmessage); in handle_drs() local
59 broker_id, in handle_drs()
74 TEST_ASSERT(broker_id >= 0, in handle_drs()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/ |
| H A D | admin.rs | 391 broker_id: Option<i32>, field
401 broker_id: None, in new()
441 pub fn broker_id<T: Into<Option<i32>>>(mut self, broker_id: T) -> Self { in broker_id() method
442 self.broker_id = broker_id.into(); in broker_id()
495 if let Some(broker_id) = self.broker_id { in to_native()
499 broker_id, in to_native()
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/ |
| H A D | test_misc.py | 128 assert isinstance(throttle_event.broker_id, int) and throttle_event.broker_id == 0
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | HandleImpl.cpp | 93 int32_t broker_id, in throttle_cb_trampoline() argument
100 event.id_ = broker_id; in throttle_cb_trampoline()
151 int32_t broker_id, 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 | 92 int32_t broker_id, in throttle_cb_trampoline() argument
99 event.id_ = broker_id; in throttle_cb_trampoline()
149 int32_t broker_id, 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 | 93 int32_t broker_id, in throttle_cb_trampoline() argument
100 event.id_ = broker_id; in throttle_cb_trampoline()
151 int32_t broker_id, 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 | 74 int32_t broker_id, in ssl_cert_verify_cb() argument
82 ", broker_id=" << broker_id << 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 | 74 int32_t broker_id, in ssl_cert_verify_cb() argument
82 ", broker_id=" << broker_id << in ssl_cert_verify_cb()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0097-ssl_verify.cpp | 58 int32_t broker_id, in ssl_cert_verify_cb() argument
68 ", broker_id=" << broker_id << in ssl_cert_verify_cb()
|