workflow

package
v0.1.18 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2025 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EVENT_WORKFLOW_SET      = "workflow:set"
	EVENT_WORKFLOW_DELETE   = "workflow:delete"
	EVENT_WORKFLOW_STATUS   = "workflow:status"
	EVENT_WORKFLOW_AWAITING = "workflow:awaiting"
	EVENT_WORKFLOW_RESULTS  = "workflow:results"
)
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"
)

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) (bool, error)

* * DeleteFlow * @param tag string * @return (bool, error) *

func HealthCheck 

func HealthCheck() bool

* * HealthCheck * @return bool *

func Load 

func Load() error

* * Load * @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, tag string * @return error *

Types

type Awaiting 

type Awaiting struct {
	CreatedAt  time.Time `json:"created_at"`
	ExecutedAt time.Time `json:"executed_at"`
	Id         string    `json:"id"`
	// contains filtered or unexported fields
}

func (*Awaiting) ToJson 

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

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, fn FnContext, stop bool, createdBy string) *Flow

* * New * @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) Step 

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

* * Step * @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"`
	Id         string          `json:"id"`
	CreatedBy  string          `json:"created_by"`
	Current    int             `json:"current"`
	Ctx        et.Json         `json:"ctx"`
	Ctxs       map[int]et.Json `json:"ctxs"`
	Results    map[int]*Result `json:"results"`
	Rollbacks  map[int]*Result `json:"rollbacks"`
	Status     FlowStatus      `json:"status"`
	DoneAt     time.Time       `json:"done_at"`
	Tags       et.Json         `json:"tags"`
	WorkerHost string          `json:"worker_host"`
	// contains filtered or unexported fields
}

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) Stop 

func (s *Instance) Stop() error

* * Stop * @return error *

func (*Instance) ToJson 

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

* * ToJson * @return et.Json *

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 Step 

type Step struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Stop        bool   `json:"stop"`
	Expression  string `json:"expression"`
	YesGoTo     int    `json:"yes_go_to"`
	NoGoTo      int    `json:"no_go_to"`
	// 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 WorkFlows 

type WorkFlows struct {
	Flows         map[string]*Flow     `json:"flows"`
	Instances     map[string]*Instance `json:"instances"`
	LimitRequests int                  `json:"limit_requests"`
	AwaitingList  []*Awaiting          `json:"awaiting_list"`
	Results       map[string]et.Json   `json:"results"`
	RetentionTime time.Duration        `json:"retention_time"`
	// contains filtered or unexported fields
}

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.