Versions in this module Expand all Collapse all v0 v0.4.1 Jan 17, 2024 Changes in this version + const LOG_INFO + const LOG_QUIET + const LOG_VERBOSE + const TYPE_BOOL + const TYPE_FLOAT + const TYPE_INT + const TYPE_STRING + var ErrEndWorkflow = errors.New("end workflow") + func CreateLoopStack() loopStack + type Action struct + Action string + Config map[string]interface{} + ContinueOnError interface{} + Description string + Disabled interface{} + Fail string + Key string + func CreateAction(opts ...ActionOption) *Action + func (m *Action) GetConfig(key string) interface{} + func (m *Action) GetConfigBool(key string) bool + func (m *Action) GetConfigFloat64(key string) float64 + func (m *Action) GetConfigInt(key string) int + func (m *Action) GetConfigString(key string) string + type ActionFunc func(w *Workflow, m *TemplateData) error + type ActionOption func(*Action) + func OptionActionAction(v string) ActionOption + func OptionActionConfig(v map[string]interface{}) ActionOption + func OptionActionContinueOnError(v interface{}) ActionOption + func OptionActionDescription(v string) ActionOption + func OptionActionDisabled(v bool) ActionOption + func OptionActionFail(v string) ActionOption + func OptionActionKey(v string) ActionOption + type ActionSchema struct + Action ActionFunc + ConfigSchema map[string]*Schema + InlineFormat InlineFormatter + InlineParams bool + Long string + ProcessResults bool + Short string + Target string + type Answer struct + Description string + InputType string + Key string + Title string + Value interface{} + type Answers struct + Answers []Answer + Name string + Version string + func (m *Answers) GetPackageProjectName() string + func (m *Answers) Save(file_name string) error + type DeleteConfigFunc func(key string, custom ...string) error + type EventFunc func(w *Workflow) error + type FunctionSchema struct + Cmd string + Description string + Function any + ParameterSchema map[string]*Schema + Target string + type InlineFormatter func(cfg map[string]interface{}) string + type Job struct + Actions []Action + Description string + Inputs map[string]Parameter + IsSubWorkflow bool + Key string + Title string + func CreateJob(opts ...JobOption) *Job + func (m *Job) ActionExists(key string) bool + func (m *Job) ActionKeyExists(key string) bool + func (m *Job) GetActionByKey(key string) *Action + func (m *Job) GetInput(key string) *Parameter + func (m *Job) GetKeyIndex(key string) int + func (m *Job) SetInputAnswer(key string, value interface{}) error + type JobOption func(*Job) + func OptionJobActions(v []Action) JobOption + func OptionJobDescription(v string) JobOption + func OptionJobKey(v string) JobOption + func OptionJobTitle(v string) JobOption + type Manifest struct + Actions []Action + Data map[string]interface{} + Jobs []Job + Meta MetaData + Parameters []Parameter + func CreateManifest(opts ...ManifestOption) *Manifest + func (m *Manifest) DataModel() *go_data_chain.Data + func (m *Manifest) GetGlobalAction(key string) *Action + func (m *Manifest) GetJob(key string) *Job + func (m *Manifest) GetParameter(key string) *Parameter + func (m *Manifest) GlobalActionKeyExists(key string) bool + func (m *Manifest) ParameterExists(key string) bool + type ManifestOption func(*Manifest) + func OptionManifestData(v map[string]interface{}) ManifestOption + func OptionManifestJobs(v []Job) ManifestOption + func OptionManifestMeta(v MetaData) ManifestOption + func OptionManifestParameters(v []Parameter) ManifestOption + type MetaData struct + Author string + Contact string + CreatedDate string + Description string + Name string + UpdateDate string + Vars map[string]interface{} + Version string + func CreateMetaData(opts ...MetaDataOption) *MetaData + type MetaDataOption func(*MetaData) + func OptionMetaDataAuthor(v string) MetaDataOption + func OptionMetaDataContact(v string) MetaDataOption + func OptionMetaDataCreatedDate(v string) MetaDataOption + func OptionMetaDataDescription(v string) MetaDataOption + func OptionMetaDataName(v string) MetaDataOption + func OptionMetaDataUpdateDate(v string) MetaDataOption + func OptionMetaDataVars(v map[string]interface{}) MetaDataOption + func OptionMetaDataVersion(v string) MetaDataOption + type Parameter struct + Description string + InputType string + Key string + Title string + Value interface{} + func CreateParameter(opts ...ParameterOption) *Parameter + func (m *Parameter) GetValue() interface{} + func (m *Parameter) SetAnswer(answer interface{}) + func (m *Parameter) ValueBool() bool + func (m *Parameter) ValueFloat() float64 + func (m *Parameter) ValueInt() int + func (m *Parameter) ValueString() string + type ParameterOption func(*Parameter) + func OptionParameterDescription(v string) ParameterOption + func OptionParameterKey(v string) ParameterOption + func OptionParameterTitle(v string) ParameterOption + func OptionParameterType(v string) ParameterOption + func OptionParameterValue(v string) ParameterOption + type ReadConfigFunc func(key string, data_type string, custom ...string) (interface{}, error) + type Schema struct + ConfigKey string + Default interface{} + Description string + Partial bool + Required bool + Short string + Type ValueType + Value string + type SchemaEndpoint interface + GetActionSchema func() map[string]ActionSchema + GetFunctionMap func() map[string]FunctionSchema + GetTargetSchema func() map[string]TargetSchema + type TargetMapFunc func(w *Workflow, m interface{}, target interface{}) (interface{}, error) + type TargetSchema struct + Action string + Long string + Short string + Target interface{} + func BuildTargetConfig(short string, long string, target interface{}) TargetSchema + func (m *TargetSchema) GetTargetMap() map[string]interface{} + type TemplateData struct + CurrentAction *Action + Data map[string]interface{} + Manifest *Manifest + Meta *MetaData + func (m *TemplateData) SetAction(current_action *Action) + type ValueOperand int + type ValueType int + const TypeBool + const TypeFloat + const TypeInt + const TypeInvalid + const TypeList + const TypeMap + const TypeObject + const TypeSet + const TypeString + const TypeWorkflow + func (v ValueType) String() string + type Workflow struct + ActionList map[string]ActionFunc + CleanFunc EventFunc + InitFunc EventFunc + LogLevel int64 + Manifest Manifest + ReadConfigFunc map[string]ReadConfigFunc + TargetMapFunc TargetMapFunc + func CreateWorkflow(opts ...WorkflowOption) *Workflow + func (m *Workflow) AddActionSchema(sch SchemaEndpoint) + func (m *Workflow) BuildAnswerFile() (*Answers, error) + func (m *Workflow) BuildPath(file_path string) string + func (m *Workflow) BuildStoreMap(key string, custom ...string) map[string]interface{} + func (m *Workflow) ClearDataBucket(key string) + func (m *Workflow) ClearDataBuckets() + func (m *Workflow) CountArray(v []interface{}) int + func (m *Workflow) CreateJSEngine() *goja.Runtime + func (m *Workflow) CreateSubWorkflowEngine() *Workflow + func (m *Workflow) CreateTemplateData(current_action *Action) *TemplateData + func (m *Workflow) FileTemplate(file string, custom ...interface{}) (string, error) + func (m *Workflow) GenerateToken(password string) (string, error) + func (m *Workflow) GetConfigToken(key string, model *TemplateData) (interface{}, error) + func (m *Workflow) GetConfigTokenBool(key string, model *TemplateData, required bool) (bool, error) + func (m *Workflow) GetConfigTokenFloat(key string, model *TemplateData, required bool) (float64, error) + func (m *Workflow) GetConfigTokenInt(key string, model *TemplateData, required bool) (int, error) + func (m *Workflow) GetConfigTokenInterface(key string, model *TemplateData, required bool) (interface{}, error) + func (m *Workflow) GetConfigTokenInterfaceArray(key string, model *TemplateData, required bool) ([]interface{}, error) + func (m *Workflow) GetConfigTokenMap(key string, model *TemplateData, required bool) (map[string]interface{}, error) + func (m *Workflow) GetConfigTokenMapArray(key string, model *TemplateData, required bool) ([]map[string]interface{}, error) + func (m *Workflow) GetConfigTokenString(key string, model *TemplateData, required bool) (string, error) + func (m *Workflow) GetConfigTokenStringArray(key string, model *TemplateData, required bool) ([]string, error) + func (m *Workflow) GetCurrentActionIndex() int + func (m *Workflow) GetCurrentJob() *Job + func (m *Workflow) GetDataBucket() map[string]map[string]interface{} + func (m *Workflow) GetDataBucketContent(key string) map[string]interface{} + func (m *Workflow) GetDataFromString(path string) (interface{}, error) + func (m *Workflow) GetDataItem(item string) *go_data_chain.Data + func (m *Workflow) GetInbuiltTemplateFuncMap() template.FuncMap + func (m *Workflow) GetInputValue(key string) interface{} + func (m *Workflow) GetParamValue(key string) interface{} + func (m *Workflow) GetRuntimeVar(key string) (interface{}, error) + func (m *Workflow) GetStackVariable(variable_name string) int + func (m *Workflow) GetTemplateFuncMap() template.FuncMap + func (m *Workflow) GetTokenBool(value interface{}, model *TemplateData) (bool, error) + func (m *Workflow) GetTokenFloat64(value interface{}, model *TemplateData) (float64, error) + func (m *Workflow) GetTokenInt(value interface{}, model *TemplateData) (int, error) + func (m *Workflow) GetTokenString(value interface{}, model *TemplateData) (string, error) + func (m *Workflow) GetValueFromDataBucket(key string, name string) interface{} + func (m *Workflow) GetValueFromDataBucketAsBool(key string, name string) bool + func (m *Workflow) GetValueFromDataBucketAsFloat(key string, name string) float64 + func (m *Workflow) GetValueFromDataBucketAsInt(key string, name string) int + func (m *Workflow) GetValueFromDataBucketAsStrings(key string, name string) string + func (m *Workflow) GetWorkflow() *Workflow + func (m *Workflow) KeyPair(key string, value interface{}) string + func (m *Workflow) KeyPairMap(custom ...string) map[string]interface{} + func (m *Workflow) LoadAnswerFile(answer_file string) error + func (m *Workflow) LoadManifest(package_path string) error + func (m *Workflow) LoadManifestFromString(manifest_string string) error + func (m *Workflow) ManifestAddActionToJob(job_key string, action_obj *Action) error + func (m *Workflow) ManifestAddGlobalAction(action_obj *Action) error + func (m *Workflow) ManifestAddJob(job *Job) error + func (m *Workflow) ManifestCreateMeta(meta *MetaData) + func (m *Workflow) ManifestCreateParameter(param *Parameter) error + func (m *Workflow) ManifestDeleteActionFromJob(job_key string, action_key string) error + func (m *Workflow) ManifestDeleteJob(job_key string) error + func (m *Workflow) ManifestDeleteParameter(param_key string) error + func (m *Workflow) ManifestGetJob(job_key string) *Job + func (m *Workflow) ManifestUpdateMeta(meta *MetaData) + func (m *Workflow) MapValuesToInput(map_data map[string]interface{}) error + func (m *Workflow) ParseInterfaceMap(model *TemplateData, val map[string]interface{}) map[string]interface{} + func (m *Workflow) ParseToken(data *TemplateData, value string) (string, error) + func (m *Workflow) RunAction(current_action *Action) error + func (m *Workflow) RunJob(key string, run_time_vars map[string]interface{}, ...) error + func (m *Workflow) RunSubWorkflow(key string, inputs map[string]interface{}) error + func (m *Workflow) SaveManifest(file_name string) error + func (m *Workflow) SetAnswers(answers map[string]interface{}) + func (m *Workflow) SetBasePath(base_path string) + func (m *Workflow) SetCurrentActionIndex(index int) error + func (m *Workflow) SetTemplateFuncMap(f template.FuncMap) + func (m *Workflow) SetValueToDataBucket(key string, name string, value interface{}) + func (m *Workflow) Template(val string, custom ...interface{}) (string, error) + func (m *Workflow) TemplateMap(val string, custom map[string]interface{}) (string, error) + func (m *Workflow) UpdateWorkflow(opts ...WorkflowOption) *Workflow + func (w *Workflow) ActionProcessResults(m *TemplateData, data interface{}) error + func (w *Workflow) GetConfigValue(config_target string, key string, data_type string, custom ...string) (interface{}, error) + func (w *Workflow) MapTargetConfigValue(m interface{}, target interface{}) (interface{}, error) + type WorkflowOption func(*Workflow) + func OptionWorkflowLogLevel(v int64) WorkflowOption + func OptionWorkflowManifest(v Manifest) WorkflowOption + type WriteConfigFunc func(key string, value interface{}, custom ...string) error