Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
AllowedEvents = []string{
"ArbitratorError",
"EnterOverloadPeriod",
"ForgetPeer",
"HeartbeatAlive",
"HeartbeatStale",
"HeartbeatMessageTypeUpdated",
"InstanceMonitorAction",
"LeaveOverloadPeriod",
"NodeAlive",
"NodeFrozen",
"NodeSplitAction",
"NodeStale",
}
)
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager(drainDuration time.Duration, subQS pubsub.QueueSizer) *Manager
Click to show internal directories.
Click to hide internal directories.