cronx

Feb 24, 2023

Changes in this version

type Job

+ NextRun time.Time

+ PrevRun time.Time

Sep 6, 2022

Changes in this version

type Option

+ func WithAlerter(client AlerterItf) Option

Jun 2, 2022

Changes in this version

type StatusCode

+ const StatusCodeSuccess

Jun 2, 2022

Changes in this version

+ var DefaultAlerter = NewAlerter()

+ type Alerter struct

+ func NewAlerter() *Alerter

+ func (a *Alerter) NotifyHighLatency(ctx context.Context, job *Job, prev, next time.Time, ...)

+ type AlerterItf interface

+ NotifyHighLatency func(ctx context.Context, job *Job, prev, next time.Time, ...)

type HistoryPageData

+ Sort Sort

type ServerController

+ func (c *ServerController) Histories(ctx echo.Context) error

May 10, 2022

Changes in this version

+ type HistoryPageData struct

+ Data []storage.History

+ Pagination Response

+ type Request struct

+ EndingBefore *string

+ Limit int

+ Sort string

+ StartingAfter *string

+ func (r *Request) QueryParams() map[string]string

+ func (r *Request) URI(req *url.URL) *string

+ func (r *Request) Validate() error

+ type Response struct

+ CursorRange []string

+ EndingBefore *string

+ Limit int

+ NextURI *string

+ PreviousURI *string

+ Sort string

+ StartingAfter *string

+ Total int

+ Yielded int

+ func (r *Response) HasNextPage() bool

+ func (r *Response) HasPrevPage() bool

+ func (r *Response) NextPageCursor() *string

+ func (r *Response) NextPageRequest() *Request

+ func (r *Response) PrevPageCursor() *string

+ func (r *Response) PrevPageRequest() *Request

May 10, 2022

Changes in this version

+ var DefaultStorage = storage.NewNoopClient()

+ type HistoryData struct

+ Data []storage.History

+ Pagination pagination.Response

type Job

+ func (j *Job) RecordHistory(ctx context.Context, start, finish time.Time)

type Manager

+ func (m *Manager) GetHistoryData(ctx context.Context, req pagination.Request) (HistoryData, error)

type Option

+ func WithStorage(client storage.Client) Option

type ServerController

+ func (c *ServerController) APIHistories(ctx echo.Context) error

+ type Sort struct

+ Columns map[string]string

+ Query string

type StatusCode

+ func (s StatusCode) String() string

type StatusPageData

+ Data []StatusData

+ Sort Sort

Apr 19, 2022

Changes in this version

type Manager

+ func (m *Manager) GetStatusPageData(param ...string) StatusPageData

+ type StatusPageData struct

+ SortColumns map[string]string

+ SortQuery string

+ StatusData []StatusData

Apr 17, 2022

Changes in this version

+ const QueryParamSort

+ const SortKeyID

+ const SortKeyLatency

+ const SortKeyName

+ const SortKeyNextRun

+ const SortKeyPrevRun

+ const SortKeyStatus

+ func NewStatusDataSorter(key sortx.Key, order sortx.Order, data []StatusData) sort.Interface

Apr 17, 2022

Changes in this version

type Option

+ func WithLowPriorityDownJobs() Option

Apr 17, 2022

Changes in this version

+ type FuncJob struct

+ func NewFuncJob(name string, cmd Func) *FuncJob

+ func (f FuncJob) Run(ctx context.Context) error

type Manager

+ func (m *Manager) ScheduleFunc(spec, name string, cmd func(ctx context.Context) error) error

+ func (m *Manager) SchedulesFunc(spec, separator, name string, cmd func(ctx context.Context) error) error

type Option

+ func WithAutoStartDisabled() Option

Apr 12, 2022

Changes in this version

+ var DefaultInterceptors = Chain()

+ var DefaultLocation = time.Local

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

+ func GetJobName(job JobItf) (name string)

+ type Manager struct

+ func NewManager(opts ...Option) *Manager

+ func (m *Manager) GetEntries() []cron.Entry

+ func (m *Manager) GetEntry(id cron.EntryID) *cron.Entry

+ func (m *Manager) GetInfo() map[string]interface{}

+ func (m *Manager) GetStatusData() []StatusData

+ func (m *Manager) GetStatusJSON() map[string]interface{}

+ func (m *Manager) Remove(id cron.EntryID)

+ func (m *Manager) Schedule(spec string, job JobItf) error

+ func (m *Manager) Schedules(spec, separator string, job JobItf) error

+ func (m *Manager) Start()

+ func (m *Manager) Stop()

+ type Option func(*Manager)

+ func WithInterceptor(interceptors ...Interceptor) Option

+ func WithLocation(loc *time.Location) Option

+ func WithParser(p cron.Parser) Option

type ServerController

+ Manager *Manager

Mar 30, 2022

Changes in this version

+ const CtxKeyJobMetadata

+ const SleepDuration

+ func Custom(config Config, interceptors ...Interceptor)

+ func Default(interceptors ...Interceptor)

+ func Every(duration time.Duration, job JobItf)

+ func GetEntries() []cron.Entry

+ func GetEntry(id cron.EntryID) *cron.Entry

+ func GetInfo() map[string]interface

+ func GetStatusJSON() map[string]interface

+ func New(interceptors ...Interceptor)

+ func NewServer(address string) (*http.Server, error)

+ func NewSideCarServer(commandCtrl *CommandController)

+ func Remove(id cron.EntryID)

+ func Schedule(spec string, job JobItf) error

+ func ScheduleWithName(name, spec string, job JobItf) error

+ func Schedules(spec, separator string, job JobItf) error

+ func SetJobMetadata(ctx context.Context, meta JobMetadata) context.Context

+ func Stop()

+ type CommandController struct

+ Address string

+ Commander *cron.Cron

+ CreatedTime time.Time

+ Interceptor Interceptor

+ Location *time.Location

+ Parser cron.Parser

+ UnregisteredJobs []*Job

+ func NewCommandController(config Config, interceptors ...Interceptor) *CommandController

+ func (c *CommandController) Info() map[string]interface{}

+ func (c *CommandController) StatusData() []StatusData

+ func (c *CommandController) StatusJSON() map[string]interface{}

+ type Config struct

+ Address string

+ Location *time.Location

+ type Func func(ctx context.Context) error

+ func (r Func) Run(ctx context.Context) error

+ type Handler func(ctx context.Context, job *Job) error

+ type Interceptor func(ctx context.Context, job *Job, handler Handler) error

+ func Chain(interceptors ...Interceptor) Interceptor

+ type Job struct

+ Error string

+ Latency string

+ Name string

+ Status StatusCode

+ func NewJob(job JobItf, name string, waveNumber, totalWave int64) *Job

+ func (j *Job) Run()

+ func (j *Job) UpdateStatus() StatusCode

+ type JobItf interface

+ Run func(ctx context.Context) error

+ type JobMetadata struct

+ EntryID cron.EntryID

+ IsLastWave bool

+ TotalWave int64

+ Wave int64

+ func GetJobMetadata(ctx context.Context) (JobMetadata, bool)

+ type ServerController struct

+ CommandController *CommandController

+ func (c *ServerController) APIJobs(ctx echo.Context) error

+ func (c *ServerController) HealthCheck(ctx echo.Context) error

+ func (c *ServerController) Jobs(ctx echo.Context) error

+ type StatusCode string

+ const StatusCodeDown

+ const StatusCodeError

+ const StatusCodeIdle

+ const StatusCodeRunning

+ const StatusCodeUp

+ type StatusData struct

+ ID cron.EntryID

+ Job *Job

+ Next time.Time

+ Prev time.Time

+ func GetStatusData() []StatusData