monitoring

Documentation

Index

• type Actions
  • func NewActions(logger *WorkerJobLogger, location *time.Location) *Actions
  • func (a *Actions) WorkersLoad(ctx *gin.Context)
  • func (a *Actions) WorkersLoadTotal(ctx *gin.Context)
• type WorkerJobLogger
  • func NewWorkerJobLogger(location *time.Location) *WorkerJobLogger
  • func (w *WorkerJobLogger) GoRunTimelineWriter()
  • func (w *WorkerJobLogger) Log(rec result.JobLog)
  • func (w *WorkerJobLogger) TotalLoad(fromDT, toDT time.Time) (float64, error)
  • func (w *WorkerJobLogger) WorkersLoad(fromDT, toDT time.Time) (WorkersLoad, error)
• type WorkersLoad

Types

type Actions

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

func NewActions

func NewActions(
	logger *WorkerJobLogger,
	location *time.Location,
) *Actions

func (*Actions) WorkersLoad

func (a *Actions) WorkersLoad(ctx *gin.Context)

func (*Actions) WorkersLoadTotal

func (a *Actions) WorkersLoadTotal(ctx *gin.Context)

type WorkerJobLogger

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

func NewWorkerJobLogger

func NewWorkerJobLogger(location *time.Location) *WorkerJobLogger

func (*WorkerJobLogger) GoRunTimelineWriter

func (w *WorkerJobLogger) GoRunTimelineWriter()

func (*WorkerJobLogger) Log

func (w *WorkerJobLogger) Log(rec result.JobLog)

func (*WorkerJobLogger) TotalLoad

func (w *WorkerJobLogger) TotalLoad(fromDT, toDT time.Time) (float64, error)

func (*WorkerJobLogger) WorkersLoad

func (w *WorkerJobLogger) WorkersLoad(fromDT, toDT time.Time) (WorkersLoad, error)

type WorkersLoad

type WorkersLoad map[string]float64