clustering

type AlertingState struct {
	// contains filtered or unexported fields
}

type ClusterManager struct {
	// contains filtered or unexported fields
}

type ClusterNode struct {
	// contains filtered or unexported fields
}

type ClusterNodeMgmt interface {
	GetNodeId() (string, error)
	CheckIn(alertingState *AlertingState, participantLimit int) error
	GetNode(node *m.ActiveNode) (*m.ActiveNode, error)
	CheckInNodeProcessingMissingAlerts(alertingState *AlertingState) error
	GetActiveNodesCount(heartbeat int64) (int, error)
	GetLastHeartbeat() (int64, error)
	GetMissingAlerts() []*m.Alert
	GetNodeProcessingMissingAlerts() *m.ActiveNode
}

type DispatcherTask struct {
	// contains filtered or unexported fields
}

type DispatcherTaskAlertsMissing struct {
	// contains filtered or unexported fields
}

type DispatcherTaskAlertsPartition struct {
	// contains filtered or unexported fields
}

type DispatcherTaskStatus struct {
	// contains filtered or unexported fields
}