period

Sep 12, 2018

Changes in this version

+ const EventSchedulePeriodicPolicy

+ const EventUnSchedulePeriodicPolicy

+ type Interface interface

+ AcceptPeriodicPolicy func(policy *PeriodicJobPolicy) error

+ Clear func() error

+ Load func() error

+ RemovePeriodicPolicy func(policyID string) *PeriodicJobPolicy

+ Schedule func(jobName string, params models.Parameters, cronSpec string) (string, int64, error)

+ Start func()

+ UnSchedule func(cronJobPolicyID string) error

+ type PeriodicJobPolicy struct

+ CronSpec string

+ JobName string

+ JobParameters map[string]interface{}

+ PolicyID string

+ func (pjp *PeriodicJobPolicy) DeSerialize(rawJSON []byte) error

+ func (pjp *PeriodicJobPolicy) Serialize() ([]byte, error)

+ type RedisPeriodicScheduler struct

+ func NewRedisPeriodicScheduler(ctx *env.Context, namespace string, redisPool *redis.Pool) *RedisPeriodicScheduler

+ func (rps *RedisPeriodicScheduler) AcceptPeriodicPolicy(policy *PeriodicJobPolicy) error

+ func (rps *RedisPeriodicScheduler) Clear() error

+ func (rps *RedisPeriodicScheduler) Load() error

+ func (rps *RedisPeriodicScheduler) RemovePeriodicPolicy(policyID string) *PeriodicJobPolicy

+ func (rps *RedisPeriodicScheduler) Schedule(jobName string, params models.Parameters, cronSpec string) (string, int64, error)

+ func (rps *RedisPeriodicScheduler) Start()

+ func (rps *RedisPeriodicScheduler) UnSchedule(cronJobPolicyID string) error

+ type Sweeper struct

+ func NewSweeper(namespace string, pool *redis.Pool, client *work.Client) *Sweeper

+ func (s *Sweeper) ClearOutdatedScheduledJobs() error