step

Documentation

Overview

package step holds all possible steps to create pipelines

Index

• type HttpStep
  • func NewHTTP(defaultTimeout time.Duration, defaultMethod string) HttpStep
  • func UnmarshalHttpStep(reader io.Reader) (HttpStep, error)
  • func (h HttpStep) Invoke(reader io.Reader, writer io.Writer) error
• type HttpStepInput
• type HttpStepOutput
• type JsonStep
  • func NewJSON(tmpl string) (step JsonStep, err error)
  • func UnmarshalJsonStep(reader io.Reader) (JsonStep, error)
  • func (j JsonStep) Invoke(reader io.Reader, writer io.Writer) error
• type NoOpStep
  • func (n NoOpStep) Invoke(reader io.Reader, writer io.Writer) error

Types

type HttpStep

type HttpStep struct {
	DefaultTimeout time.Duration `json:"default_timeout"`
	DefaultMethod  string        `json:"default_method"`
}

func NewHTTP

func NewHTTP(defaultTimeout time.Duration, defaultMethod string) HttpStep

func UnmarshalHttpStep

func UnmarshalHttpStep(reader io.Reader) (HttpStep, error)

func (HttpStep) Invoke

func (h HttpStep) Invoke(reader io.Reader, writer io.Writer) error

type HttpStepInput

type HttpStepInput struct {
	Timeout time.Duration          `json:"timeout"`
	Method  string                 `json:"method"`
	URL     string                 `json:"url"`
	Body    map[string]interface{} `json:"body"`
	Header  http.Header            `json:"header"`
}

type HttpStepOutput

type HttpStepOutput struct {
	StatusCode int                    `json:"status_code"`
	Header     http.Header            `json:"header"`
	Body       map[string]interface{} `json:"body"`
}

type JsonStep

type JsonStep struct {
	Template string `json:"template"`
	// contains filtered or unexported fields
}

func NewJSON

func NewJSON(tmpl string) (step JsonStep, err error)

func UnmarshalJsonStep

func UnmarshalJsonStep(reader io.Reader) (JsonStep, error)

func (JsonStep) Invoke

func (j JsonStep) Invoke(reader io.Reader, writer io.Writer) error

type NoOpStep

type NoOpStep struct{}

NoOpStep is a step that does nothing but copy from the reader to the writer. It's good e.g. for testing purposes where you simply want to check the functionality of the pipeline itself.

func (NoOpStep) Invoke

func (n NoOpStep) Invoke(reader io.Reader, writer io.Writer) error