xcron

Nov 20, 2024

Changes in this version

+ type ServerResolver interface

+ Name func() string

+ Resolve func(name string, router *engine.RouterGroup, cfg config.Config, ...) (Server, error)

Aug 1, 2024

Changes in this version

type Job

+ DlockKey string

Nov 16, 2023

Changes in this version

type Job

+ func (m *Job) CalcExpireSeconds() int

+ func (t *Job) GetLockData() string

Sep 19, 2023

Changes in this version

+ func DeregisterServer(name string)

+ func RegisterServer(resolver ServerResover)

+ type Config struct

+ Addr string

+ Proto string

+ Status engine.Status

+ type Job struct

+ Cron string

+ Disable bool

+ Immediately bool

+ Meta metadata.Metadata

+ Monopoly bool

+ Service string

+ WithSeconds bool

+ func (m *Job) CalcExpireTime() int

+ func (m *Job) Init() (err error)

+ func (m *Job) NextTime(t time.Time) time.Time

+ func (t *Job) GetKey() string

+ func (t *Job) GetService() string

+ func (t *Job) IsImmediately() bool

+ func (t *Job) IsMonopoly() bool

+ type Server interface

+ AddJob func(jobs ...*Job) (keys []string, err error)

+ GetAddr func() string

+ GetProto func() string

+ RemoveJob func(key ...string)

+ Serve func(ctx context.Context) (err error)

+ Stop func(ctx context.Context) error

+ func NewServer(proto string, router *engine.RouterGroup, cfg config.Config, ...) (Server, error)

+ type ServerResover interface

+ Name func() string

+ Resolve func(name string, router *engine.RouterGroup, cfg config.Config, ...) (Server, error)