operation

Documentation

Index

• type FuncErrorHandler
• type GoFlowOperation
  • func (operation *GoFlowOperation) AddFailureHandler(handler FuncErrorHandler)
  • func (operation *GoFlowOperation) Encode() []byte
  • func (operation *GoFlowOperation) Execute(data []byte, _ map[string]interface{}) ([]byte, error)
  • func (operation *GoFlowOperation) GetId() string
  • func (operation *GoFlowOperation) GetOptions() map[string][]string
  • func (operation *GoFlowOperation) GetProperties() map[string][]string
• type Modifier

Types

type FuncErrorHandler

type FuncErrorHandler func(error) error

FuncErrorHandler the error handler for OnFailure() options

type GoFlowOperation

type GoFlowOperation struct {
	Id      string              // ID
	Mod     Modifier            // Modifier
	Options map[string][]string // The option as a input to workload

	FailureHandler FuncErrorHandler // The Failure handler of the operation
}

func (*GoFlowOperation) AddFailureHandler

func (operation *GoFlowOperation) AddFailureHandler(handler FuncErrorHandler)

func (*GoFlowOperation) Encode

func (operation *GoFlowOperation) Encode() []byte

func (*GoFlowOperation) Execute

func (operation *GoFlowOperation) Execute(data []byte, _ map[string]interface{}) ([]byte, error)

func (*GoFlowOperation) GetId

func (operation *GoFlowOperation) GetId() string

func (*GoFlowOperation) GetOptions

func (operation *GoFlowOperation) GetOptions() map[string][]string

func (*GoFlowOperation) GetProperties

func (operation *GoFlowOperation) GetProperties() map[string][]string

type Modifier

type Modifier func([]byte, map[string][]string) ([]byte, error)

Modifier definition for Modify() call