summaryrefslogtreecommitdiff
path: root/kafka/coordinator/base.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2017-03-03 10:14:54 -0800
committerDana Powers <dana.powers@gmail.com>2017-03-03 10:14:54 -0800
commitd9283c14534dd56456e7a3f259f512fa57cc40ad (patch)
tree451818e8d3795fb6ea1012db89d322b87bdf5509 /kafka/coordinator/base.py
parentb1f22b882a338a3456ca88782e05660cffff72f6 (diff)
downloadkafka-python-d9283c14534dd56456e7a3f259f512fa57cc40ad.tar.gz
Add sphinx formatting to hyperlink methods (#898)
Diffstat (limited to 'kafka/coordinator/base.py')
-rw-r--r--kafka/coordinator/base.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index 66d7e6c..d6ffc3a 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -43,10 +43,10 @@ class BaseCoordinator(object):
leader and begins processing.
To leverage this protocol, an implementation must define the format of
- metadata provided by each member for group registration in group_protocols()
- and the format of the state assignment provided by the leader in
- _perform_assignment() and which becomes available to members in
- _on_join_complete().
+ metadata provided by each member for group registration in
+ :meth:`.group_protocols` and the format of the state assignment provided by
+ the leader in :meth:`._perform_assignment` and which becomes available to
+ members in :meth:`._on_join_complete`.
"""
DEFAULT_CONFIG = {
@@ -277,7 +277,7 @@ class BaseCoordinator(object):
"""Join the group and return the assignment for the next generation.
This function handles both JoinGroup and SyncGroup, delegating to
- _perform_assignment() if elected leader by the coordinator.
+ :meth:`._perform_assignment` if elected leader by the coordinator.
Returns:
Future: resolves to the encoded-bytes assignment returned from the