monitors

Documentation

Index

• type ClusterMonitor
  • func (m ClusterMonitor) Run()
• type InstanceCleaner
  • func (cleaner *InstanceCleaner) GetVersionNo() string
  • func (cleaner *InstanceCleaner) Run()
  • func (cleaner *InstanceCleaner) SetVersionNo(v string)
  • func (cleaner *InstanceCleaner) UniqueKey() string
• type InstanceCountWatchJob
  • func (m *InstanceCountWatchJob) GetVersionNo() string
  • func (m *InstanceCountWatchJob) Run()
  • func (m *InstanceCountWatchJob) SetVersionNo(v string)
  • func (m *InstanceCountWatchJob) UniqueKey() string
• type QueryOrderJobs
  • func (p *QueryOrderJobs) Run()
• type TaskKiller
  • func (m TaskKiller) Run()
• type TaskMonitor
  • func (m TaskMonitor) Run()

Types

type ClusterMonitor

type ClusterMonitor struct {
	LockerClient *clients.EtcdClient
}

ClusterMonitor 负责发现新建立的cluster，并启动一个定时任务，已监控该集群是否有变更

func (ClusterMonitor) Run

func (m ClusterMonitor) Run()

type InstanceCleaner

type InstanceCleaner struct {
	VersionNo    *atomic.String
	LockerClient *clients.EtcdClient
	// contains filtered or unexported fields
}

InstanceCleaner 负责定时扫描云厂商由于系统异常创建的实例，并释放这部分实例

func (*InstanceCleaner) GetVersionNo

func (cleaner *InstanceCleaner) GetVersionNo() string

func (*InstanceCleaner) Run

func (cleaner *InstanceCleaner) Run()

func (*InstanceCleaner) SetVersionNo

func (cleaner *InstanceCleaner) SetVersionNo(v string)

func (*InstanceCleaner) UniqueKey

func (cleaner *InstanceCleaner) UniqueKey() string

type InstanceCountWatchJob

type InstanceCountWatchJob struct {
	ClusterName  string
	VersionNo    *atomic.String
	LockerClient *clients.EtcdClient
	sync.Mutex
}

InstanceCountWatchJob 负责监控一个cluster是否有变更，如果有变更会schedule一个任务，保证需求可以满足

func (*InstanceCountWatchJob) GetVersionNo

func (m *InstanceCountWatchJob) GetVersionNo() string

func (*InstanceCountWatchJob) Run

func (m *InstanceCountWatchJob) Run()

func (*InstanceCountWatchJob) SetVersionNo

func (m *InstanceCountWatchJob) SetVersionNo(v string)

func (*InstanceCountWatchJob) UniqueKey

func (m *InstanceCountWatchJob) UniqueKey() string

type QueryOrderJobs

type QueryOrderJobs struct {
}

func (*QueryOrderJobs) Run

func (p *QueryOrderJobs) Run()

type TaskKiller

type TaskKiller struct {
}

TaskKiller 负责将执行时间超过最大执行时间的任务设置为失败

func (TaskKiller) Run

func (m TaskKiller) Run()

type TaskMonitor

type TaskMonitor struct {
	LockerClient *clients.EtcdClient
}

func (TaskMonitor) Run

func (m TaskMonitor) Run()