Versions in this module Expand all Collapse all v1 v1.0.1 Sep 21, 2023 Changes in this version + func Activities() map[string]Activity + func CleanupSingletons() + func GetLogger(ref string) log.Logger + func GetRef(activity Activity) string + func HasLegacyActivities() bool + func IsLegacyActivity(ref string) bool + func IsSingleton(activity Activity) bool + func LegacyRegister(ref string, activity Activity) error + func Register(activity Activity, f ...Factory) error + type Activity interface + Eval func(ctx Context) (done bool, err error) + Metadata func() *Metadata + func Get(ref string) Activity + type AsyncActivity interface + PostEval func(context Context, userData interface{}) (done bool, err error) + type Config struct + Input map[string]interface{} + Output map[string]interface{} + Ref string + Schemas *SchemaConfig + Settings map[string]interface{} + Type string + type Context interface + ActivityHost func() Host + GetInput func(name string) interface{} + GetInputObject func(input data.StructValue) error + GetSharedTempData func() map[string]interface{} + GetTracingContext func() trace.TracingContext + Logger func() log.Logger + Name func() string + SetOutput func(name string, value interface{}) error + SetOutputObject func(output data.StructValue) error + type Details struct + IsReply bool + IsReturn bool + type Error struct + func NewError(errorText string, code string, errorData interface{}) *Error + func NewRetriableError(errorText string, code string, errorData interface{}) *Error + func (e *Error) ActivityName() string + func (e *Error) Code() string + func (e *Error) Data() interface{} + func (e *Error) Error() string + func (e *Error) Retriable() bool + func (e *Error) SetActivityName(name string) + type Factory func(ctx InitContext) (Activity, error) + func GetFactory(ref string) Factory + type HasDetails interface + Details func() *Details + type Host interface + ID func() string + IOMetadata func() *metadata.IOMetadata + Name func() string + Reply func(replyData map[string]interface{}, err error) + Return func(returnData map[string]interface{}, err error) + Scope func() data.Scope + type InitContext interface + HostName func() string + Logger func() log.Logger + MapperFactory func() mapper.Factory + Name func() string + Settings func() map[string]interface{} + type LegacyCtx interface + GetOutput func(name string) interface{} + GetSetting func(name string) (value interface{}, exists bool) + type Metadata struct + Settings map[string]data.TypedValue + func ToMetadata(mdStructs ...interface{}) *Metadata + func (md *Metadata) UnmarshalJSON(b []byte) error + type ReconfigurableActivity interface + Reconfigure func(settings map[string]interface{}) error + type SchemaConfig struct + Input map[string]interface{} + Output map[string]interface{}
Go to main page