Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Rebalancer ¶
type Rebalancer struct {
// contains filtered or unexported fields
}
func NewRebalancer ¶
func NewRebalancer(service *bootstrapping.BootstrapService, brokerHost string) Rebalancer
func (*Rebalancer) DeregisterTopicWatchers ¶
func (r *Rebalancer) DeregisterTopicWatchers(topic string) error
func (*Rebalancer) IsMasterNode ¶
func (r *Rebalancer) IsMasterNode() bool
func (*Rebalancer) IsRunning ¶
func (r *Rebalancer) IsRunning() bool
func (*Rebalancer) RegisterTopicWatchers ¶
func (r *Rebalancer) RegisterTopicWatchers(topic string) error
func (*Rebalancer) Wait ¶
func (r *Rebalancer) Wait()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.