Versions in this module Expand all Collapse all v0 v0.1.0 Jun 21, 2017 Changes in this version + const StateFail + const StateRunning + const StateSuccess + const TypeCron + const TypeOnce + var RunningCount int32 = 0 + func AddNotifyAddr(addr string) + func Count() int + func Init(localIP string) + func NotifyAddrs() []string + func Once(job *Job) string + func ParseIPFromID(id string) (string, error) + func RawOnce(name string, args FuncArg) (string, error) + func Register(name string, f Func) error + func RemoveNotifyAddr(addr string) + func Sleep(ID string, sleep bool) + func Start() + func Status() string + func Stop() + func Update(jobs []Job, version string) error + func Version() string + type Crond struct + Version string + func New() *Crond + func (cd *Crond) Count() int + func (cd *Crond) Entries(query map[string]string) []EntrySpec + func (cd *Crond) Find(name string, args FuncArg) (*Job, error) + func (cd *Crond) FindById(id string) (*Job, error) + func (cd *Crond) Once(job *Job) string + func (cd *Crond) RawOnce(name string, args FuncArg) (string, error) + func (cd *Crond) Register(name string, f Func) error + func (cd *Crond) Sleep(ID string, sleep bool) + func (cd *Crond) Start() + func (cd *Crond) Stop() + func (cd *Crond) Update(jobs []Job, version string) error + func (cd *Crond) WrapFunc(job *Job, rid string) func() + type EntrySpec struct + J Job + Next time.Time + Prev time.Time + func Entries(query map[string]string) []EntrySpec + type Func func(FuncArg) (FuncResult, error) + type FuncArg map[string]interface + func (fa FuncArg) GetInt(key string, defaultv int) int + func (fa FuncArg) GetString(key string, defaultv string) string + func (fa FuncArg) GetStringSlice(key string, defaultv []string) []string + type FuncResult map[string]interface + type Job struct + Action string + Args FuncArg + ID string + Sleep bool + Spec string + Type JobType + func Find(name string, args FuncArg) (*Job, error) + func FindById(id string) (*Job, error) + func (job *Job) GenerateID(ip string) string + func (job *Job) Match(query map[string]string) bool + type JobRecord struct + End time.Time + Reason string + RecordID string + Result FuncResult + Start time.Time + State JobState + func (record *JobRecord) Match(query map[string]string) bool + func (record *JobRecord) Value() interface{} + type JobState string + type JobType string
Go to main page