executor

package

v0.0.0-...-25da3cc Latest Latest Go to latest Published: Jul 8, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/devfeel/rockman

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ValidateTargetType(execType string) bool
type Exec
type Executor
- func NewDebugGoExecutor(taskID string) Executor
- func NewDebugHttpExecutor(taskID string) Executor
- func NewDebugShellExecutor(taskID string) Executor
type GoConfig
- func (c *GoConfig) LoadFromJson(json string) error
type GoExecutor
- func NewGoExecutor(conf *core.TaskConfig) (*GoExecutor, error)
- func (exec *GoExecutor) Exec(ctx *task.TaskContext) error
- func (exec *GoExecutor) GetTargetType() string
- func (exec *GoExecutor) GetTask() task.Task
- func (exec *GoExecutor) GetTaskConfig() *core.TaskConfig
- func (exec *GoExecutor) GetTaskID() string
- func (exec *GoExecutor) SetTask(task task.Task)
type HttpConfig
- func (c *HttpConfig) LoadFromJson(json string) error
type HttpExecutor
- func NewHttpExecutor(conf *core.TaskConfig) (*HttpExecutor, error)
- func (exec *HttpExecutor) Exec(ctx *task.TaskContext) error
- func (exec *HttpExecutor) GetTargetType() string
- func (exec *HttpExecutor) GetTask() task.Task
- func (exec *HttpExecutor) GetTaskConfig() *core.TaskConfig
- func (exec *HttpExecutor) GetTaskID() string
- func (exec *HttpExecutor) SetTask(task task.Task)
type ShellConfig
- func (c *ShellConfig) LoadFromJson(json string) error
type ShellExecutor
- func NewShellExecutor(conf *core.TaskConfig) (*ShellExecutor, error)
- func (exec *ShellExecutor) Exec(ctx *task.TaskContext) error
- func (exec *ShellExecutor) GetTargetType() string
- func (exec *ShellExecutor) GetTask() task.Task
- func (exec *ShellExecutor) GetTaskConfig() *core.TaskConfig
- func (exec *ShellExecutor) GetTaskID() string
- func (exec *ShellExecutor) SetTask(task task.Task)

Constants ¶

View Source

const (
	TargetType_Http  = "http"
	TargetType_Shell = "shell"
	TargetType_GoSo  = "goso"
	TargetType_Code  = "code"

	CorrectStatus = "200 OK"
	CorrectResult = "OK"
)

View Source

const (
	HttpMethod_HEAD = "HEAD"
	HttpMethod_GET  = "GET"
	HttpMethod_POST = "POST"
)

View Source

const (
	ShellType_Script = "SCRIPT"
	ShellType_File   = "FILE"
	ShellFilePath    = "shells/"
)

View Source

const GoFilePath = "plugins/"

Variables ¶

View Source

var (
	ErrorNotSupportShellType       = errors.New("not support shell type")
	ErrorShellFileNotInSpecifyPath = errors.New("shell file not in specify path")
	ErrorNotEnabledShellScriptMode = errors.New("shell script mode is not enabled")
)

View Source

var (
	ErrorGoSoFileNotInSpecifyPath = errors.New("go.so file not in specify path")
)

View Source

var ErrorNotMatchConfigType = errors.New("not match config type")

Functions ¶

func ValidateTargetType ¶

func ValidateTargetType(execType string) bool

ValidateTargetType validate the TargetType is supported

Types ¶

type Exec ¶

type Exec func(ctx *task.TaskContext) error

type Executor ¶

type Executor interface {
	GetTask() task.Task
	SetTask(task.Task)
	GetTaskID() string
	GetTargetType() string
	GetTaskConfig() *core.TaskConfig
	Exec(*task.TaskContext) error
}

func NewDebugGoExecutor ¶

func NewDebugGoExecutor(taskID string) Executor

func NewDebugHttpExecutor ¶

func NewDebugHttpExecutor(taskID string) Executor

func NewDebugShellExecutor ¶

func NewDebugShellExecutor(taskID string) Executor

type GoConfig ¶

type GoConfig struct {
	FileName string
}

func (*GoConfig) LoadFromJson ¶

func (c *GoConfig) LoadFromJson(json string) error

type GoExecutor ¶

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

func NewGoExecutor ¶

func NewGoExecutor(conf *core.TaskConfig) (*GoExecutor, error)

func (*GoExecutor) Exec ¶

func (exec *GoExecutor) Exec(ctx *task.TaskContext) error

func (*GoExecutor) GetTargetType ¶

func (exec *GoExecutor) GetTargetType() string

func (*GoExecutor) GetTask ¶

func (exec *GoExecutor) GetTask() task.Task

func (*GoExecutor) GetTaskConfig ¶

func (exec *GoExecutor) GetTaskConfig() *core.TaskConfig

func (*GoExecutor) GetTaskID ¶

func (exec *GoExecutor) GetTaskID() string

func (*GoExecutor) SetTask ¶

func (exec *GoExecutor) SetTask(task task.Task)

type HttpConfig ¶

type HttpConfig struct {
	Url         string
	Method      string
	ContentType string
	PostBody    string
	Timeout     int //单位为秒
}

func (*HttpConfig) LoadFromJson ¶

func (c *HttpConfig) LoadFromJson(json string) error

type HttpExecutor ¶

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

func NewHttpExecutor ¶

func NewHttpExecutor(conf *core.TaskConfig) (*HttpExecutor, error)

func (*HttpExecutor) Exec ¶

func (exec *HttpExecutor) Exec(ctx *task.TaskContext) error

func (*HttpExecutor) GetTargetType ¶

func (exec *HttpExecutor) GetTargetType() string

func (*HttpExecutor) GetTask ¶

func (exec *HttpExecutor) GetTask() task.Task

func (*HttpExecutor) GetTaskConfig ¶

func (exec *HttpExecutor) GetTaskConfig() *core.TaskConfig

func (*HttpExecutor) GetTaskID ¶

func (exec *HttpExecutor) GetTaskID() string

func (*HttpExecutor) SetTask ¶

func (exec *HttpExecutor) SetTask(task task.Task)

type ShellConfig ¶

type ShellConfig struct {
	Type   string //default will be ShellType_Script
	Script string
}

func (*ShellConfig) LoadFromJson ¶

func (c *ShellConfig) LoadFromJson(json string) error

type ShellExecutor ¶

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

func NewShellExecutor ¶

func NewShellExecutor(conf *core.TaskConfig) (*ShellExecutor, error)

func (*ShellExecutor) Exec ¶

func (exec *ShellExecutor) Exec(ctx *task.TaskContext) error

func (*ShellExecutor) GetTargetType ¶

func (exec *ShellExecutor) GetTargetType() string

func (*ShellExecutor) GetTask ¶

func (exec *ShellExecutor) GetTask() task.Task

func (*ShellExecutor) GetTaskConfig ¶

func (exec *ShellExecutor) GetTaskConfig() *core.TaskConfig

func (*ShellExecutor) GetTaskID ¶

func (exec *ShellExecutor) GetTaskID() string

func (*ShellExecutor) SetTask ¶

func (exec *ShellExecutor) SetTask(task task.Task)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
test
plugin

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