actions

Documentation

Index

• Constants
• func ParseDuration(durationStr string) (time.Duration, error)
• func VerifyHost(host string, remote net.Addr, key ssh.PublicKey) error
• type HTTP
  • func (h *HTTP) Name() string
  • func (h *HTTP) ParameterNew() interface{}
  • func (h *HTTP) Run(ctx run.ExecuteContext, params interface{}) (err error)
• type HTTPParams
• type SSH
  • func (s *SSH) Name() string
  • func (s *SSH) ParameterNew() interface{}
  • func (s *SSH) Run(ctx run.ExecuteContext, params interface{}) (err error)
• type SSHParams
• type Waiting
  • func (s *Waiting) Name() string
  • func (s *Waiting) ParameterNew() interface{}
  • func (s *Waiting) Run(ctx run.ExecuteContext, params interface{}) error
• type WaitingParams

Constants

const (
	ActionKeySSH = "ssh"

	// SSHKeyDir env variable to customize SSH key directory
	SSHKeyDir = "FASTFLOW_SSH_KEY_DIR"
)

const (
	ActionHTTP = "http"
)

const (
	ActionKeyWait = "ff-waiting"
)

Functions

func ParseDuration

func ParseDuration(durationStr string) (time.Duration, error)

ParseDuration

func VerifyHost

func VerifyHost(host string, remote net.Addr, key ssh.PublicKey) error

Types

type HTTP

type HTTP struct {
}

func (*HTTP) Name

func (h *HTTP) Name() string

Name Action name

func (*HTTP) ParameterNew

func (h *HTTP) ParameterNew() interface{}

ParameterNew

func (*HTTP) Run

func (h *HTTP) Run(ctx run.ExecuteContext, params interface{}) (err error)

Run

type HTTPParams

type HTTPParams struct {
	Method    string            `yaml:"method" json:"method"`
	URL       string            `yaml:"url" json:"url"`
	RawBody   string            `yaml:"rawBody" json:"rawBody"`
	Header    map[string]string `yaml:"header" json:"header"`
	BasicAuth map[string]string `yaml:"basicauth" json:"basicauth"`
	AuthToken string            `yaml:"authtoken" json:"authtoken"`
}

type SSH

type SSH struct {
}

func (*SSH) Name

func (s *SSH) Name() string

func (*SSH) ParameterNew

func (s *SSH) ParameterNew() interface{}

ParameterNew

func (*SSH) Run

func (s *SSH) Run(ctx run.ExecuteContext, params interface{}) (err error)

Run

type SSHParams

type SSHParams struct {
	User    string `json:"user"`
	Ip      string `json:"ip"`
	Port    uint   `json:"port"`
	Key     string `json:"key"`
	Cmd     string `json:"cmd"`
	Timeout int    `json:"timeout"`
}

type Waiting

type Waiting struct {
}

Waiting action

func (*Waiting) Name

func (s *Waiting) Name() string

Name

func (*Waiting) ParameterNew

func (s *Waiting) ParameterNew() interface{}

ParameterNew

func (*Waiting) Run

func (s *Waiting) Run(ctx run.ExecuteContext, params interface{}) error

Run

type WaitingParams

type WaitingParams struct {
	// Support "d|h|m|s|ms" such as 1h mean 1hours
	WaitingTime string `json:"waitingTime"`
}

WaitingParams