watcher

Documentation

Index

• Constants
• type AlertQueue
  • func NewAlertQueue() *AlertQueue
  • func (aq *AlertQueue) WriteBackAlert(alertId string)
• type Executor
• type ExecutorInfo
• type ExecutorWatcher
  • func NewExecutorWatcher() *ExecutorWatcher
  • func (ew *ExecutorWatcher) GetExecutorCount() int
  • func (ew *ExecutorWatcher) GetExecutors() []ExecutorInfo
  • func (ew *ExecutorWatcher) Serve()
• type HealthChecker
  • func NewHealthChecker() *HealthChecker
  • func (hc *HealthChecker) HealthCheck()
  • func (hc *HealthChecker) SetExecutorWatcher(executorWatcher *ExecutorWatcher)
• type Member

Constants

const (
	DefaultTimeOut = 60 * time.Second
)

Types

type AlertQueue

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

func NewAlertQueue

func NewAlertQueue() *AlertQueue

func (*AlertQueue) WriteBackAlert

func (aq *AlertQueue) WriteBackAlert(alertId string)

type Executor

type Executor struct {
	Name      string
	TaskCount int
}

type ExecutorInfo

type ExecutorInfo struct {
	Name      string
	TaskCount int
}

ExecutorInfo is the service register information to etcd

type ExecutorWatcher

type ExecutorWatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewExecutorWatcher

func NewExecutorWatcher() *ExecutorWatcher

func (*ExecutorWatcher) GetExecutorCount

func (ew *ExecutorWatcher) GetExecutorCount() int

func (*ExecutorWatcher) GetExecutors

func (ew *ExecutorWatcher) GetExecutors() []ExecutorInfo

func (*ExecutorWatcher) Serve

func (ew *ExecutorWatcher) Serve()

type HealthChecker

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

func NewHealthChecker

func NewHealthChecker() *HealthChecker

func (*HealthChecker) HealthCheck

func (hc *HealthChecker) HealthCheck()

func (*HealthChecker) SetExecutorWatcher

func (hc *HealthChecker) SetExecutorWatcher(executorWatcher *ExecutorWatcher)

type Member

type Member struct {
	Name      string
	TaskCount int
}

Member is a client machine