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.