summaryrefslogtreecommitdiff
path: root/test/test_client_async.py
Commit message (Expand)AuthorAgeFilesLines
* Spelling and grammar changes (#923)melissacrawford3962017-01-111-1/+1
* Add metadata update to pattern subscribing (#915)Dmitry Lazurkin2016-12-271-2/+26
* Instrument metrics in BrokerConnectionDana Powers2016-08-041-0/+2
* Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-011-1/+1
* Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-161-2/+2
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-92/+48
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-201-2/+100
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-3/+6
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-241-7/+7
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-1/+14
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-2/+8
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as cal...Dana Powers2016-04-081-10/+24
* Split test_ready to test_is_readyDana Powers2016-04-081-34/+21
* Default sleep=True in client.pollDana Powers2016-04-081-4/+4
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-081-6/+5
* Consolidate conn fixture definitionsDana Powers2016-04-071-15/+0
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-4/+4
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
* Improve KafkaClient connect and ready handlingnode_not_readyDana Powers2016-04-041-44/+40
* Kafka IPv6 Support.Tim Evens2016-03-301-7/+8
* Fix client poll tests (called with sleep=False)Dana Powers2016-01-231-4/+5
* Fix delayed_task timeout commit 45d26b6Dana Powers2016-01-101-3/+3
* Check delayed task timeout in client.poll()Dana Powers2016-01-101-2/+28
* Fill out more async client unit testsDana Powers2016-01-091-18/+165
* Use parameterized pytests in test_client_async; add pytest-mocker pluginDana Powers2016-01-031-70/+94
* Skeleton tests for async kafka clientDana Powers2016-01-011-0/+103