jobservice

Documentation

Index

• Variables
• type Execution
• type SchedulerController
  • func NewSchedulerCtrl() SchedulerController

Variables

var (
	// SchedulerCtl ...
	SchedulerCtl = NewSchedulerCtrl()
)

Types

type Execution

type Execution struct {
	ID            int64
	Status        string
	StatusMessage string
	Trigger       string
	ExtraAttrs    map[string]interface{}
	StartTime     time.Time
	EndTime       time.Time
}

Execution model for replication

type SchedulerController

type SchedulerController interface {
	// Get the schedule
	Get(ctx context.Context, vendorType string) (*scheduler.Schedule, error)
	// Create with cron type & string
	Create(ctx context.Context, vendorType, cronType, cron, callbackFuncName string, policy interface{}, extrasParam map[string]interface{}) (int64, error)
	// Delete the schedule
	Delete(ctx context.Context, vendorType string) error
	// List lists schedules
	List(ctx context.Context, query *q.Query) ([]*scheduler.Schedule, error)
	// Count counts schedules
	Count(ctx context.Context, query *q.Query) (int64, error)
	// Paused get the job scheduler is paused or not
	Paused(ctx context.Context) (bool, error)
}

SchedulerController interface to manage schedule

func NewSchedulerCtrl

func NewSchedulerCtrl() SchedulerController

NewSchedulerCtrl ...