summaryrefslogtreecommitdiff
path: root/kafka/future.py
Commit message (Collapse)AuthorAgeFilesLines
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
|
* Simplify RecordMetadata; short circuit callbacks (#768)Dana Powers2016-07-171-1/+2
| | | | Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks
* Cleanup error logging (#760 / #759)Dana Powers2016-07-151-1/+1
| | | | | | - add error type to all KafkaErrors - add args to BrokerResponseError - drop description from BrokerResponseError - fix bug logging errbacks as callbacks
* use the same logic for callbacks regardless of is_done statusZack Dever2016-04-251-12/+15
|
* Remove unused importskafka-3318Dana Powers2016-04-051-2/+0
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
|
* Coerce exceptions to bool in Future.succeeded() and Future.failed()Dana Powers2016-04-051-2/+2
|
* Call errbacks with future.exceptionDana Powers2016-01-031-1/+1
|
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-8/+4
|
* Improvements to kafka.future.FutureDana Powers2015-12-281-8/+37
| | | | | | | | - log exceptions in callbacks/errors - dont raise - guarantee future.exception is an instance, not a class/type - *args, **kwargs in add_callback / errback (functools.partial) - add_both(f, *args, **kwargs) to add same f as callback and errback - chain(new_future) to trigger new_future on success / failure of this
* Use attributes on exception classes to signal retriable and invalid metadata ↵Dana Powers2015-12-281-2/+5
| | | | errors
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-0/+51
- return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion