Documentation
¶
Index ¶
- func Get(e *Executor, name string, args []interface{}) (step.Function, error)
- type AppConsulArgs
- type AppRedisArgs
- type CmdArgs
- type ConfigAppConsulArgs
- type DialArgs
- type Executor
- func (e *Executor) AppConsul(args *AppConsulArgs) (step.Function, error)
- func (e *Executor) AppRedis(args *AppRedisArgs) (step.Function, error)
- func (e *Executor) Close() error
- func (e *Executor) Cmd(args *CmdArgs) (step.Function, error)
- func (e *Executor) Dial(args *DialArgs) (step.Function, error)
- func (e *Executor) Http(args *HttpArgs) (step.Function, error)
- func (e *Executor) Repeat(args *RepeatArgs, cmd *config.Step) (step.Function, error)
- func (e *Executor) Simple(args *SimpleArgs) (step.Function, error)
- func (e *Executor) Sql(args *SqlArgs) (step.Function, error)
- type HttpArgs
- type HttpAuthConfigAppConsulArgs
- type RepeatArgs
- type SimpleArgs
- type SqlArgs
- type TLSConfigConfigAppConsulArgs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AppConsulArgs ¶
type AppConsulArgs struct {
// region Request
Config *ConfigAppConsulArgs `json:"config"`
// endregion
// region Require
Require AppConsulArgsRequire `json:"require"`
}
func (*AppConsulArgs) Validate ¶
func (a *AppConsulArgs) Validate() (err error)
type AppRedisArgs ¶
type AppRedisArgs struct {
URL string `json:"url"`
Password string `json:"password"`
Cmd string `json:"cmd"`
Args []interface{} `json:"args"`
Require *AppRedisArgsRequire `json:"require"`
}
func (*AppRedisArgs) Validate ¶
func (a *AppRedisArgs) Validate() (err error)
type CmdArgs ¶
type ConfigAppConsulArgs ¶
type ConfigAppConsulArgs struct {
Address string `json:"address"`
Scheme string `json:"scheme"`
Datacenter string `json:"datacenter"`
HttpAuth *HttpAuthConfigAppConsulArgs `json:"http_auth"`
WaitTime time.Duration `json:"wait_time"`
Token string `json:"token"`
TokenFile string `json:"token_file"`
Namespace string `json:"namespace"`
TLSConfig TLSConfigConfigAppConsulArgs `json:"tls_config"`
}
type DialArgs ¶
type DialArgs struct {
// region Request
Type String `json:"type"`
Address String `json:"address"`
Input *ReachText `json:"input"`
Until string `json:"until"`
Timeout Duration `json:"timeout"`
// endregion
// region Require
Require *DialArgsRequire `json:"require"`
}
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func (*Executor) AppConsul ¶
func (e *Executor) AppConsul(args *AppConsulArgs) (step.Function, error)
type HttpArgs ¶
type HttpArgs struct {
// region Request
Method string `json:"method"`
Url string `json:"url"`
Payload *ReachText `json:"payload"`
Form HttpArgsForm `json:"form"`
Headers map[string]string `json:"headers"`
Timeout Duration `json:"timeout"`
Redirect bool `json:"redirect"`
BasicAuth *HttpArgsBasicAuth `json:"basic_auth"`
// endregion
// region Response
Require HttArgsRequire `json:"require"`
}
type RepeatArgs ¶
type RepeatArgs struct {
Count int `json:"count"`
Delay Duration `json:"delay"`
Require RepeatArgsRequire `json:"require"`
}
func (*RepeatArgs) Validate ¶
func (a *RepeatArgs) Validate() (err error)
type SimpleArgs ¶
type SimpleArgs struct {
Sleep Duration `json:"sleep"`
Status step.Status `json:"status"`
Message string `json:"message"`
}
func (*SimpleArgs) Validate ¶
func (a *SimpleArgs) Validate() (err error)
Validate is a wrapper to Validate all internal attributes
type SqlArgs ¶
type TLSConfigConfigAppConsulArgs ¶
type TLSConfigConfigAppConsulArgs struct {
Address string `json:"address"`
CAFile string `json:"ca_file"`
CAPath string `json:"ca_path"`
CAPem []byte `json:"ca_pem"`
CertFile string `json:"cert_file"`
CertPEM []byte `json:"cert_pem"`
KeyFile string `json:"key_file"`
KeyPEM []byte `json:"key_pem"`
InsecureSkipVerify bool `json:"insecure_skip_verify"`
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.