cronsun

package module

Go to main page

Versions in this module

v0

v0.3.5-2

Jan 17, 2023

v0.3.2

Jun 10, 2018

Changes in this version

+ var InvalidNodeCmdErr = errors.New("invalid node command")

+ var NodeCmds = []string

+ func PutCsctl(cmd *CsctlCmd) error

+ func WatchCsctl() client.WatchChan

+ type CsctlCmd struct

+ Cmd NodeCmd

+ Exclude []string

+ Include []string

type Node

+ PIDFile string

+ func (n *Node) RmOldInfo()

+ func (n *Node) SyncToMgo()

+ type NodeCmd int

+ const NodeCmdMax

+ const NodeCmdRmOld

+ const NodeCmdSync

+ const NodeCmdUnknown

+ func ToNodeCmd(cmd string) (NodeCmd, error)

+ func (cmd NodeCmd) String() string

type Role

+ const Reporter

v0.3.1

Mar 19, 2018

Changes in this version

+ const VersionNumber

+ func NewEtcdTimeoutContext(c *Client) (context.Context, context.CancelFunc)

type Client

+ func (c *Client) Revoke(id client.LeaseID) (*client.LeaseRevokeResponse, error)

type JobLog

+ Hostname string

+ IP string

type Node

+ Hostname string

+ IP string

+ func GetNodesByID(id string) (node *Node, err error)

v0.2.3

Dec 22, 2017

Changes in this version

type Job

+ LogExpiration int

type JobLog

+ Cleanup time.Time

type StatExecuted

+ Date string

+ func JobLogDailyStat(begin, end time.Time) (ls []*StatExecuted, err error)

v0.2.2

Oct 24, 2017

Changes in this version

+ func ISNodeAlive(id string) (bool, error)

+ func RemoveNode(query interface{}) error

v0.2.1

Sep 14, 2017

Changes in this version

+ const Coll_Account

+ func BanAccount(email string) error

+ func CreateAccount(u *Account) error

+ func EnsureAccountIndex() error

+ func UpdateAccount(query bson.M, change bson.M) error

+ type Account struct

+ CreateTime time.Time

+ Email string

+ ID bson.ObjectId

+ Password string

+ Role Role

+ Salt string

+ Session string

+ Status UserStatus

+ Unchangeable bool

+ func GetAccountByEmail(email string) (u *Account, err error)

+ func GetAccounts(query bson.M) (list []Account, err error)

+ type Role int

+ const Administrator

+ const Developer

+ func (r Role) Defined() bool

+ func (r Role) String() string

+ type UserStatus int

+ const UserActived

+ const UserBanned

+ func (s UserStatus) Defined() bool

v0.1.2

Jun 14, 2017

Changes in this version

type Job

+ Count *int64

+ func (j *Job) Init(n string)

v0.1.1

May 27, 2017

Changes in this version

+ const Binary

+ const Coll_JobLatestLog

+ const Coll_JobLog

+ const Coll_Node

+ const Coll_Stat

+ const DefaultJobGroup

+ const KindAlone

+ const KindCommon

+ const KindInterval

+ var ErrEmptyJobCommand = errors.New("Command of job is empty.")

+ var ErrEmptyJobName = errors.New("Name of job is empty.")

+ var ErrEmptyNodeGroupName = errors.New("Name of node group is empty.")

+ var ErrIllegalJobGroupName = errors.New("Invalid job group name that includes illegal characters such as '/'.")

+ var ErrIllegalJobId = errors.New("Invalid id that includes illegal characters such as '/'.")

+ var ErrIllegalNodeGroupId = errors.New("Invalid node group id that includes illegal characters such as '/'.")

+ var ErrNilRule = errors.New("invalid job rule, empty timer.")

+ var ErrNotFound = errors.New("Record not found.")

+ var ErrSecurityInvalidCmd = errors.New("Security error: the suffix of script file is not on the whitelist.")

+ var ErrSecurityInvalidUser = errors.New("Security error: the user is not on the whitelist.")

+ var ErrValueMayChanged = errors.New("The value has been changed by others on this time.")

+ var Version = fmt.Sprintf("%s (build %s)", Binary, runtime.Version())

+ func CreateJobLog(j *Job, t time.Time, rs string, success bool)

+ func DeleteGroupById(id string) (*client.DeleteResponse, error)

+ func DeleteJob(group, id string) (resp *client.DeleteResponse, err error)

+ func Exit(i interface{})

+ func GetDb() *db.Mdb

+ func GetGroups(nid string) (groups map[string]*Group, err error)

+ func GetIDFromKey(key string) string

+ func GetJobLatestLogListByJobIds(jobIds []string) (m map[string]*JobLatestLog, err error)

+ func GetJobs() (jobs map[string]*Job, err error)

+ func GroupKey(id string) string

+ func ISNodeFault(id string) (bool, error)

+ func Init() (err error)

+ func IsValidAsKeyPath(s string) bool

+ func JobKey(group, id string) string

+ func NextID() string

+ func PutOnce(group, jobID, nodeID string) error

+ func Reload(i interface{})

+ func StartNoticer(n Noticer)

+ func StartProc() error

+ func WatchGroups() client.WatchChan

+ func WatchJobs() client.WatchChan

+ func WatchNode() client.WatchChan

+ func WatchOnce() client.WatchChan

+ type Client struct

+ var DefalutClient *Client

+ func NewClient(cfg *conf.Conf) (c *Client, err error)

+ func (c *Client) DelLock(key string) error

+ func (c *Client) Delete(key string, opts ...client.OpOption) (*client.DeleteResponse, error)

+ func (c *Client) Get(key string, opts ...client.OpOption) (*client.GetResponse, error)

+ func (c *Client) GetLock(key string, id client.LeaseID) (bool, error)

+ func (c *Client) Grant(ttl int64) (*client.LeaseGrantResponse, error)

+ func (c *Client) KeepAliveOnce(id client.LeaseID) (*client.LeaseKeepAliveResponse, error)

+ func (c *Client) Put(key, val string, opts ...client.OpOption) (*client.PutResponse, error)

+ func (c *Client) PutWithModRev(key, val string, rev int64) (*client.PutResponse, error)

+ func (c *Client) Watch(key string, opts ...client.OpOption) client.WatchChan

+ type Cmd struct

+ func (c *Cmd) GetID() string

+ func (c *Cmd) Run()

+ type Group struct

+ ID string

+ Name string

+ NodeIDs []string

+ func GetGroupById(gid string) (g *Group, err error)

+ func GetGroupFromKv(kv *mvccpb.KeyValue) (g *Group, err error)

+ func GetNodeGroups() (list []*Group, err error)

+ func (g *Group) Check() error

+ func (g *Group) Included(nid string) bool

+ func (g *Group) Key() string

+ func (g *Group) Put(modRev int64) (*client.PutResponse, error)

+ type HttpAPI struct

+ func (h *HttpAPI) Send(msg *Message)

+ func (h *HttpAPI) Serve()

+ type Job struct

+ AvgTime int64

+ Command string

+ FailNotify bool

+ Group string

+ ID string

+ Interval int

+ Kind int

+ Name string

+ Parallels int64

+ Pause bool

+ Retry int

+ Rules []*JobRule

+ Timeout int64

+ To []string

+ User string

+ func GetJob(group, id string) (job *Job, err error)

+ func GetJobAndRev(group, id string) (job *Job, rev int64, err error)

+ func GetJobFromKv(kv *mvccpb.KeyValue) (job *Job, err error)

+ func (j *Job) Avg(t, et time.Time)

+ func (j *Job) Check() error

+ func (j *Job) Cmds(nid string, gs map[string]*Group) (cmds map[string]*Cmd)

+ func (j *Job) CountRunning() (int64, error)

+ func (j *Job) Fail(t time.Time, msg string)

+ func (j *Job) Key() string

+ func (j *Job) Notify(t time.Time, msg string)

+ func (j *Job) Run() bool

+ func (j *Job) RunOn(n string)

+ func (j *Job) RunWithRecovery()

+ func (j *Job) ShortName() string

+ func (j *Job) String() string

+ func (j *Job) Success(t time.Time, out string)

+ func (j *Job) Valid() error

+ func (j *Job) ValidRules() error

+ func (j Job) IsRunOn(nid string, gs map[string]*Group) bool

+ type JobLatestLog struct

+ RefLogId string

+ func GetJobLatestLogList(query bson.M, page, size int, sort string) (list []*JobLatestLog, total int, err error)

+ type JobLog struct

+ BeginTime time.Time

+ Command string

+ EndTime time.Time

+ Id bson.ObjectId

+ JobGroup string

+ JobId string

+ Name string

+ Node string

+ Output string

+ Success bool

+ User string

+ func GetJobLogById(id bson.ObjectId) (l *JobLog, err error)

+ func GetJobLogList(query bson.M, page, size int, sort string) (list []*JobLog, total int, err error)

+ type JobRule struct

+ ExcludeNodeIDs []string

+ GroupIDs []string

+ ID string

+ NodeIDs []string

+ Schedule cron.Schedule

+ Timer string

+ func (j *JobRule) Valid() error

+ type Mail struct

+ func NewMail(timeout time.Duration) (m *Mail, err error)

+ func (m *Mail) Send(msg *Message)

+ func (m *Mail) Serve()

+ type Message struct

+ Body string

+ Subject string

+ To []string

+ type Node struct

+ Alived bool

+ Connected bool

+ DownTime time.Time

+ ID string

+ PID string

+ UpTime time.Time

+ Version string

+ func GetNodes() (nodes []*Node, err error)

+ func GetNodesBy(query interface{}) (nodes []*Node, err error)

+ func (n *Node) Del() (*client.DeleteResponse, error)

+ func (n *Node) Down()

+ func (n *Node) Exist() (pid int, err error)

+ func (n *Node) On()

+ func (n *Node) Put(opts ...client.OpOption) (*client.PutResponse, error)

+ func (n *Node) String() string

+ type Noticer interface

+ Send func(*Message)

+ Serve func()

+ type Process struct

+ Group string

+ ID string

+ JobID string

+ NodeID string

+ Time time.Time

+ func GetProcFromKey(key string) (proc *Process, err error)

+ func (p *Process) Key() string

+ func (p *Process) Start()

+ func (p *Process) Stop()

+ func (p *Process) Val() string

+ type StatExecuted struct

+ Failed int64

+ Successed int64

+ Total int64

+ func JobLogDayStat(day time.Time) (s *StatExecuted, err error)

+ func JobLogStat() (s *StatExecuted, err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL