Documentation
¶
Index ¶
- Constants
- type CheckFailController
- type TaskNumController
- func (tnc *TaskNumController) Clean()
- func (tnc *TaskNumController) Collect(ch chan<- prometheus.Metric)
- func (tnc *TaskNumController) Dec(engine, queue, status, reason string)
- func (tnc *TaskNumController) Describe(ch chan<- *prometheus.Desc)
- func (tnc *TaskNumController) Inc(engine, queue, status, reason string)
- type TaskRunningTimeController
- type TaskTimeController
Constants ¶
View Source
const ( CheckFailInitTimeout = "init timeout" CheckFailStagingTimeout = "staging timeout" CheckFailStartingTimeout = "starting timeout" CheckFailHeartbeatTimeout = "heartbeat timeout" CheckFailEngineCheckFail = "engine check fail" CheckFailNotEnoughAvailableWorkers = "not enough available workers" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckFailController ¶
type CheckFailController struct {
// contains filtered or unexported fields
}
CheckFailController 描述了错误类型分布的统计
func NewCheckFailController ¶
func NewCheckFailController() *CheckFailController
NewCheckFailController get a new CheckFailController
func (*CheckFailController) Collect ¶
func (dnc *CheckFailController) Collect(ch chan<- prometheus.Metric)
Collect
func (*CheckFailController) Describe ¶
func (dnc *CheckFailController) Describe(ch chan<- *prometheus.Desc)
Describe
func (*CheckFailController) Inc ¶
func (dnc *CheckFailController) Inc(engine, queue, reason string)
Inc 增加给定引擎, 队列, 错误类型的计数
type TaskNumController ¶
type TaskNumController struct {
// contains filtered or unexported fields
}
TaskNumController 描述了task状态分布的统计
func NewTaskNumController ¶
func NewTaskNumController() *TaskNumController
NewTaskNumController get a new TaskNumController
func (*TaskNumController) Collect ¶
func (tnc *TaskNumController) Collect(ch chan<- prometheus.Metric)
Collect
func (*TaskNumController) Dec ¶
func (tnc *TaskNumController) Dec(engine, queue, status, reason string)
Dec 减少给定引擎, 队列, 状态的task计数
func (*TaskNumController) Describe ¶
func (tnc *TaskNumController) Describe(ch chan<- *prometheus.Desc)
Describe
func (*TaskNumController) Inc ¶
func (tnc *TaskNumController) Inc(engine, queue, status, reason string)
Inc 增加给定引擎, 队列, 状态的task计数
type TaskRunningTimeController ¶
type TaskRunningTimeController struct {
// contains filtered or unexported fields
}
record running duration time
func NewTaskRunningTimeController ¶
func NewTaskRunningTimeController() *TaskRunningTimeController
NewTaskRunningTimeController get a new TaskRunningTimeController
func (*TaskRunningTimeController) Collect ¶
func (trt *TaskRunningTimeController) Collect(ch chan<- prometheus.Metric)
Collect
func (*TaskRunningTimeController) Describe ¶
func (trt *TaskRunningTimeController) Describe(ch chan<- *prometheus.Desc)
Describe
func (*TaskRunningTimeController) Observe ¶
func (trt *TaskRunningTimeController) Observe(durationTimeSecond float64)
Observe 增加一次统计, 对running状态的持续时间
type TaskTimeController ¶
type TaskTimeController struct {
// contains filtered or unexported fields
}
record all status duration time
func NewTaskTimeController ¶
func NewTaskTimeController() *TaskTimeController
NewTaskTimeController get a new TaskTimeController
func (*TaskTimeController) Collect ¶
func (ttc *TaskTimeController) Collect(ch chan<- prometheus.Metric)
Collect
func (*TaskTimeController) Describe ¶
func (ttc *TaskTimeController) Describe(ch chan<- *prometheus.Desc)
Describe
func (*TaskTimeController) Observe ¶
func (ttc *TaskTimeController) Observe(status string, durationTimeSecond float64)
Observe 增加一次统计, 对给定状态的持续时间
Source Files
Click to show internal directories.
Click to hide internal directories.