period

type Interface interface {
	//Schedule the specified cron job policy.
	//
	//jobName string           : The name of periodical job
	//params models.Parameters : The parameters required by the periodical job
	//cronSpec string          : The periodical settings with cron format
	//
	//Returns:
	//  The uuid of the cron job policy
	//  The latest next trigger time
	//  error if failed to schedule
	Schedule(jobName string, params models.Parameters, cronSpec string) (string, int64, error)

	//Unschedule the specified cron job policy.
	//
	//cronJobPolicyID string: The ID of cron job policy.
	//
	//Return:
	//  error if failed to unschedule
	UnSchedule(cronJobPolicyID string) error

	//Load and cache data if needed
	//
	//Return:
	//  error if failed to do
	Load() error

	//Clear all the cron job policies.
	//
	//Return:
	//  error if failed to do
	Clear() error

	//Start to serve
	Start()

	//Accept the pushed policy and cache it
	//
	//policy *PeriodicJobPolicy : the periodic policy being accept
	//
	//Return:
	//  error if failed to do
	AcceptPeriodicPolicy(policy *PeriodicJobPolicy) error

	//Remove the specified policy from the cache if it is existing
	//
	//policyID string : ID of the policy being removed
	//
	//Return:
	//  the ptr of the being deletd policy
	RemovePeriodicPolicy(policyID string) *PeriodicJobPolicy
}

type PeriodicJobPolicy struct {
	//NOTES: The 'PolicyID' should not be set when serialize this policy struct to the zset
	//because each 'Policy ID' is different and it may cause issue of losing zset unique capability.
	PolicyID      string                 `json:"policy_id,omitempty"`
	JobName       string                 `json:"job_name"`
	JobParameters map[string]interface{} `json:"job_params"`
	CronSpec      string                 `json:"cron_spec"`
}

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

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