scheduler

Documentation

Index

• Constants
• func BuildScheduledEnvJob(scheduler *gocron.Scheduler, healthCheck *service.PmHealthCheck) *gocron.Job
• func BuildScheduledJob(scheduler *gocron.Scheduler, schedule *service.Schedule) *gocron.Job
• func BuildScheduledPipelineJob(scheduler *gocron.Scheduler, schedule *service.Schedule) *gocron.Job
• func InitExistedCronjob(client *client.Client, scheduler *cronlib.CronSchduler)
• type CronClient
  • func NewCronClient() *CronClient
  • func (c *CronClient) Init()
  • func (c *CronClient) InitBuildStatScheduler()
  • func (c *CronClient) InitCleanJobScheduler()
  • func (c *CronClient) InitCleanProductScheduler()
  • func (c *CronClient) InitColliePipelineScheduler()
  • func (c *CronClient) InitHealthCheckScheduler()
  • func (c *CronClient) InitJobScheduler()
  • func (c *CronClient) InitOperationStatScheduler()
  • func (c *CronClient) InitPullSonarStatScheduler()
  • func (c *CronClient) InitSystemCapacityGCScheduler()
  • func (c *CronClient) InitTestScheduler()
  • func (c *CronClient) RunColliePipelineScheduledTask(pipeline *service.PipelineResource, log *zap.SugaredLogger)
  • func (c *CronClient) RunScheduledPipelineTask(pipeline *service.Pipeline, params *service.TaskArgs, log *zap.SugaredLogger)
  • func (c *CronClient) RunScheduledService(svc *service.Service, healthCheck *service.PmHealthCheck, ...)
  • func (c *CronClient) RunScheduledTask(workflow *service.Workflow, params *service.WorkflowTaskArgs, ...)
  • func (c *CronClient) RunTestScheduledTask(test *service.TestingOpt, log *zap.SugaredLogger)
  • func (c *CronClient) StopTestScheduler(key string, log *zap.SugaredLogger)
  • func (c *CronClient) UpsertColliePipelineScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertEnvServiceScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertTestScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertWorkflowScheduler(log *zap.SugaredLogger)
• type CronjobHandler
  • func NewCronjobHandler(client *client.Client, scheduler *cronlib.CronSchduler) *CronjobHandler
  • func (h *CronjobHandler) HandleMessage(message *nsq.Message) error

Constants

const (
	InitializeThreshold = 5 * time.Minute
	PullInterval        = 3 * time.Second
)

const (
	// Success Result
	Success string = "success"
	// Failure Result
	Failure string = "failure"
	// maxProbeRetries
	MaxProbeRetries = 3
)

const (
	// CleanJobScheduler ...
	CleanJobScheduler = "CleanJobScheduler"
	// UpsertWorkflowScheduler ...
	UpsertWorkflowScheduler = "UpsertWorkflowScheduler"
	// UpsertTestScheduler ...
	UpsertTestScheduler = "UpsertTestScheduler"
	// UpsertColliePipelineScheduler ...
	UpsertColliePipelineScheduler = "UpsertColliePipelineScheduler"
	//CleanProductScheduler ...
	CleanProductScheduler = "CleanProductScheduler"
	//InitBuildStatScheduler
	InitStatScheduler = "InitStatScheduler"
	//InitOperationStatScheduler
	InitOperationStatScheduler = "InitOperationStatScheduler"

	//InitPullSonarStatScheduler
	InitPullSonarStatScheduler = "InitPullSonarStatScheduler"

	// SystemCapacityGC periodically triggers  garbage collection for system data based on its retention policy.
	SystemCapacityGC = "SystemCapacityGC"
	//InitHealthCheckScheduler
	InitHealthCheckScheduler = "InitHealthCheckScheduler"
)

Functions

func BuildScheduledEnvJob

func BuildScheduledEnvJob(scheduler *gocron.Scheduler, healthCheck *service.PmHealthCheck) *gocron.Job

BuildScheduledEnvJob ...

func BuildScheduledJob

func BuildScheduledJob(scheduler *gocron.Scheduler, schedule *service.Schedule) *gocron.Job

BuildScheduledJob ...

func BuildScheduledPipelineJob

func BuildScheduledPipelineJob(scheduler *gocron.Scheduler, schedule *service.Schedule) *gocron.Job

BuildScheduledPipelineJob ...

func InitExistedCronjob

func InitExistedCronjob(client *client.Client, scheduler *cronlib.CronSchduler)

Types

type CronClient

type CronClient struct {
	AslanCli            *client.Client
	CollieCli           *client.CollieClient
	Schedulers          map[string]*gocron.Scheduler
	SchedulerController map[string]chan bool
	// contains filtered or unexported fields
}

CronClient ...

func NewCronClient

func NewCronClient() *CronClient

NewCronClient ... 服务初始化

func (*CronClient) Init

func (c *CronClient) Init()

初始化轮询任务

func (*CronClient) InitBuildStatScheduler

func (c *CronClient) InitBuildStatScheduler()

InitBuildStatScheduler ...

func (*CronClient) InitCleanJobScheduler

func (c *CronClient) InitCleanJobScheduler()

InitCleanJobScheduler ...

func (*CronClient) InitCleanProductScheduler

func (c *CronClient) InitCleanProductScheduler()

InitCleanProductScheduler ...

func (*CronClient) InitColliePipelineScheduler

func (c *CronClient) InitColliePipelineScheduler()

InitJobScheduler ...

func (*CronClient) InitHealthCheckScheduler

func (c *CronClient) InitHealthCheckScheduler()

func (*CronClient) InitJobScheduler

func (c *CronClient) InitJobScheduler()

InitJobScheduler ...

func (*CronClient) InitOperationStatScheduler

func (c *CronClient) InitOperationStatScheduler()

InitOperationStatScheduler ...

func (*CronClient) InitPullSonarStatScheduler

func (c *CronClient) InitPullSonarStatScheduler()

InitPullSonarStatScheduler ...

func (*CronClient) InitSystemCapacityGCScheduler

func (c *CronClient) InitSystemCapacityGCScheduler()

func (*CronClient) InitTestScheduler

func (c *CronClient) InitTestScheduler()

InitTestScheduler ...

func (*CronClient) RunColliePipelineScheduledTask

func (c *CronClient) RunColliePipelineScheduledTask(pipeline *service.PipelineResource, log *zap.SugaredLogger)

RunTestScheduledTask ...

func (*CronClient) RunScheduledPipelineTask

func (c *CronClient) RunScheduledPipelineTask(pipeline *service.Pipeline, params *service.TaskArgs, log *zap.SugaredLogger)

func (*CronClient) RunScheduledService

func (c *CronClient) RunScheduledService(svc *service.Service, healthCheck *service.PmHealthCheck, address, envName, hostID string, log *zap.SugaredLogger)

func (*CronClient) RunScheduledTask

func (c *CronClient) RunScheduledTask(workflow *service.Workflow, params *service.WorkflowTaskArgs, log *zap.SugaredLogger)

RunScheduledTask ...

func (*CronClient) RunTestScheduledTask

func (c *CronClient) RunTestScheduledTask(test *service.TestingOpt, log *zap.SugaredLogger)

RunTestScheduledTask ...

func (*CronClient) StopTestScheduler

func (c *CronClient) StopTestScheduler(key string, log *zap.SugaredLogger)

func (*CronClient) UpsertColliePipelineScheduler

func (c *CronClient) UpsertColliePipelineScheduler(log *zap.SugaredLogger)

UpsertColliePipelineScheduler ...

func (*CronClient) UpsertEnvServiceScheduler

func (c *CronClient) UpsertEnvServiceScheduler(log *zap.SugaredLogger)

UpsertEnvServiceScheduler ...

func (*CronClient) UpsertTestScheduler

func (c *CronClient) UpsertTestScheduler(log *zap.SugaredLogger)

UpsertTestScheduler ...

func (*CronClient) UpsertWorkflowScheduler

func (c *CronClient) UpsertWorkflowScheduler(log *zap.SugaredLogger)

type CronjobHandler

type CronjobHandler struct {
	Scheduler *cronlib.CronSchduler
	// contains filtered or unexported fields
}

func NewCronjobHandler

func NewCronjobHandler(client *client.Client, scheduler *cronlib.CronSchduler) *CronjobHandler

func (*CronjobHandler) HandleMessage

func (h *CronjobHandler) HandleMessage(message *nsq.Message) error

HandleMessage ...