handler

Documentation

Index

• func GetHandler(c config.HandlerConfig, idPrefix string) (definitions.Handler, error)
• type MergePNGsHandler
  • func NewMergePNGsHandler(idPrefix string, c map[string]interface{}) (*MergePNGsHandler, error)
  • func (h *MergePNGsHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)
  • func (h *MergePNGsHandler) Name() string
• type ReadFileHandler
  • func NewReadFileHandler(idPrefix string, c map[string]interface{}) (*ReadFileHandler, error)
  • func (h *ReadFileHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)
  • func (h *ReadFileHandler) Name() string
• type ReadFileHandlerConfig
• type RunExecutableHandler
  • func NewRunExecutableHandler(idPrefix string, c map[string]interface{}) (*RunExecutableHandler, error)
  • func (h *RunExecutableHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)
  • func (h *RunExecutableHandler) Name() string
• type SendHTTPHandler
  • func NewSendHTTPHandler(idPrefix string, c map[string]interface{}) (*SendHTTPHandler, error)
  • func (h *SendHTTPHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)
  • func (h *SendHTTPHandler) Name() string
• type WriteFileHandler
  • func NewWriteFileHandler(idPrefix string, c map[string]interface{}) (*WriteFileHandler, error)
  • func (h *WriteFileHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)
  • func (h *WriteFileHandler) Name() string

Functions

func GetHandler

func GetHandler(c config.HandlerConfig, idPrefix string) (definitions.Handler, error)

Types

type MergePNGsHandler

type MergePNGsHandler struct {
	definitions.BaseHandler
	// contains filtered or unexported fields
}

func NewMergePNGsHandler

func NewMergePNGsHandler(idPrefix string, c map[string]interface{}) (*MergePNGsHandler, error)

func (*MergePNGsHandler) Handle

func (h *MergePNGsHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)

func (*MergePNGsHandler) Name

func (h *MergePNGsHandler) Name() string

type ReadFileHandler

type ReadFileHandler struct {
	definitions.BaseHandler
	// contains filtered or unexported fields
}

*

• ReadFileHandler is a handler that reads the input file to a specified output file
• Metadata:
• Write:
• `ReadFile.Source` - the path to the input file

func NewReadFileHandler

func NewReadFileHandler(idPrefix string, c map[string]interface{}) (*ReadFileHandler, error)

func (*ReadFileHandler) Handle

func (h *ReadFileHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)

func (*ReadFileHandler) Name

func (h *ReadFileHandler) Name() string

type ReadFileHandlerConfig

type ReadFileHandlerConfig struct {
	Input        string `mapstructure:"input"`
	RemoveSource bool   `mapstructure:"remove_source"`
}

type RunExecutableHandler

type RunExecutableHandler struct {
	definitions.BaseHandler
	// contains filtered or unexported fields
}

*

• RunExecutableHandler is a handler that runs an executable with the given arguments

func NewRunExecutableHandler

func NewRunExecutableHandler(idPrefix string, c map[string]interface{}) (*RunExecutableHandler, error)

func (*RunExecutableHandler) Handle

func (h *RunExecutableHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)

func (*RunExecutableHandler) Name

func (h *RunExecutableHandler) Name() string

type SendHTTPHandler

type SendHTTPHandler struct {
	definitions.BaseHandler
	// contains filtered or unexported fields
}

func NewSendHTTPHandler

func NewSendHTTPHandler(idPrefix string, c map[string]interface{}) (*SendHTTPHandler, error)

func (*SendHTTPHandler) Handle

func (h *SendHTTPHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)

func (*SendHTTPHandler) Name

func (h *SendHTTPHandler) Name() string

type WriteFileHandler

type WriteFileHandler struct {
	definitions.BaseHandler
	// contains filtered or unexported fields
}

*

• WriteFileHandler is a handler that writes the input file to a specified output file
• Metadata:
• Write:
• `WriteFile.OutputPath` - the path to the output file

func NewWriteFileHandler

func NewWriteFileHandler(idPrefix string, c map[string]interface{}) (*WriteFileHandler, error)

func (*WriteFileHandler) Handle

func (h *WriteFileHandler) Handle(info *definitions.EngineFlowObject, fileHandler definitions.EngineFileHandler) (*definitions.EngineFlowObject, error)

func (*WriteFileHandler) Name

func (h *WriteFileHandler) Name() string