Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type T ¶
type T struct {
// contains filtered or unexported fields
}
T maintains a consumer group member registration in ZooKeeper, watches for other members to join, leave and update their subscriptions, and generates notifications of such changes.
func (*T) ClaimPartition ¶
func (gm *T) ClaimPartition(claimerActorID *actor.ID, topic string, partition int32, cancelCh <-chan none.T) func()
ClaimPartition claims a topic/partition to be consumed by this member of the consumer group. It blocks until either succeeds or canceled by the caller. It returns a function that should be called to release the claim.
func (*T) Stop ¶
func (gm *T) Stop()
Stop signals the consumer group member to stop and blocks until its goroutines are over.
func (*T) Subscriptions ¶
Subscriptions returns a channel that subscriptions will be sent whenever a member joins or leaves the group or when an existing member updates its subscription.
Source Files
Click to show internal directories.
Click to hide internal directories.