Documentation
¶
Index ¶
- type Worker
- func (w *Worker) Close()
- func (w *Worker) CmdRunWithTimeout(cmd *exec.Cmd, timeout time.Duration) (error, bool)
- func (w *Worker) DoRpcTaskRequest(req *task.TaskRequest) (string, error)
- func (w *Worker) DoScriptTaskRequest(req *task.TaskRequest) (string, error)
- func (w *Worker) DoTaskRequest(args []interface{}) (*task.TaskResult, error)
- func (w *Worker) ExecBin(binPath string, args []string, maxRunTime int64) (string, error)
- func (w *Worker) Run() error
- func (w *Worker) SetSuccessTaskCount(reqKey string) error
- func (w *Worker) SetTaskResult(result *task.TaskResult) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) CmdRunWithTimeout ¶
func (*Worker) DoRpcTaskRequest ¶
func (w *Worker) DoRpcTaskRequest(req *task.TaskRequest) (string, error)
func (*Worker) DoScriptTaskRequest ¶
func (w *Worker) DoScriptTaskRequest(req *task.TaskRequest) (string, error)
func (*Worker) DoTaskRequest ¶
func (w *Worker) DoTaskRequest(args []interface{}) (*task.TaskResult, error)
func (*Worker) SetSuccessTaskCount ¶
func (*Worker) SetTaskResult ¶
func (w *Worker) SetTaskResult(result *task.TaskResult) error
Source Files
Click to show internal directories.
Click to hide internal directories.