ecron

type Component struct {
	*cron.Cron
	// contains filtered or unexported fields
}

type Config struct {
	WaitLockTime          time.Duration // 抢锁等待时间，默认60s
	LockTTL               time.Duration // 租期，默认60s
	LockDir               string        // 定时任务锁目录
	RefreshTTL            time.Duration // 刷新ttl，默认60s
	WaitUnlockTime        time.Duration // 抢锁等待时间，默认1s
	DelayExecType         string        // skip，queue，concurrent，如果上一个任务执行较慢，到达了新任务执行时间，那么新任务选择跳过，排队，并发执行的策略，新任务默认选择skip策略
	EnableDistributedTask bool          // 是否分布式任务，默认否，如果存在分布式任务，会只执行该定时人物
	EnableImmediatelyRun  bool          // 是否立刻执行，默认否
	EnableWithSeconds     bool          // 是否使用秒作解析器，默认否
	// contains filtered or unexported fields
}

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

type Ecron interface {
	standard.Component
}

type Entry = cron.Entry

type EntryID = cron.EntryID

type FuncJob func() error

type Job = cron.Job

type JobWrapper = cron.JobWrapper

type Locker interface {
	Lock(ctx context.Context, key string, ttl time.Duration) error
	Unlock(ctx context.Context, key string) error
	Refresh(ctx context.Context, key string, ttl time.Duration) error
}

type NamedJob interface {
	Run() error
	Name() string
}

type Option func(c *Container)

type Parser = cron.Parser

type Schedule = cron.Schedule