| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/_drivers/ |
| H A D | base.py | 44 def wrapper(in_self, timeout=None, batch_size=1, batch_timeout=None): argument
188 def poll(self, timeout=None, batch_size=1, batch_timeout=None): argument
245 def __init__(self, batch_size, batch_timeout, argument
284 def __init__(self, poll_style_listener, batch_size, batch_timeout): argument
497 def listen(self, target, batch_size, batch_timeout): argument
547 batch_size, batch_timeout): argument
|
| H A D | impl_amqp1.py | 400 def listen(self, target, batch_size, batch_timeout): argument
412 batch_size, batch_timeout): argument
|
| H A D | impl_fake.py | 230 def listen(self, target, batch_size, batch_timeout): argument
244 batch_size, batch_timeout): argument
|
| H A D | impl_kafka.py | 442 def listen(self, target, batch_size, batch_timeout): argument
447 batch_size, batch_timeout): argument
|
| H A D | amqpdriver.py | 696 def listen(self, target, batch_size, batch_timeout): argument
714 batch_size, batch_timeout): argument
|
| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/notify/ |
| H A D | listener.py | 149 batch_timeout=None): argument
256 batch_size=None, batch_timeout=None): argument
|
| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/ |
| H A D | transport.py | 137 def _listen(self, target, batch_size, batch_timeout): argument
146 batch_size, batch_timeout): argument
|
| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/tests/ |
| H A D | test_transport.py | 41 def listen(self, target, batch_size, batch_timeout): argument
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ack-tracker/tests/ |
| H A D | test_batched_ack_tracker.c | 246 Test(batched_ack_tracker, batch_timeout) in Test() argument
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logthrdest/ |
| H A D | logthrdestdrv.h | 119 gint batch_timeout; member
|
| H A D | logthrdestdrv.c | 67 log_threaded_dest_driver_set_batch_timeout(LogDriver *s, gint batch_timeout) in log_threaded_dest_driver_set_batch_timeout()
|
| /dports/net-mgmt/collectd5/collectd-5.12.0/src/ |
| H A D | write_riemann.c | 63 int batch_timeout; member
|
| /dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/tests/functional/ |
| H A D | utils.py | 404 def __init__(self, conf, url, topics, batch_size=5, batch_timeout=2): argument
|