ecron

May 25, 2023

Changes in this version

type Option

+ func WithSpec(spec string) Option

Apr 20, 2021

Changes in this version

type Config

+ Enable bool

Mar 19, 2021

Changes in this version

type Config

+ EnableSeconds bool

+ RefreshGap time.Duration

+ Spec string

+ type Lock interface

+ Lock func(ctx context.Context, ttl time.Duration) error

+ Refresh func(ctx context.Context, ttl time.Duration) error

+ Unlock func(ctx context.Context) error

type Option

+ func WithJob(job FuncJob) Option

+ func WithLock(lock Lock) Option

+ func WithWrappers(wrappers ...JobWrapper) Option

Mar 15, 2021

Changes in this version

type Config

+ DelayExecType string

+ EnableDistributedTask bool

+ EnableImmediatelyRun bool

+ EnableWithSeconds bool

Mar 1, 2021

Changes in this version

type Config

+ LockDir string

+ LockTTL time.Duration

+ RefreshTTL time.Duration

+ WaitUnlockTime time.Duration

type Locker

+ Refresh func(ctx context.Context, key string, ttl time.Duration) error

Dec 11, 2020

Changes in this version

+ const PackageName

+ var Every = cron.Every

+ var NewChain = cron.NewChain

+ var NewParser = cron.NewParser

+ var WithLocation = cron.WithLocation

+ var WithParser = cron.WithParser

+ var WithSeconds = cron.WithSeconds

+ type Component struct

+ Config *Config

+ func (c *Component) AddFunc(spec string, cmd func() error) (EntryID, error)

+ func (c *Component) AddJob(spec string, cmd NamedJob) (EntryID, error)

+ func (c *Component) GetEntryByName(name string) cron.Entry

+ func (c *Component) Init() error

+ func (c *Component) Name() string

+ func (c *Component) PackageName() string

+ func (c *Component) Schedule(schedule Schedule, job NamedJob) EntryID

+ func (c *Component) Start() error

+ func (c *Component) Stop() error

+ type Config struct

+ AutoSyncInterval time.Duration

+ ConcurrentDelay int

+ ConnectTimeout time.Duration

+ DistributedTask bool

+ Endpoints []string

+ ImmediatelyRun bool

+ Secure bool

+ TTL int

+ WaitLockTime time.Duration

+ WithSeconds bool

+ WorkerLockDir string

+ func DefaultConfig() *Config

+ type Container struct

+ func DefaultContainer() *Container

+ func Load(key string) *Container

+ func (c *Container) Build(options ...Option) *Component

+ type Ecron interface

+ type Entry = cron.Entry

+ type EntryID = cron.EntryID

+ type FuncJob func() error

+ func (f FuncJob) Name() string

+ func (f FuncJob) Run() error

+ type Job = cron.Job

+ type JobWrapper = cron.JobWrapper

+ type Locker interface

+ Lock func(context.Context) error

+ Unlock func(context.Context) error

+ type NamedJob interface

+ Name func() string

+ Run func() error

+ type Option func(c *Container)

+ func WithChain(wrappers ...JobWrapper) Option

+ func WithLocker(locker Locker) Option

+ type Parser = cron.Parser

+ type Schedule = cron.Schedule