controllers

Documentation

Index

• Constants
• type CheckFailController
  • func NewCheckFailController() *CheckFailController
  • func (dnc *CheckFailController) Clean()
  • func (dnc *CheckFailController) Collect(ch chan<- prometheus.Metric)
  • func (dnc *CheckFailController) Describe(ch chan<- *prometheus.Desc)
  • func (dnc *CheckFailController) Inc(engine, queue, reason string)
• type TaskNumController
  • func NewTaskNumController() *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
  • func NewTaskRunningTimeController() *TaskRunningTimeController
  • func (trt *TaskRunningTimeController) Collect(ch chan<- prometheus.Metric)
  • func (trt *TaskRunningTimeController) Describe(ch chan<- *prometheus.Desc)
  • func (trt *TaskRunningTimeController) Observe(durationTimeSecond float64)
• type TaskTimeController
  • func NewTaskTimeController() *TaskTimeController
  • func (ttc *TaskTimeController) Collect(ch chan<- prometheus.Metric)
  • func (ttc *TaskTimeController) Describe(ch chan<- *prometheus.Desc)
  • func (ttc *TaskTimeController) Observe(status string, durationTimeSecond float64)

Constants

const (
	CheckFailInitTimeout               = "init timeout"
	CheckFailStagingTimeout            = "staging timeout"
	CheckFailStartingTimeout           = "starting timeout"
	CheckFailHeartbeatTimeout          = "heartbeat timeout"
	CheckFailEngineCheckFail           = "engine check fail"
	CheckFailNotEnoughAvailableWorkers = "not enough available workers"
)

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)