job

Documentation

Index

• Constants
• type CreateK8sClusterPayload
• type CreateK8sClusterTask
  • func NewCreateK8sClusterTask(l *zap.Logger, client client.K8sClient, dao admin.ClusterDAO) *CreateK8sClusterTask
  • func (k *CreateK8sClusterTask) ProcessTask(ctx context.Context, t *asynq.Task) error
• type Routes
  • func NewRoutes(createK8sCluster *CreateK8sClusterTask, updateK8sCluster *UpdateK8sClusterTask, ...) *Routes
  • func (r *Routes) RegisterHandlers() *asynq.ServeMux
• type TimedPayload
• type TimedScheduler
  • func NewTimedScheduler(scheduler *asynq.Scheduler) *TimedScheduler
  • func (s *TimedScheduler) RegisterTimedTasks() error
  • func (s *TimedScheduler) Run() error
  • func (s *TimedScheduler) Stop()
• type TimedTask
  • func NewTimedTask(l *zap.Logger, k8sClient client.K8sClient, promCache cache.MonitorCache, ...) *TimedTask
  • func (t *TimedTask) ProcessTask(ctx context.Context, task *asynq.Task) error
• type UpdateK8sClusterPayload
• type UpdateK8sClusterTask
  • func NewUpdateK8sClusterTask(l *zap.Logger, client client.K8sClient, dao admin.ClusterDAO) *UpdateK8sClusterTask
  • func (k *UpdateK8sClusterTask) ProcessTask(ctx context.Context, t *asynq.Task) error

Constants

const (
	RefreshK8sClientsTask      = "refresh_k8s_clients"
	RefreshPrometheusCacheTask = "refresh_prometheus_cache"
	CheckHostStatusTask        = "check_host_status"
)

const DeferCreateK8sCluster = "defer_create_k8s_cluster"

const DeferTimedTask = "timed:task"

const DeferUpdateK8sCluster = "defer_update_k8s_cluster"

Types

type CreateK8sClusterPayload

type CreateK8sClusterPayload struct {
	Cluster *model.K8sCluster `json:"cluster"`
}

type CreateK8sClusterTask

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

func NewCreateK8sClusterTask

func NewCreateK8sClusterTask(l *zap.Logger, client client.K8sClient, dao admin.ClusterDAO) *CreateK8sClusterTask

func (*CreateK8sClusterTask) ProcessTask

func (k *CreateK8sClusterTask) ProcessTask(ctx context.Context, t *asynq.Task) error

ProcessTask 处理异步任务

type Routes

type Routes struct {
	CreateK8sCluster *CreateK8sClusterTask
	UpdateK8sCluster *UpdateK8sClusterTask
	TimedTask        *TimedTask
}

func NewRoutes

func NewRoutes(createK8sCluster *CreateK8sClusterTask, updateK8sCluster *UpdateK8sClusterTask, timedTask *TimedTask) *Routes

func (*Routes) RegisterHandlers

func (r *Routes) RegisterHandlers() *asynq.ServeMux

type TimedPayload

type TimedPayload struct {
	TaskName    string    `json:"task_name"`
	LastRunTime time.Time `json:"last_run_time"`
}

type TimedScheduler

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

func NewTimedScheduler

func NewTimedScheduler(scheduler *asynq.Scheduler) *TimedScheduler

func (*TimedScheduler) RegisterTimedTasks

func (s *TimedScheduler) RegisterTimedTasks() error

func (*TimedScheduler) Run

func (s *TimedScheduler) Run() error

func (*TimedScheduler) Stop

func (s *TimedScheduler) Stop()

type TimedTask

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

func NewTimedTask

func NewTimedTask(l *zap.Logger, k8sClient client.K8sClient, promCache cache.MonitorCache, cronMgr cron.CronManager) *TimedTask

func (*TimedTask) ProcessTask

func (t *TimedTask) ProcessTask(ctx context.Context, task *asynq.Task) error

type UpdateK8sClusterPayload

type UpdateK8sClusterPayload struct {
	Cluster *model.K8sCluster `json:"cluster"`
}

type UpdateK8sClusterTask

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

func NewUpdateK8sClusterTask

func NewUpdateK8sClusterTask(l *zap.Logger, client client.K8sClient, dao admin.ClusterDAO) *UpdateK8sClusterTask

func (*UpdateK8sClusterTask) ProcessTask

func (k *UpdateK8sClusterTask) ProcessTask(ctx context.Context, t *asynq.Task) error

ProcessTask 处理异步任务