heal

Documentation

Index

• func GetNodeAutoscalingState(instanceId string, client *autoscaling.AutoScaling) (string, error)
• func RestartSystemdService(serviceName string) error
• func StandbyNodeUntilCaughtUp(logMessages chan<- string, kavaClient *kava.Client, healerConfig HealerConfig)
• type AwsDoctor
  • func NewAwsDoctor() (*AwsDoctor, error)
• type HealerConfig

Functions

func GetNodeAutoscalingState

func GetNodeAutoscalingState(instanceId string, client *autoscaling.AutoScaling) (string, error)

GetNodeAutoscalingState gets the autoscaling state of the node based off it's instance id returning the state and error (if any).

func RestartSystemdService

func RestartSystemdService(serviceName string) error

RestartSystemdService restarts a systemd service by name returning error (if any)

func StandbyNodeUntilCaughtUp

func StandbyNodeUntilCaughtUp(logMessages chan<- string, kavaClient *kava.Client, healerConfig HealerConfig)

StandbyNodeUntilCaughtUp will keep the ec2 instance the kava node is on in standby (to shift resources that would be consumed by an api node serving production client requests towards synching up to live faster) until it catches back up.

Types

type AwsDoctor

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

AwsDoctor is a doctor that is capable of healing a kava node running in AWS

func NewAwsDoctor

func NewAwsDoctor() (*AwsDoctor, error)

NewAwsDoctor returns a new AwsDoctor for healing a kava node that is running in aws, and error (if any)

type HealerConfig

type HealerConfig struct {
	AutohealSyncToLiveToleranceSeconds int
}

HealerConfig wraps values for use by one or more runs of one or more healer routines