Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workflow

package

Go to main page

Versions in this module

v1

v1.0.21

Mar 21, 2026

Changes in this version

+ var ErrorInstanceNotFound = fmt.Errorf(MSG_INSTANCE_NOT_FOUND)

+ var FlowStatusList map[Status]bool = map[Status]bool

+ var MSG_INSTANCE_CANCEL = "Instancia cancelada Id:%s"

+ var MSG_INSTANCE_LOSS = "Instancia perdida Id:%s"

+ var MSG_WORKFLOWS_NOT_LOAD = "workFlows not loaded"

+ type CheckList struct

+ Data et.Json

+ Description string

+ Ok bool

+ Tag string

type Flow

+ CheckList []*CheckList

+ func (s *Flow) DefineCheckList(tag string, description string) *Flow

+ func (s *Flow) RemoveCheckList(tag string) *Flow

type Instance

+ ID string

+ Params et.Json

+ Resilence map[string]*resilience.Instance

+ Tag string

+ Traces []et.Json

+ UpdatedBy string

+ func (s *Instance) GetParam(key string) interface{}

+ func (s *Instance) GetTag(key string) interface{}

+ func (s *Instance) GetTraceByStep(step int) []et.Json

+ func (s *Instance) GetTraces(idx int) (et.Json, error)

+ func (s *Instance) PutParam(value et.Json) (et.Json, error)

+ func (s *Instance) PutTag(tags et.Json) error

+ func (s *Instance) Save() error

+ func (s *Instance) Serialize() ([]byte, error)

+ func (s *Instance) SetCheckList(tag string, ok bool, data et.Json) error

+ func (s *Instance) SetCtx(ctx et.Json) error

+ func (s *Instance) SetParam(key string, value interface{}) (et.Json, error)

+ func (s *Instance) SetStatus(status Status) error

+ func (s *Instance) SetTag(key string, value interface{}) error

+ func (s *Instance) ToString() string

+ type Status string

+ const Cancel

+ const Done

+ const Failed

+ const Loss

+ const Pending

+ const Running

+ type WorkFlow struct

+ Flows map[string]*Flow

+ Instances map[string]*Instance

+ Results map[string]et.Json

+ func (s *WorkFlow) Count() int

+ func (s *WorkFlow) DeleteFlow(tag string) (bool, error)

+ func (s *WorkFlow) Get(id string) (*Instance, bool)

+ func (s *WorkFlow) GetInstance(instanceId string) (*Instance, error)

+ func (s *WorkFlow) HttpGet(w http.ResponseWriter, r *http.Request)

+ func (s *WorkFlow) HttpQuery(w http.ResponseWriter, r *http.Request)

+ func (s *WorkFlow) HttpSetParams(w http.ResponseWriter, r *http.Request)

+ func (s *WorkFlow) HttpState(w http.ResponseWriter, r *http.Request)

+ func (s *WorkFlow) New(tag, version, name, description string, fn FnContext, stop bool, ...) *Flow

+ func (s *WorkFlow) Reset(instanceId, updatedBy string) error

+ func (s *WorkFlow) Rollback(instanceId, updatedBy string) (et.Json, error)

+ func (s *WorkFlow) Run(instanceId, tag string, step int, ctx, tags et.Json, createdBy string) (et.Json, error)

+ func (s *WorkFlow) Status(instanceId, status, updatedBy string) (Status, error)

+ func (s *WorkFlow) Stop(instanceId, updatedBy string) error

v0

v0.1.18

Sep 15, 2025

Changes in this version

+ const EVENT_WORKFLOW_AWAITING

+ const EVENT_WORKFLOW_DELETE

+ const EVENT_WORKFLOW_RESULTS

+ const EVENT_WORKFLOW_SET

+ const EVENT_WORKFLOW_STATUS

+ const MSG_FLOW_CREATED

+ const MSG_FLOW_NOT_FOUND

+ const MSG_FLOW_NOT_INSTANCE

+ const MSG_ID_REQUIRED

+ const MSG_INSTANCE_ALREADY_DONE

+ const MSG_INSTANCE_ALREADY_RUNNING

+ const MSG_INSTANCE_CONSISTENCY

+ const MSG_INSTANCE_DEBUG

+ const MSG_INSTANCE_EVALUATE

+ const MSG_INSTANCE_EXISTS

+ const MSG_INSTANCE_EXPRESSION_FALSE

+ const MSG_INSTANCE_EXPRESSION_TRUE

+ const MSG_INSTANCE_FAILED

+ const MSG_INSTANCE_GOTO

+ const MSG_INSTANCE_GOTO_USER_DECISION

+ const MSG_INSTANCE_ID_REQUIRED

+ const MSG_INSTANCE_IFELSE

+ const MSG_INSTANCE_INSTANCE_DEC

+ const MSG_INSTANCE_INSTANCE_INC

+ const MSG_INSTANCE_LOAD

+ const MSG_INSTANCE_NOT_FOUND

+ const MSG_INSTANCE_PENDING

+ const MSG_INSTANCE_RESILIENCE

+ const MSG_INSTANCE_RETENTION

+ const MSG_INSTANCE_ROLLBACK

+ const MSG_INSTANCE_ROLLBACK_CREATED

+ const MSG_INSTANCE_ROLLBACK_FAILED

+ const MSG_INSTANCE_ROLLBACK_STEP

+ const MSG_INSTANCE_RUN

+ const MSG_INSTANCE_STATUS

+ const MSG_INSTANCE_STEP_CREATED

+ const MSG_INSTANCE_WORKFLOWS_IS_NIL

+ const MSG_START_WORKFLOW

+ const MSG_WORKFLOW_DELETE

+ const MSG_WORKFLOW_DONE_INSTANCE

+ const MSG_WORKFLOW_LIMIT_REQUESTS

+ func Continue(instanceId string, tags et.Json, ctx et.Json, createdBy string) (et.Json, error)

+ func DeleteFlow(tag string) (bool, error)

+ func HealthCheck() bool

+ func Load() error

+ func Rollback(instanceId string) (et.Json, error)

+ func Run(instanceId, tag string, startId int, tags et.Json, ctx et.Json, ...) (et.Json, error)

+ func Stop(instanceId string) error

+ type Awaiting struct

+ CreatedAt time.Time

+ ExecutedAt time.Time

+ Id string

+ func (s *Awaiting) ToJson() et.Json

+ type Flow struct

+ CreatedBy string

+ Description string

+ Level string

+ Name string

+ RetentionTime time.Duration

+ Steps []*Step

+ Tag string

+ Team string

+ TimeAttempts time.Duration

+ TotalAttempts int

+ TpConsistency TpConsistency

+ Version string

+ func New(tag, version, name, description string, fn FnContext, stop bool, ...) *Flow

+ func (s *Flow) Consistency(consistency TpConsistency) *Flow

+ func (s *Flow) Debug() *Flow

+ func (s *Flow) IfElse(expression string, yesGoTo int, noGoTo int) *Flow

+ func (s *Flow) Resilence(totalAttempts int, timeAttempts time.Duration, team string, level string) *Flow

+ func (s *Flow) Retention(retentionTime time.Duration) *Flow

+ func (s *Flow) Rollback(fn FnContext) *Flow

+ func (s *Flow) Step(name, description string, fn FnContext, stop bool) *Flow

+ func (s *Flow) ToJson() et.Json

+ type FlowStatus string

+ const FlowStatusDone

+ const FlowStatusFailed

+ const FlowStatusPending

+ const FlowStatusRunning

+ type FnContext func(flow *Instance, ctx et.Json) (et.Json, error)

+ type Instance struct

+ CreatedAt time.Time

+ CreatedBy string

+ Ctx et.Json

+ Ctxs map[int]et.Json

+ Current int

+ DoneAt time.Time

+ Id string

+ Results map[int]*Result

+ Rollbacks map[int]*Result

+ Status FlowStatus

+ Tags et.Json

+ UpdatedAt time.Time

+ WorkerHost string

+ func (s *Instance) Done() error

+ func (s *Instance) Goto(step int) error

+ func (s *Instance) Stop() error

+ func (s *Instance) ToJson() et.Json

+ type Result struct

+ Attempt int

+ Ctx et.Json

+ Error string

+ Result et.Json

+ Step int

+ func (s *Result) Serialize() (string, error)

+ func (s *Result) ToJson() et.Json

+ type Step struct

+ Description string

+ Expression string

+ Name string

+ NoGoTo int

+ Stop bool

+ YesGoTo int

+ func (s *Step) ToJson() et.Json

+ type TpConsistency string

+ const TpConsistencyEventual

+ const TpConsistencyStrong

+ type WorkFlows struct

+ AwaitingList []*Awaiting

+ Flows map[string]*Flow

+ Instances map[string]*Instance

+ LimitRequests int

+ Results map[string]et.Json

+ RetentionTime time.Duration