summaryrefslogtreecommitdiff
path: root/kafka/coordinator/heartbeat.py
Commit message (Collapse)AuthorAgeFilesLines
* Remove unused importskafka-3318Dana Powers2016-04-051-2/+0
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
|
* Fixup heartbeat config assertionDana Powers2015-12-311-1/+1
|
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-3/+3
|
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-11/+15
|
* AbstractCoordinator (modelled after upstream Java class)Dana Powers2015-12-281-0/+43
- Heartbeat class manages HeartbeatRequest / Response state - metrics are still TODO