monitor

Documentation

Index

• type Service
  • func NewService(db *db.Client, logstorageService *logstorage.Service, ...) *Service
  • func (s *Service) RecycleHeartbeatTimeoutJobs(ctx context.Context, timeout time.Duration) error

Types

type Service

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

Service is the service that provides the monitor functionality.

func NewService

func NewService(db *db.Client, logstorageService *logstorage.Service, eventhook *eventhook.Service, dispatchService *dispatch.Service) *Service

func (*Service) RecycleHeartbeatTimeoutJobs

func (s *Service) RecycleHeartbeatTimeoutJobs(ctx context.Context, timeout time.Duration) error

RecycleHeartbeatTimeoutJobs recycle heartbeat timeout jobs. If the job execution is not updated for a long time, it will be recycled (update status to failed).