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) InitCleanCIResourcesScheduler()
  • func (c *CronClient) InitCleanJobScheduler()
  • func (c *CronClient) InitCleanProductScheduler()
  • func (c *CronClient) InitEnvResourceSyncScheduler()
  • func (c *CronClient) InitHealthCheckPmHostScheduler()
  • func (c *CronClient) InitHealthCheckScheduler()
  • func (c *CronClient) InitHelmEnvSyncValuesScheduler()
  • func (c *CronClient) InitJobScheduler()
  • func (c *CronClient) InitOperationStatScheduler()
  • func (c *CronClient) InitPullSonarStatScheduler()
  • func (c *CronClient) InitSystemCapacityGCScheduler()
  • func (c *CronClient) RunScheduledEnvResourceUpdate(productName, envName, resType, resName string, log *zap.SugaredLogger)
  • func (c *CronClient) RunScheduledEnvUpdate(productName, envName string, 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) UpdatePmHostStatusScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertEnvResourceSyncScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertEnvServiceScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertEnvValueSyncScheduler(log *zap.SugaredLogger)
  • func (c *CronClient) UpsertWorkflowScheduler(log *zap.SugaredLogger)
• type CronV3Client
  • func NewCronV3() *CronV3Client
  • func (c *CronV3Client) Start()
• type CronjobHandler
  • func NewCronjobHandler(client *client.Client, scheduler *cronlib.CronSchduler) *CronjobHandler
  • func (h *CronjobHandler) HandleMessage(msgs []*service.CronjobPayload) 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"

	UpsertWorkflowScheduler = "UpsertWorkflowScheduler"

	UpsertTestScheduler = "UpsertTestScheduler"

	UpsertColliePipelineScheduler = "UpsertColliePipelineScheduler"

	CleanProductScheduler = "CleanProductScheduler"

	CleanCIResourcesScheduler = "CleanCIResourcesScheduler"

	InitStatScheduler = "InitStatScheduler"

	InitOperationStatScheduler = "InitOperationStatScheduler"

	InitPullSonarStatScheduler = "InitPullSonarStatScheduler"

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

	InitHealthCheckScheduler = "InitHealthCheckScheduler"

	InitHealthCheckPmHostScheduler = "InitHealthCheckPmHostScheduler"

	InitHelmEnvSyncValuesScheduler = "InitHelmEnvSyncValuesScheduler"

	EnvResourceSyncScheduler = "EnvResourceSyncScheduler"
)

const EnvUpdateInterval = 30

EnvUpdateInterval TODO interval will be set on product in future

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
	Schedulers          map[string]*gocron.Scheduler
	SchedulerController map[string]chan bool

	SchedulersRWMutex          sync.RWMutex
	SchedulerControllerRWMutex sync.RWMutex
	// 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()

func (*CronClient) InitCleanCIResourcesScheduler

func (c *CronClient) InitCleanCIResourcesScheduler()

func (*CronClient) InitCleanJobScheduler

func (c *CronClient) InitCleanJobScheduler()

func (*CronClient) InitCleanProductScheduler

func (c *CronClient) InitCleanProductScheduler()

func (*CronClient) InitEnvResourceSyncScheduler

func (c *CronClient) InitEnvResourceSyncScheduler()

func (*CronClient) InitHealthCheckPmHostScheduler

func (c *CronClient) InitHealthCheckPmHostScheduler()

func (*CronClient) InitHealthCheckScheduler

func (c *CronClient) InitHealthCheckScheduler()

func (*CronClient) InitHelmEnvSyncValuesScheduler

func (c *CronClient) InitHelmEnvSyncValuesScheduler()

func (*CronClient) InitJobScheduler

func (c *CronClient) InitJobScheduler()

func (*CronClient) InitOperationStatScheduler

func (c *CronClient) InitOperationStatScheduler()

func (*CronClient) InitPullSonarStatScheduler

func (c *CronClient) InitPullSonarStatScheduler()

func (*CronClient) InitSystemCapacityGCScheduler

func (c *CronClient) InitSystemCapacityGCScheduler()

func (*CronClient) RunScheduledEnvResourceUpdate

func (c *CronClient) RunScheduledEnvResourceUpdate(productName, envName, resType, resName string, log *zap.SugaredLogger)

func (*CronClient) RunScheduledEnvUpdate

func (c *CronClient) RunScheduledEnvUpdate(productName, envName string, log *zap.SugaredLogger)

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) UpdatePmHostStatusScheduler

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

func (*CronClient) UpsertEnvResourceSyncScheduler

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

func (*CronClient) UpsertEnvServiceScheduler

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

UpsertEnvServiceScheduler ...

func (*CronClient) UpsertEnvValueSyncScheduler

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

func (*CronClient) UpsertWorkflowScheduler

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

type CronV3Client

type CronV3Client struct {
	Scheduler *newgoCron.Scheduler
	AslanCli  *aslan.Client
}

func NewCronV3

func NewCronV3() *CronV3Client

func (*CronV3Client) Start

func (c *CronV3Client) Start()

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(msgs []*service.CronjobPayload) error

HandleMessage ...