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
}
func NewCheckFailController ¶
func NewCheckFailController() *CheckFailController
func (*CheckFailController) Clean ¶
func (dnc *CheckFailController) Clean()
func (*CheckFailController) Collect ¶
func (dnc *CheckFailController) Collect(ch chan<- prometheus.Metric)
func (*CheckFailController) Describe ¶
func (dnc *CheckFailController) Describe(ch chan<- *prometheus.Desc)
func (*CheckFailController) Inc ¶
func (dnc *CheckFailController) Inc(engine, queue, reason string)
type TaskNumController ¶
type TaskNumController struct {
// contains filtered or unexported fields
}
func NewTaskNumController ¶
func NewTaskNumController() *TaskNumController
func (*TaskNumController) Clean ¶
func (tnc *TaskNumController) Clean()
func (*TaskNumController) Collect ¶
func (tnc *TaskNumController) Collect(ch chan<- prometheus.Metric)
func (*TaskNumController) Dec ¶
func (tnc *TaskNumController) Dec(engine, queue, status, reason string)
func (*TaskNumController) Describe ¶
func (tnc *TaskNumController) Describe(ch chan<- *prometheus.Desc)
func (*TaskNumController) Inc ¶
func (tnc *TaskNumController) Inc(engine, queue, status, reason string)
type TaskRunningTimeController ¶
type TaskRunningTimeController struct {
// contains filtered or unexported fields
}
record running duration time
func NewTaskRunningTimeController ¶
func NewTaskRunningTimeController() *TaskRunningTimeController
func (*TaskRunningTimeController) Collect ¶
func (trt *TaskRunningTimeController) Collect(ch chan<- prometheus.Metric)
func (*TaskRunningTimeController) Describe ¶
func (trt *TaskRunningTimeController) Describe(ch chan<- *prometheus.Desc)
func (*TaskRunningTimeController) Observe ¶
func (trt *TaskRunningTimeController) Observe(durationTimeSecond float64)
type TaskTimeController ¶
type TaskTimeController struct {
// contains filtered or unexported fields
}
record all status duration time
func NewTaskTimeController ¶
func NewTaskTimeController() *TaskTimeController
func (*TaskTimeController) Collect ¶
func (ttc *TaskTimeController) Collect(ch chan<- prometheus.Metric)
func (*TaskTimeController) Describe ¶
func (ttc *TaskTimeController) Describe(ch chan<- *prometheus.Desc)
func (*TaskTimeController) Observe ¶
func (ttc *TaskTimeController) Observe(status string, durationTimeSecond float64)
Source Files
Click to show internal directories.
Click to hide internal directories.