app

Documentation

Index

• func PrepareRun(configFilePath string, pidFilePath string) error
• func Run(configFilePath string) error
• func RunAsLeader(stopChan <-chan struct{}, config *options.WatchConfig, clusterID string) error
• type HealthChecker
  • func (h *HealthChecker) Run(stopChan <-chan struct{})

Functions

func PrepareRun

func PrepareRun(configFilePath string, pidFilePath string) error

func Run

func Run(configFilePath string) error

func RunAsLeader

func RunAsLeader(stopChan <-chan struct{}, config *options.WatchConfig, clusterID string) error

RunAsLeader do the leader stuff

Types

type HealthChecker

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

func (*HealthChecker) Run

func (h *HealthChecker) Run(stopChan <-chan struct{})