cron

type Config struct {
	Driver  string
	Tick    time.Duration
	Sync    time.Duration
	LockTTL time.Duration
	Setting Map
}

type Connection interface {
	Open() error
	Close() error

	// Add stores or updates one job definition.
	Add(name string, job Job) error
	// Enable marks one job as enabled.
	Enable(name string) error
	// Disable marks one job as disabled.
	Disable(name string) error
	// Remove deletes one job definition.
	Remove(name string) error
	// List returns all persisted job definitions.
	List() (map[string]Job, error)
	// Append writes one execution log entry.
	AppendLog(log Log) error
	// History returns logs of one job, with total count and paged results.
	History(jobName string, offset, limit int) (int64, []Log, error)

	// Lock tries to acquire a distributed lock key with ttl.
	// It returns true when lock is acquired, false when already locked.
	Lock(key string, ttl time.Duration) (bool, error)
}

type Driver interface {
	Connection(*Instance) (Connection, error)
}

type Instance struct {
	Config  Config
	Setting Map
}

type Job struct {
	Name      string   `json:"name"`
	Desc      string   `json:"desc"`
	Target    string   `json:"target"`
	Schedule  string   `json:"schedule"`
	Schedules []string `json:"schedules"`
	Disabled  bool     `json:"disabled"`
	Payload   Map      `json:"payload"`
	Setting   Map      `json:"setting"`
}

type Jobs map[string]Job

type Log struct {
	Job       string    `json:"job"`
	Schedule  string    `json:"schedule"`
	Target    string    `json:"target"`
	Payload   Map       `json:"payload"`
	Triggered time.Time `json:"triggered"`
	Started   time.Time `json:"started"`
	Ended     time.Time `json:"ended"`
	Success   bool      `json:"success"`
	State     string    `json:"state"`
	Error     string    `json:"error"`
}

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