test

Documentation

Index

• func NewCounterActivity() activity.Activity
• func NewLogActivity() activity.Activity
• func NewTestModel() *model.FlowModel
• type CounterActivity
  • func (a *CounterActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *CounterActivity) Metadata() *activity.Metadata
• type LogActivity
  • func (a *LogActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *LogActivity) Metadata() *activity.Metadata
• type TestActivityContext
  • func NewTestActivityContext(metadata *activity.Metadata) *TestActivityContext
  • func NewTestActivityContextWithAction(metadata *activity.Metadata, activityHost *TestActivityHost) *TestActivityContext
  • func (c *TestActivityContext) ActivityHost() activity.Host
  • func (c *TestActivityContext) FlowDetails() activity.FlowDetails
  • func (c *TestActivityContext) GetAttrType(attrName string) (attrType data.Type, exists bool)
  • func (c *TestActivityContext) GetAttrValue(attrName string) (value string, exists bool)
  • func (c *TestActivityContext) GetInitValue(key string) (value interface{}, exists bool)
  • func (c *TestActivityContext) GetInput(name string) interface{}
  • func (c *TestActivityContext) GetOutput(name string) interface{}
  • func (c *TestActivityContext) GetSetting(setting string) (value interface{}, exists bool)
  • func (c *TestActivityContext) GetSharedTempData() map[string]interface{}
  • func (c *TestActivityContext) Name() string
  • func (c *TestActivityContext) SetAttrValue(attrName string, value string)
  • func (c *TestActivityContext) SetInput(name string, value interface{})
  • func (c *TestActivityContext) SetOutput(name string, value interface{})
  • func (c *TestActivityContext) SetSetting(name string, value interface{})
  • func (c *TestActivityContext) TaskName() string
• type TestActivityHost
  • func (ac *TestActivityHost) GetResolver() data.Resolver
  • func (ac *TestActivityHost) ID() string
  • func (ac *TestActivityHost) IOMetadata() *data.IOMetadata
  • func (ac *TestActivityHost) Name() string
  • func (ac *TestActivityHost) Ref() string
  • func (ac *TestActivityHost) Reply(data map[string]*data.Attribute, err error)
  • func (ac *TestActivityHost) Return(data map[string]*data.Attribute, err error)
  • func (ac *TestActivityHost) WorkingData() data.Scope
• type TestFlowDetails
  • func (fd *TestFlowDetails) ID() string
  • func (fd *TestFlowDetails) Name() string
  • func (fd *TestFlowDetails) ReplyHandler() activity.ReplyHandler

Functions

func NewCounterActivity

func NewCounterActivity() activity.Activity

NewActivity creates a new AppActivity

func NewLogActivity

func NewLogActivity() activity.Activity

NewActivity creates a new AppActivity

func NewTestModel

func NewTestModel() *model.FlowModel

Types

type CounterActivity

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

func (*CounterActivity) Eval

func (a *CounterActivity) Eval(context activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Logs the Message

func (*CounterActivity) Metadata

func (a *CounterActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata

type LogActivity

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

func (*LogActivity) Eval

func (a *LogActivity) Eval(context activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Logs the Message

func (*LogActivity) Metadata

func (a *LogActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata

type TestActivityContext

type TestActivityContext struct {
	TaskNameVal string
	Attrs       map[string]*data.Attribute
	// contains filtered or unexported fields
}

TestActivityContext is a dummy ActivityContext to assist in testing

func NewTestActivityContext

func NewTestActivityContext(metadata *activity.Metadata) *TestActivityContext

todo needs to move to lib NewTestActivityContext creates a new TestActivityContext

func NewTestActivityContextWithAction

func NewTestActivityContextWithAction(metadata *activity.Metadata, activityHost *TestActivityHost) *TestActivityContext

NewTestActivityContextWithAction creates a new TestActivityContext

func (*TestActivityContext) ActivityHost

func (c *TestActivityContext) ActivityHost() activity.Host

func (*TestActivityContext) FlowDetails

func (c *TestActivityContext) FlowDetails() activity.FlowDetails

func (*TestActivityContext) GetAttrType

func (c *TestActivityContext) GetAttrType(attrName string) (attrType data.Type, exists bool)

GetAttrType implements data.Scope.GetAttrType

func (*TestActivityContext) GetAttrValue

func (c *TestActivityContext) GetAttrValue(attrName string) (value string, exists bool)

GetAttrValue implements data.Scope.GetAttrValue

func (*TestActivityContext) GetInitValue

func (c *TestActivityContext) GetInitValue(key string) (value interface{}, exists bool)

GetInitValue implements activity.Context.GetInitValue

func (*TestActivityContext) GetInput

func (c *TestActivityContext) GetInput(name string) interface{}

GetInput implements activity.Context.GetInput

func (*TestActivityContext) GetOutput

func (c *TestActivityContext) GetOutput(name string) interface{}

GetOutput implements activity.Context.GetOutput

func (*TestActivityContext) GetSetting

func (c *TestActivityContext) GetSetting(setting string) (value interface{}, exists bool)

GetSetting implements activity.Context.GetSetting

func (*TestActivityContext) GetSharedTempData

func (c *TestActivityContext) GetSharedTempData() map[string]interface{}

func (*TestActivityContext) Name

func (c *TestActivityContext) Name() string

func (*TestActivityContext) SetAttrValue

func (c *TestActivityContext) SetAttrValue(attrName string, value string)

SetAttrValue implements data.Scope.SetAttrValue

func (*TestActivityContext) SetInput

func (c *TestActivityContext) SetInput(name string, value interface{})

SetInput implements activity.Context.SetInput

func (*TestActivityContext) SetOutput

func (c *TestActivityContext) SetOutput(name string, value interface{})

SetOutput implements activity.Context.SetOutput

func (*TestActivityContext) SetSetting

func (c *TestActivityContext) SetSetting(name string, value interface{})

SetInput implements activity.Context.SetInput

func (*TestActivityContext) TaskName

func (c *TestActivityContext) TaskName() string

TaskName implements activity.Context.TaskName

type TestActivityHost

type TestActivityHost struct {
	HostId  string
	HostRef string

	IoMetadata    *data.IOMetadata
	HostData      data.Scope
	ReplyData     map[string]interface{}
	ReplyDataAttr map[string]*data.Attribute
	ReplyErr      error
}

func (*TestActivityHost) GetResolver

func (ac *TestActivityHost) GetResolver() data.Resolver

func (*TestActivityHost) ID

func (ac *TestActivityHost) ID() string

func (*TestActivityHost) IOMetadata

func (ac *TestActivityHost) IOMetadata() *data.IOMetadata

func (*TestActivityHost) Name

func (ac *TestActivityHost) Name() string

func (*TestActivityHost) Ref

func (ac *TestActivityHost) Ref() string

func (*TestActivityHost) Reply

func (ac *TestActivityHost) Reply(data map[string]*data.Attribute, err error)

func (*TestActivityHost) Return

func (ac *TestActivityHost) Return(data map[string]*data.Attribute, err error)

func (*TestActivityHost) WorkingData

func (ac *TestActivityHost) WorkingData() data.Scope

type TestFlowDetails

type TestFlowDetails struct {
	FlowIDVal   string
	FlowNameVal string
}

TestFlowDetails simple FlowDetails for use in testing

func (*TestFlowDetails) ID

func (fd *TestFlowDetails) ID() string

ID implements activity.FlowDetails.ID

func (*TestFlowDetails) Name

func (fd *TestFlowDetails) Name() string

Name implements activity.FlowDetails.Name

func (*TestFlowDetails) ReplyHandler

func (fd *TestFlowDetails) ReplyHandler() activity.ReplyHandler

ReplyHandler implements activity.FlowDetails.ReplyHandler