Documentation ¶
Index ¶
- func ActiveJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func AddFunc(quene delayquene.Quene, apiRedis *redis.Pool, lpool *luacore.LStatePool) func(w http.ResponseWriter, r *http.Request)
- func AddJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func DumpAll(m *migrate.Migrate) func(w http.ResponseWriter, r *http.Request)
- func DumpBy(m *migrate.Migrate) func(w http.ResponseWriter, r *http.Request)
- func EditJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func GetGroupList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func GetJobList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func GetNodeList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func GroupInfo(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func GroupJobClear(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func Import(m *migrate.Migrate) func(w http.ResponseWriter, r *http.Request)
- func PauseJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func RegisterGroup(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func RemoveGroup(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func RemoveJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func RemoveJobsByJobName(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
- func SetLogger(l *logrus.Logger)
- func Version(serverVersion string) func(w http.ResponseWriter, r *http.Request)
- type ActiveJobPayload
- type AddFuncPayload
- type AddJobPayload
- type EditJobPayload
- type GetJobsPayload
- type JobControlPayload
- type RegisterGroupPayload
- type ResponseJobList
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ActiveJob ¶
func ActiveJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func AddFunc ¶
func AddFunc(quene delayquene.Quene, apiRedis *redis.Pool, lpool *luacore.LStatePool) func(w http.ResponseWriter, r *http.Request)
func AddJob ¶
func AddJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func EditJob ¶
func EditJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func GetGroupList ¶
func GetGroupList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func GetJobList ¶
func GetJobList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func GetNodeList ¶
func GetNodeList(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func GroupInfo ¶
func GroupInfo(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func GroupJobClear ¶ added in v1.1.0
func GroupJobClear(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func PauseJob ¶
func PauseJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func RegisterGroup ¶
func RegisterGroup(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func RemoveGroup ¶ added in v1.3.0
func RemoveGroup(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func RemoveJob ¶
func RemoveJob(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
func RemoveJobsByJobName ¶ added in v1.2.0
func RemoveJobsByJobName(quene delayquene.Quene) func(w http.ResponseWriter, r *http.Request)
Types ¶
type ActiveJobPayload ¶
type AddFuncPayload ¶
type AddJobPayload ¶
type AddJobPayload struct { GroupName string `json:"group_name"` JobId string `json:"job_id"` Name string `json:"name"` Exectime int64 `json:"exec_time"` RequestUrl string `json:"request_url"` IntervalPattern string `json:"interval_pattern"` ExecCommand string `json:"exec_command"` Timeout int64 `json:"timeout"` UseGroupOtp bool `json:"use_group_otp"` Memo string `json:"memo"` }
type EditJobPayload ¶
type GetJobsPayload ¶
type GetJobsPayload struct {
GroupName string `json:"group_name"`
}
type JobControlPayload ¶
type RegisterGroupPayload ¶
type RegisterGroupPayload struct {
GroupName string `json:"group_name"`
}
type ResponseJobList ¶
type ResponseJobList struct { Name string `json:"name"` Id string `json:"id"` Exectime int64 `json:"exec_time"` OtpToken string `json:"otp_token"` IntervalPattern string `json:"interval_pattern"` RequestUrl string `json:"request_url"` ExecCmd string `json:"exec_cmd"` GroupName string `json:"group_name"` Active bool `json:"active"` Memo string `json:"memo"` }
Click to show internal directories.
Click to hide internal directories.