ruleaction

Documentation

Index

• Constants
• type ActionData
• type ActionDataOld
• type ActionFactory
  • func (f *ActionFactory) Init() error
  • func (f *ActionFactory) New(cfg *action.Config) (action.Action, error)
• type ActionFactoryOld
  • func (ff *ActionFactoryOld) Init() error
  • func (ff *ActionFactoryOld) New(config *action.Config) (action.Action, error)
• type RuleAction
  • func (a *RuleAction) IOMetadata() *data.IOMetadata
  • func (a *RuleAction) Metadata() *action.Metadata
  • func (a *RuleAction) Run(ctx context.Context, inputs map[string]*data.Attribute) (map[string]*data.Attribute, error)
• type RuleActionOld
  • func (a *RuleActionOld) IOMetadata() *data.IOMetadata
  • func (a *RuleActionOld) Metadata() *action.Metadata
  • func (a *RuleActionOld) Run(ctx context.Context, inputs map[string]*data.Attribute) (map[string]*data.Attribute, error)
• type Settings

Constants

const (
	ActionRef = "github.com/project-flogo/rules/ruleaction"
)

Action ref to register the action factory

const (
	ActionRefOld = "github.com/project-flogo/rules/ruleaction_old"
)

Action ref to register the action factory

Types

type ActionData

type ActionData struct {
	Tds json.RawMessage `json:"tds"`
}

ActionData maintains Tuple descriptor details

type ActionDataOld

type ActionDataOld struct {
	Tds []model.TupleDescriptor
}

ActionDataOld maintains Tuple descriptor details

type ActionFactory

type ActionFactory struct {
}

ActionFactory wrapper to register with the action

func (*ActionFactory) Init

func (f *ActionFactory) Init() error

Init implements action.Factory.Init

func (*ActionFactory) New

func (f *ActionFactory) New(cfg *action.Config) (action.Action, error)

New implements action.Factory.New

type ActionFactoryOld

type ActionFactoryOld struct {
}

ActionFactoryOld wrapper to register with the action

func (*ActionFactoryOld) Init

func (ff *ActionFactoryOld) Init() error

Init implements action.Factory.Init

func (*ActionFactoryOld) New

func (ff *ActionFactoryOld) New(config *action.Config) (action.Action, error)

New implements action.Factory.New

type RuleAction

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

RuleAction wraps RuleSession

func (*RuleAction) IOMetadata

func (a *RuleAction) IOMetadata() *data.IOMetadata

IOMetadata get the Action's IO metadata

func (*RuleAction) Metadata

func (a *RuleAction) Metadata() *action.Metadata

Metadata get the Action's metadata

func (*RuleAction) Run

func (a *RuleAction) Run(ctx context.Context, inputs map[string]*data.Attribute) (map[string]*data.Attribute, error)

Run implements action.Action.Run

type RuleActionOld

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

RuleActionOld wraps RuleSession

func (*RuleActionOld) IOMetadata

func (a *RuleActionOld) IOMetadata() *data.IOMetadata

IOMetadata get the Action's IO metadata

func (*RuleActionOld) Metadata

func (a *RuleActionOld) Metadata() *action.Metadata

Metadata get the Action's metadata

func (*RuleActionOld) Run

func (a *RuleActionOld) Run(ctx context.Context, inputs map[string]*data.Attribute) (map[string]*data.Attribute, error)

Run implements action.Action.Run

type Settings

type Settings struct {
	RuleSessionURI string
	TupleDescFile  string
}

Settings to accept RuleSessionURI and Tuple Descriptor file