workflow

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2025 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EVENT_ERROR           = "workflow:error"
	EVENT_FLOW_SET        = "workflow:flow:set"
	EVENT_FLOW_DELETE     = "workflow:flow:delete"
	EVENT_FLOW_STATUS     = "workflow:flow:status"
	EVENT_WORKFLOW_SET    = "workflow:set"
	EVENT_WORKFLOW_DELETE = "workflow:delete"
	EVENT_WORKFLOW_STATUS = "workflow:status"
)
View Source 
const (
	MSG_FLOW_CREATED                = "Flujo definido Tag:%s version:%s name:%s"
	MSG_FLOW_NOT_FOUND              = "Flujo no encontrado"
	MSG_FLOW_NOT_INSTANCE           = "Flujo no instanciado"
	MSG_START_WORKFLOW              = "Iniciando el workflow"
	MSG_INSTANCE_ID_REQUIRED        = "Instance id es requerido"
	MSG_INSTANCE_NOT_FOUND          = "Instancia no encontrada"
	MSG_INSTANCE_EXISTS             = "Instancia existe"
	MSG_INSTANCE_FAILED             = "Instancia fallido:%s Tag:%s status:%s, step:%d error:%s"
	MSG_INSTANCE_STATUS             = "Instancia:%s Tag:%s status:%s, step:%d"
	MSG_INSTANCE_DEBUG              = "Instancia:%s debug:%s"
	MSG_INSTANCE_GOTO               = "Instancia %s Tag:%s ir al step:%d %s"
	MSG_INSTANCE_LOAD               = "Instancia load:%s tag:%s currentStep:%d"
	MSG_INSTANCE_ALREADY_DONE       = "Instancia ya finalizada"
	MSG_INSTANCE_ALREADY_RUNNING    = "Instancia ya en ejecucion"
	MSG_INSTANCE_PENDING            = "Instancia pendiente"
	MSG_INSTANCE_WORKFLOWS_IS_NIL   = "workFlows es nil"
	MSG_ID_REQUIRED                 = "id es requerido"
	MSG_INSTANCE_EXPRESSION_TRUE    = "Resultado de la expresion es true"
	MSG_INSTANCE_EXPRESSION_FALSE   = "Resultado de la expresion es false"
	MSG_INSTANCE_ROLLBACK           = "Esta intentando hacer rollback de un step que no existe"
	MSG_INSTANCE_ROLLBACK_STEP      = "Haciendo rollback del step:%d"
	MSG_INSTANCE_STEP_CREATED       = "Definido step:%d name:%s Tag:%s"
	MSG_INSTANCE_ROLLBACK_CREATED   = "Definido rollback step:%d name:%s Tag:%s"
	MSG_INSTANCE_ROLLBACK_FAILED    = "Rollback Instance:%s Tag:%s status:%s, step:%d error:%s"
	MSG_INSTANCE_CONSISTENCY        = "Consistencia definida Tag:%s consistency:%s"
	MSG_INSTANCE_RESILIENCE         = "Definida resilencia Tag:%s totalAttempts:%d timeAttempts:%s retentionTime:%s"
	MSG_INSTANCE_IFELSE             = "Definido ifElse step:%d name:%s expresion:%s ? %d : %d Tag:%s"
	MSG_INSTANCE_RETENTION          = "Definida retencion Tag:%s retentionTime:%s"
	MSG_INSTANCE_GOTO_USER_DECISION = "Por desicion del usuario"
	MSG_WORKFLOW_DELETE             = "Workflow eliminado Tag:%s"
	MSG_WORKFLOW_DONE_INSTANCE      = "Instancia terminada:%s"
	MSG_WORKFLOW_LIMIT_REQUESTS     = "Límite de peticiones alcanzado, el proceso se pondra en espera para ejecusión, instanceId:%s"
	MSG_INSTANCE_RUN                = "Run instance:%s, flow:%s"
	MSG_INSTANCE_INSTANCE_INC       = "WorkFlows.instanceInc totalInstances:%d limitRequests:%d"
	MSG_INSTANCE_INSTANCE_DEC       = "WorkFlows.instanceDec totalInstances:%d limitRequests:%d"
	MSG_INSTANCE_EVALUATE           = "error al evaluar expresion:%s, error:%s"
	MSG_ARG_REQUIRED                = "argumento requerido:%s"
	MSG_INSTANCE_DEFINITION_EMPTY   = "definition is empty"
)

Variables

This section is empty.

Functions

func Continue 

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

* * Continue * @param instanceId string, tags et.Json, ctx et.Json, createdBy string * @return et.Json, error *

func DeleteFlow 

func DeleteFlow(tag string) error

* * DeleteFlow * @param tag string * @return error *

func DeleteInstance 

func DeleteInstance(instanceId string) error

* * DeleteInstance * @param instanceId string * @return error *

func HealthCheck 

func HealthCheck() bool

* * HealthCheck * @return bool *

func Load 

func Load() error

* * Load * @return error

func OnDeleteFlow 

func OnDeleteFlow(f DeleteFlowFn)

* * OnDeleteFlow * @param f DeleteFlowFn * @return void *

func OnDeleteInstance 

func OnDeleteInstance(f DeleteInstanceFn)

* * OnDeleteInstance * @param f DeleteInstanceFn * @return void *

func OnLoadFlow 

func OnLoadFlow(f LoadFlowFn)

* * OnLoadFlow * @param f LoadFlowFn * @return void *

func OnLoadInstance 

func OnLoadInstance(f LoadInstanceFn)

* * OnLoadInstance * @param f LoadInstanceFn * @return void *

func OnSaveFlow 

func OnSaveFlow(f SaveFlowFn)

* * OnSaveFlow * @param f SaveFlowFn * @return void *

func OnSaveInstance 

func OnSaveInstance(f SaveInstanceFn)

* * OnSaveInstance * @param f SaveInstanceFn * @return void *

func Reset 

func Reset(instanceId, createdBy string) error

* * Reset * @param instanceId string * @return error *

func Rollback 

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

* * Rollback * @param instanceId string * @return et.Json, error *

func Run 

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

* * Run * @param instanceId, tag string, startId int, tags et.Json, ctx et.Json, createdBy string * @return et.Json, error *

func Stop 

func Stop(instanceId string) error

* * Stop * @param instanceId string * @return error *

Types

type DeleteFlowFn 

type DeleteFlowFn func(tag string) error

type DeleteInstanceFn 

type DeleteInstanceFn func(id string) error

type Flow 

type Flow struct {
	Tag           string        `json:"tag"`
	Version       string        `json:"version"`
	Name          string        `json:"name"`
	Description   string        `json:"description"`
	TotalAttempts int           `json:"total_attempts"`
	TimeAttempts  time.Duration `json:"time_attempts"`
	RetentionTime time.Duration `json:"retention_time"`
	Steps         []*Step       `json:"steps"`
	TpConsistency TpConsistency `json:"tp_consistency"`
	Team          string        `json:"team"`
	Level         string        `json:"level"`
	CreatedBy     string        `json:"created_by"`
	// contains filtered or unexported fields
}

func New 

func New(tag, version, name, description string, definition string, stop bool, createdBy string) *Flow

* * New * @param tag, version, name, description string, definition string, createdBy string * @return *Flow *

func NewByFile 

func NewByFile(tag, version, name, description string, filePath string, stop bool, createdBy string) *Flow

* * NewByFile * @param tag, version, name, description string, filePath string, stop bool, createdBy string * @return *Flow *

func NewFn 

func NewFn(tag, version, name, description string, fn FnContext, stop bool, createdBy string) *Flow

* * NewFn * @param tag, version, name, description string, fn FnContext, createdBy string * @return *Flow *

func (*Flow) Consistency 

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

* * Consistency * @param consistency TpConsistency * @return *Flow *

func (*Flow) Debug 

func (s *Flow) Debug() *Flow

* * Debug * @return *Flow *

func (*Flow) IfElse 

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

* * IfElse * @param expression string, yesGoTo int, noGoTo int * @return *Flow, error *

func (*Flow) Resilence 

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

* * Resilence * @param totalAttempts int, timeAttempts time.Duration * @return *Flow *

func (*Flow) Retention 

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

* * Retention * @param retentionTime time.Duration * @return *Flow *

func (*Flow) Rollback 

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

* * Rollback * @params fn FnContext * @return *Flow *

func (*Flow) Save 

func (s *Flow) Save() error

* * Save * @return error *

func (*Flow) Step 

func (s *Flow) Step(name, description string, definition string, stop bool) *Flow

* * Step * @param name, description string, definition string, stop bool * @return *Flow *

func (*Flow) StepByFile 

func (s *Flow) StepByFile(name, description string, filePath string, stop bool) *Flow

* * StepByFile * @param name, description string, filePath string, stop bool * @return *Flow *

func (*Flow) StepFn 

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

* * StepFn * @param name, description string, fn FnContext, retries, retryDelay int, stop bool * @return *Fn *

func (*Flow) ToJson 

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

* * ToJson * @return et.Json *

type FlowStatus 

type FlowStatus string
const (
	FlowStatusPending FlowStatus = "pending"
	FlowStatusRunning FlowStatus = "running"
	FlowStatusDone    FlowStatus = "done"
	FlowStatusFailed  FlowStatus = "failed"
)

type FnContext 

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

type Instance 

type Instance struct {
	*Flow

	CreatedAt  time.Time       `json:"created_at"`
	UpdatedAt  time.Time       `json:"updated_at"`
	Tag        string          `json:"tag"`
	Id         string          `json:"id"`
	CreatedBy  string          `json:"created_by"`
	UpdatedBy  string          `json:"updated_by"`
	Status     FlowStatus      `json:"status"`
	DoneAt     time.Time       `json:"done_at"`
	Current    int             `json:"current"`
	Ctx        et.Json         `json:"ctx"`
	Ctxs       map[int]et.Json `json:"ctxs"`
	PinnedData et.Json         `json:"pinned_data"`
	Results    map[int]*Result `json:"results"`
	Tags       et.Json         `json:"tags"`
	Rollbacks  map[int]*Result `json:"rollbacks"`
	WorkerHost string          `json:"worker_host"`
	// contains filtered or unexported fields
}

func GetInstance 

func GetInstance(instanceId string) (*Instance, error)

* * GetInstance * @param instanceId string * @return (*Instance, error) *

func (*Instance) Done 

func (s *Instance) Done() error

* * Done * @return error *

func (*Instance) Goto 

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

* * Goto * @param step int * @return error *

func (*Instance) Save 

func (s *Instance) Save() error

* * Save * @return error *

func (*Instance) SetCtx 

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

* * SetCtx * @param ctx et.Json *

func (*Instance) SetPinnedData 

func (s *Instance) SetPinnedData(key string, value interface{})

* * SetPinedData * @param key string, value interface{} *

func (*Instance) SetResult 

func (s *Instance) SetResult(result et.Json, err error) (et.Json, error)

* * SetResult * @param result et.Json, err error * @return et.Json, error *

func (*Instance) SetStatus 

func (s *Instance) SetStatus(status FlowStatus) error

* * SetStatus * @param status FlowStatus * @return error *

func (*Instance) SetStep 

func (s *Instance) SetStep(val int)

* * SetStep * @param val int * @return error *

func (*Instance) SetTags 

func (s *Instance) SetTags(tags et.Json)

* * SetTags * @param tags et.Json *

func (*Instance) Stop 

func (s *Instance) Stop() error

* * Stop * @return error *

func (*Instance) ToJson 

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

* * ToJson * @return et.Json *

type LoadFlowFn 

type LoadFlowFn func(tag string) (*Flow, error)

type LoadInstanceFn 

type LoadInstanceFn func(id string) (*Instance, error)

type Result 

type Result struct {
	Step    int     `json:"step"`
	Ctx     et.Json `json:"ctx"`
	Attempt int     `json:"attempt"`
	Result  et.Json `json:"result"`
	Error   string  `json:"error"`
}

func (*Result) Serialize 

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

* * Serialize * @return string *

func (*Result) ToJson 

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

* * ToJson * @return et.Json *

type SaveFlowFn 

type SaveFlowFn func(flow *Flow) error

type SaveInstanceFn 

type SaveInstanceFn func(instance *Instance) error

type Step 

type Step struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Type        TpStep `json:"type"`
	Stop        bool   `json:"stop"`
	Expression  string `json:"expression"`
	YesGoTo     int    `json:"yes_go_to"`
	NoGoTo      int    `json:"no_go_to"`
	Definition  string `json:"definition"`
	// contains filtered or unexported fields
}

func (*Step) ToJson 

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

* * ToJson * @return et.Json *

type TpConsistency 

type TpConsistency string
const (
	TpConsistencyStrong   TpConsistency = "strong"
	TpConsistencyEventual TpConsistency = "eventual"
)

type TpStep 

type TpStep string
const (
	TpFn         TpStep = "function"
	TpDefinition TpStep = "definition"
)

type WorkFlows 

type WorkFlows struct {
	Flows     map[string]*Flow     `json:"flows"`
	Instances map[string]*Instance `json:"instances"`
	// contains filtered or unexported fields
}

func (*WorkFlows) Add 

func (s *WorkFlows) Add(instance *Instance)

* * Add *

func (*WorkFlows) Count 

func (s *WorkFlows) Count() int

* * Count * @return int *

func (*WorkFlows) Remove 

func (s *WorkFlows) Remove(instanceId string)

* * Remove *

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.