Versions in this module Expand all Collapse all v1 v1.0.1 Jan 18, 2024 v1.0.0 Jan 10, 2024 Changes in this version + func InitTrigger(factory trigger.Factory, tConfig *trigger.Config, ...) (trigger.Trigger, error) + func NewActivityInitContext(settings interface{}, f mapper.Factory) activity.InitContext + func NewActivityInitContextWithName(settings interface{}, f mapper.Factory, name string) activity.InitContext + func NewCounterActivity() activity.Activity + func NewDummyAction(f func()) action.Action + func NewLogActivity() activity.Activity + type ActionInitCtx struct + func NewActionInitCtx() *ActionInitCtx + func (ctx *ActionInitCtx) AddResource(resourceType string, config *resource.Config) error + func (ctx *ActionInitCtx) ResourceManager() *resource.Manager + func (ctx *ActionInitCtx) RuntimeSettings() map[string]interface{} + func (ctx *ActionInitCtx) ServiceManager() *service.Manager + type TestActivityContext struct + TaskNameVal string + func NewActivityContext(md *activity.Metadata) *TestActivityContext + func NewActivityContextWithAction(md *activity.Metadata, activityHost *TestActivityHost) *TestActivityContext + func (c *TestActivityContext) ActivityHost() activity.Host + func (c *TestActivityContext) GetInput(name string) interface{} + func (c *TestActivityContext) GetInputObject(input data.StructValue) error + func (c *TestActivityContext) GetOutput(name string) interface{} + func (c *TestActivityContext) GetOutputObject(output data.StructValue) error + func (c *TestActivityContext) GetSetting(setting string) (value interface{}, exists bool) + func (c *TestActivityContext) GetSharedTempData() map[string]interface{} + func (c *TestActivityContext) GetTracingContext() trace.TracingContext + func (c *TestActivityContext) Logger() log.Logger + func (c *TestActivityContext) Name() string + func (c *TestActivityContext) SetInput(name string, val interface{}) + func (c *TestActivityContext) SetInputObject(input data.StructValue) error + func (c *TestActivityContext) SetOutput(name string, value interface{}) error + func (c *TestActivityContext) SetOutputObject(output data.StructValue) error + type TestActivityHost struct + HostData data.Scope + HostId string + HostRef string + IoMetadata *metadata.IOMetadata + ReplyData map[string]interface{} + ReplyErr error + func (ac *TestActivityHost) ID() string + func (ac *TestActivityHost) IOMetadata() *metadata.IOMetadata + func (ac *TestActivityHost) Name() string + func (ac *TestActivityHost) Reply(replyData map[string]interface{}, err error) + func (ac *TestActivityHost) Return(returnData map[string]interface{}, err error) + func (ac *TestActivityHost) Scope() data.Scope + type TestActivityInitContext struct + func (ic *TestActivityInitContext) HostName() string + func (ic *TestActivityInitContext) Logger() log.Logger + func (ic *TestActivityInitContext) MapperFactory() mapper.Factory + func (ic *TestActivityInitContext) Name() string + func (ic *TestActivityInitContext) Settings() map[string]interface{} + type TestCounterActivity struct + func (a *TestCounterActivity) Eval(ctx activity.Context) (done bool, err error) + func (a *TestCounterActivity) Metadata() *activity.Metadata + type TestLogActivity struct + func (a *TestLogActivity) Eval(ctx activity.Context) (done bool, err error) + func (a *TestLogActivity) Metadata() *activity.Metadata