transformer

Documentation

Index

• Constants
• type ActionStep
  • func NewActionStep(config StepConfig) (*ActionStep, error)
• type Actions
  • func NewActions(config []StepConfig) (*Actions, error)
  • func (a *Actions) Exec(e api.Event) error
• type ConditionActionStep
  • func NewConditionActionStep(config condition.Config) (*ConditionActionStep, error)
• type Config
  • func (c *Config) Validate() error
• type Interceptor
  • func (i *Interceptor) BelongTo() (componentTypes []string)
  • func (i *Interceptor) Category() api.Category
  • func (i *Interceptor) Config() interface{}
  • func (i *Interceptor) IgnoreRetry() bool
  • func (i *Interceptor) Init(context api.Context) error
  • func (i *Interceptor) Intercept(invoker source.Invoker, invocation source.Invocation) api.Result
  • func (i *Interceptor) Order() int
  • func (i *Interceptor) Start() error
  • func (i *Interceptor) Stop()
  • func (i *Interceptor) String() string
  • func (i *Interceptor) Type() api.Type
• type StepConfig
  • func (c *StepConfig) Validate() error

Constants

const Type = "transformer"

Types

type ActionStep

type ActionStep struct {
	ConditionStep *ConditionActionStep // type conditionAction
	SimpleAction  *action.Instance     // type simpleAction
}

ActionStep abstract all the action including conditionAction and simpleAction

func NewActionStep

func NewActionStep(config StepConfig) (*ActionStep, error)

type Actions

type Actions struct {
	// contains filtered or unexported fields
}

func NewActions

func NewActions(config []StepConfig) (*Actions, error)

func (*Actions) Exec

func (a *Actions) Exec(e api.Event) error

type ConditionActionStep

type ConditionActionStep struct {
	ConditionExpression string
	Conditions          []*condition.Instance
	Connector           string // AND / OR

	Then []*action.Instance
	Else []*action.Instance
}

func NewConditionActionStep

func NewConditionActionStep(config condition.Config) (*ConditionActionStep, error)

type Config

type Config struct {
	interceptor.ExtensionConfig `yaml:",inline"`
	Actions                     []StepConfig `yaml:"actions"`
	IgnoreError                 bool         `yaml:"ignoreError,omitempty"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Interceptor

type Interceptor struct {
	// contains filtered or unexported fields
}

func (*Interceptor) BelongTo

func (i *Interceptor) BelongTo() (componentTypes []string)

func (*Interceptor) Category

func (i *Interceptor) Category() api.Category

func (*Interceptor) Config

func (i *Interceptor) Config() interface{}

func (*Interceptor) IgnoreRetry

func (i *Interceptor) IgnoreRetry() bool

func (*Interceptor) Init

func (i *Interceptor) Init(context api.Context) error

func (*Interceptor) Intercept

func (i *Interceptor) Intercept(invoker source.Invoker, invocation source.Invocation) api.Result

func (*Interceptor) Order

func (i *Interceptor) Order() int

func (*Interceptor) Start

func (i *Interceptor) Start() error

func (*Interceptor) Stop

func (i *Interceptor) Stop()

func (*Interceptor) String

func (i *Interceptor) String() string

func (*Interceptor) Type

func (i *Interceptor) Type() api.Type

type StepConfig

type StepConfig struct {
	ConditionConfig condition.Config `yaml:",inline,omitempty"` // if-then-else
	ActionConfig    action.Config    `yaml:",inline,omitempty"` // only actions
}

func (*StepConfig) Validate

func (c *StepConfig) Validate() error