primitive

Documentation

Index

• Constants
• type Container
  • func (e *Container) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Container) ValidateInput(ctx context.Context, i modconfig.Input) error
• type Echo
  • func (e *Echo) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Echo) ValidateInput(ctx context.Context, i modconfig.Input) error
• type Email
  • func (h *Email) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (h *Email) ValidateInput(ctx context.Context, i modconfig.Input) error
• type Exec
  • func (e *Exec) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Exec) ValidateInput(ctx context.Context, i modconfig.Input) error
• type Function
  • func (e *Function) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Function) ValidateInput(ctx context.Context, i modconfig.Input) error
• type HTTPInput
• type HTTPRequest
  • func (h *HTTPRequest) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (h *HTTPRequest) ValidateInput(ctx context.Context, i modconfig.Input) error
• type Primitive
• type Query
  • func (e *Query) InitializeDB(ctx context.Context, i modconfig.Input) (*sql.DB, error)
  • func (e *Query) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Query) ValidateInput(ctx context.Context, i modconfig.Input) error
• type RunPipeline
  • func (e *RunPipeline) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *RunPipeline) ValidateInput(ctx context.Context, input modconfig.Input) error
• type Sleep
  • func (e *Sleep) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)
  • func (e *Sleep) ValidateInput(ctx context.Context, input modconfig.Input) error

Constants

const (
	// HTTPRequestDefaultTimeoutMs is the default timeout for HTTP requests
	// For now the value is hardcoded to 3000 milliseconds
	// TODO: Make this configurable
	HTTPRequestDefaultTimeoutMs = 3000
)

Types

type Container

type Container struct{}

func (*Container) Run

func (e *Container) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Container) ValidateInput

func (e *Container) ValidateInput(ctx context.Context, i modconfig.Input) error

type Echo

type Echo struct{}

func (*Echo) Run

func (e *Echo) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Echo) ValidateInput

func (e *Echo) ValidateInput(ctx context.Context, i modconfig.Input) error

type Email

type Email struct {
	Input modconfig.Input
}

func (*Email) Run

func (h *Email) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Email) ValidateInput

func (h *Email) ValidateInput(ctx context.Context, i modconfig.Input) error

type Exec

type Exec struct{}

func (*Exec) Run

func (e *Exec) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Exec) ValidateInput

func (e *Exec) ValidateInput(ctx context.Context, i modconfig.Input) error

type Function

type Function struct{}

func (*Function) Run

func (e *Function) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Function) ValidateInput

func (e *Function) ValidateInput(ctx context.Context, i modconfig.Input) error

type HTTPInput

type HTTPInput struct {
	URL              string
	Method           string
	RequestBody      string
	RequestHeaders   map[string]interface{}
	RequestTimeoutMs int
	CaCertPem        string
	Insecure         bool
}

type HTTPRequest

type HTTPRequest struct {
	Input modconfig.Input
}

func (*HTTPRequest) Run

func (h *HTTPRequest) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*HTTPRequest) ValidateInput

func (h *HTTPRequest) ValidateInput(ctx context.Context, i modconfig.Input) error

type Primitive

type Primitive interface {
	Run(modconfig.Input) (*modconfig.Output, error)
}

type Query

type Query struct {
	Setting string
	Mock    *sqlmock.Sqlmock
	DB      *sql.DB
}

func (*Query) InitializeDB

func (e *Query) InitializeDB(ctx context.Context, i modconfig.Input) (*sql.DB, error)

func (*Query) Run

func (e *Query) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Query) ValidateInput

func (e *Query) ValidateInput(ctx context.Context, i modconfig.Input) error

type RunPipeline

type RunPipeline struct{}

func (*RunPipeline) Run

func (e *RunPipeline) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*RunPipeline) ValidateInput

func (e *RunPipeline) ValidateInput(ctx context.Context, input modconfig.Input) error

type Sleep

type Sleep struct{}

func (*Sleep) Run

func (e *Sleep) Run(ctx context.Context, input modconfig.Input) (*modconfig.Output, error)

func (*Sleep) ValidateInput

func (e *Sleep) ValidateInput(ctx context.Context, input modconfig.Input) error