Documentation ¶
Index ¶
- func GetConfig() (map[string]NodeHealerConfig, error)
- func RemoveConfig(pool, name string) error
- func UpdateConfig(pool string, config NodeHealerConfig) error
- type NodeChecks
- type NodeHealer
- func (h *NodeHealer) GetNodeStatusData(node provision.Node) (NodeStatusData, error)
- func (h *NodeHealer) HandleError(node provision.NodeHealthChecker) time.Duration
- func (h *NodeHealer) RemoveNode(node provision.Node) error
- func (h *NodeHealer) Shutdown(ctx context.Context) error
- func (h *NodeHealer) String() string
- func (h *NodeHealer) UpdateNodeData(nodeAddrs []string, checks []provision.NodeCheckResult) error
- type NodeHealerConfig
- type NodeHealerCustomData
- type NodeStatusData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetConfig ¶
func GetConfig() (map[string]NodeHealerConfig, error)
func RemoveConfig ¶
func UpdateConfig ¶
func UpdateConfig(pool string, config NodeHealerConfig) error
Types ¶
type NodeChecks ¶
type NodeChecks struct { Time time.Time Checks []provision.NodeCheckResult }
type NodeHealer ¶
type NodeHealer struct {
// contains filtered or unexported fields
}
var (
HealerInstance *NodeHealer
)
func Initialize ¶
func Initialize() (*NodeHealer, error)
func (*NodeHealer) GetNodeStatusData ¶
func (h *NodeHealer) GetNodeStatusData(node provision.Node) (NodeStatusData, error)
func (*NodeHealer) HandleError ¶
func (h *NodeHealer) HandleError(node provision.NodeHealthChecker) time.Duration
func (*NodeHealer) RemoveNode ¶
func (h *NodeHealer) RemoveNode(node provision.Node) error
func (*NodeHealer) String ¶
func (h *NodeHealer) String() string
func (*NodeHealer) UpdateNodeData ¶
func (h *NodeHealer) UpdateNodeData(nodeAddrs []string, checks []provision.NodeCheckResult) error
type NodeHealerConfig ¶
type NodeHealerCustomData ¶
type NodeHealerCustomData struct { Node provision.NodeSpec Reason string LastCheck *NodeChecks }
type NodeStatusData ¶
Click to show internal directories.
Click to hide internal directories.