wfengine

type Action struct {
	ActionType     string   `json:"action_type"`
	ActionId       string   `json:"action_id"`
	ActionName     string   `json:"action_name"`
	Params         []*Param `json:"params"`
	NextActionIds  []string `json:"next_action_ids"`
	NextConditions []string `json:"next_conditions"`
	PrevActionIds  []string `json:"prev_action_ids"`
	Timeout        int64    `json:"timeout"`
	TimeoutAsync   bool     `json:"timeout_async"`
	TimeoutDynamic bool     `json:"timeout_dynamic"`
	RefWorkflowId  int64    `json:"ref_workflow_id"`
	Description    string   `json:"description"`
}

type ActionCounter struct {
	// contains filtered or unexported fields
}

type CondExecutors struct {
	InnerExecutor  *reflect.Value
	OuterExecutors *sync.Map
}

type Condition struct{}

type IModelBase interface {
	DoAction(context.Context, *model.StrategyContext) interface{}
	OnTimeout(context.Context, *model.StrategyContext)
	SetName(string)
	GetName() string
}

type ModelBase struct {
	IModelBase
	Name string
}

type ModuleObjBase interface {
	NewObj(moduleName string, vMap map[string]string) IModelBase
}

type Param struct {
	Name  string `json:"name"`
	Value string `json:"value"`
	Type  string `json:"type"`
}

type SceneModule struct {
	Id                     int64            `json:"id"`
	Name                   string           `json:"name"`
	AppId                  int64            `json:"appid"`
	BucketType             int              `json:"bucket_type"`
	SlotMap                map[int]int64    `json:"slots"`
	UpdateTime             time.Time        `json:"update_time"`
	FlowType               int              `json:"flow_type"`
	GroupWorkflowMap       map[string]int64 `json:"group_workflows"`
	DefaultWorkflowId      int64            `json:"default_workflow_id"`
	DispatchExperimentName string           `json:"dispatch_experiment_name"`
}

type TimeWaiter struct {
	// contains filtered or unexported fields
}

type Workflow struct {
	Id          int64           `json:"id"`
	DimensionId int64           `json:"dimension_id"`
	SceneId     int64           `json:"scene_id"`
	FlowChart   string          `json:"flow_chart"`
	FlowCharts  *WorkflowChart  `json:"flow_charts"`
	FlowBranch  *WorkflowBranch `json:"flow_branch"`
	IsDefault   int             `json:"is_default"`
	Range1      string          `json:"range1"`
	Range2      string          `json:"range2"`
	Remark      string          `json:"remark"`
	UpdateTime  time.Time       `json:"update_time"`
	GroupName   string          `json:"group_name"`
}

type WorkflowBranch struct {
	SortedBranch  []string           `json:"sorted_branch"`
	CurrentBranch map[string]int     `json:"current_branch"`
	ActionMap     map[string]*Action `json:"actions"`
}

type WorkflowChart struct {
	FirstActionId string             `json:"first_action_id"`
	LastActionId  string             `json:"last_action_id"`
	HashCondition bool               `json:"has_condition"`
	ActionMap     map[string]*Action `json:"actions"`
}

type WorkflowEngine struct {
	// contains filtered or unexported fields
}