fSchedule

Nov 19, 2024

Changes in this version

+ type ClientVO struct

+ Caption string

+ Cron string

+ Data collections.Dictionary[string, string]

+ IsEnable bool

+ Name string

+ StartAt int64

+ Ver int

Jun 11, 2024

Changes in this version

type JobContext

+ Caption string

+ Ctx context.Context

+ func (receiver *JobContext) Remark(format string, a ...any)

type TaskReportDTO

+ FailRemark string

Feb 4, 2024

Changes in this version

+ var StandardParser = cron.NewParser(...)

+ func RegistryJob()

type ClientJob

+ func (receiver *ClientJob) IsNil() bool

Nov 22, 2023

Changes in this version

type ClientJob

+ Data collections.Dictionary[string, string]

type JobContext

+ TaskGroupId int64

+ Ver int

+ type Option struct

+ Data collections.Dictionary[string, string]

+ StartAt int64

+ type RegistryResponse struct

+ ClientIp string

+ ClientPort int

type TaskEO

+ TaskGroupId int64

type TaskReportDTO

+ TaskGroupId int64

+ Ver int

Jul 27, 2023

Changes in this version

+ type Enum int

+ const Critical

+ const Debug

+ const Error

+ const Information

+ const NoneLevel

+ const Trace

+ const Warning

type JobContext

+ LogQueue chan logContent

+ func (receiver *JobContext) Critical(contents ...any)

+ func (receiver *JobContext) Criticalf(format string, a ...any)

+ func (receiver *JobContext) Debug(contents ...any)

+ func (receiver *JobContext) Debugf(format string, a ...any)

+ func (receiver *JobContext) Error(contents ...any) error

+ func (receiver *JobContext) Errorf(format string, a ...any) error

+ func (receiver *JobContext) Info(contents ...any)

+ func (receiver *JobContext) Infof(format string, a ...any)

+ func (receiver *JobContext) Trace(content ...any)

+ func (receiver *JobContext) Tracef(format string, a ...any)

+ func (receiver *JobContext) Warning(contents ...any)

+ func (receiver *JobContext) Warningf(format string, a ...any)

Mar 3, 2023

Changes in this version

+ func AddJob(isEnable bool, name, caption string, ver int, cron string, startAt int64, ...)

+ func GetClient() *clientVO

+ func Kill(TaskId int64)

+ func NewClient()

+ type ClientJob struct

+ Caption string

+ Cron string

+ IsEnable bool

+ Name string

+ StartAt int64

+ Ver int

+ type Job struct

+ ClientJob ClientJob

+ func (receiver *Job) Run()

+ type JobContext struct

+ Data collections.Dictionary[string, string]

+ Id int64

+ Name string

+ StartAt time.Time

+ func (receiver *JobContext) SetNextAt(t time.Time)

+ func (receiver *JobContext) SetProgress(progress int)

+ type JobFunc func(jobContext *JobContext) bool

+ type Module struct

+ func (module Module) DependsModule() []modules.FarseerModule

+ func (module Module) Initialize()

+ func (module Module) PostInitialize()

+ func (module Module) PreInitialize()

+ func (module Module) Shutdown()

+ type ResourceVO struct

+ AllowSchedule bool

+ CpuUsage float32

+ MemoryUsage float32

+ QueueCount int

+ WorkCount int

+ func Check(clientId int64) ResourceVO

+ func Invoke(task TaskEO) ResourceVO

+ type TaskEO struct

+ Caption string

+ Data collections.Dictionary[string, string]

+ Id int64

+ Name string

+ StartAt time.Time

+ type TaskReportDTO struct

+ Data collections.Dictionary[string, string]

+ Id int64

+ Name string

+ NextTimespan int64

+ Progress int

+ RunSpeed int64

+ Status TaskStatus

+ func Status(TaskId int64) TaskReportDTO

+ type TaskStatus int

+ const Fail

+ const None

+ const ScheduleFail

+ const Scheduling

+ const Success

+ const Working

+ func (receiver TaskStatus) String() string