Versions in this module Expand all Collapse all v0 v0.0.2 Dec 16, 2024 v0.0.1 Dec 16, 2024 Changes in this version + type AbstractEntity struct + Id string + func (entity *AbstractEntity) GetId() string + func (entity *AbstractEntity) SetId(id string) + type AbstractVariableScopeImpl interface + GetSourceActivityExecution func() ExecutionEntity + type DefaultHistoryManager struct + type DeploymentEntity struct + DeploymentTime time.Time + IsNew bool + Key string + Name string + ProcessId string + ResourceEntity ResourceEntity + TenantId string + func (deploymentEntity *DeploymentEntity) AddResource(resource ResourceEntity) + func (deploymentEntity *DeploymentEntity) GetKey() string + func (deploymentEntity *DeploymentEntity) GetName() string + func (deploymentEntity *DeploymentEntity) GetResources() ResourceEntity + func (deploymentEntity *DeploymentEntity) SetDeploymentTime(deploymentTime time.Time) + func (deploymentEntity *DeploymentEntity) SetKey(key string) + func (deploymentEntity *DeploymentEntity) SetName(name string) + func (deploymentEntity *DeploymentEntity) SetResources(resourceEntity ResourceEntity) + func (deploymentEntity *DeploymentEntity) SetTenantId(tenantId string) + type DeploymentEntityManager struct + func GetDeploymentEntityManager() *DeploymentEntityManager + func (deploymentEntityManager DeploymentEntityManager) FindById(deploymentId string) (DeploymentEntity, error) + type Entity interface + GetId func() string + SetId func(id string) + type EntityManager interface + Delete func(entity Entity) + GetById func(id string, data interface{}) interface{} + Insert func(interface{}) error + type ExecutionEntity struct + ActivityId string + BusinessKey string + BusinessStatus string + CallbackId string + CallbackType string + CurrentActivityId string + CurrentFlowElement delegate.FlowElement + DeploymentId string + Ended bool + ProcessDefinitionDescription string + ProcessDefinitionId string + ProcessDefinitionName string + ProcessInstanceId string + ReferenceId string + ReferenceType string + StartTime time.Time + StartUserId string + Suspended bool + TenantId *string + func (execution *ExecutionEntity) GetExecutionId() string + func (execution *ExecutionEntity) GetTenantId() *string + func (execution *ExecutionEntity) SetBusinessKey(businessKey string) + func (execution *ExecutionEntity) SetCurrentActivityId(currentActivityId string) + func (execution *ExecutionEntity) SetCurrentFlowElement(flow delegate.FlowElement) + func (execution *ExecutionEntity) SetDeploymentId(deploymentId string) + func (execution *ExecutionEntity) SetProcessDefinitionId(processDefineId string) + func (execution *ExecutionEntity) SetProcessInstanceId(processInstanceId string) + func (execution ExecutionEntity) GetCurrentActivityId() string + func (execution ExecutionEntity) GetCurrentFlowElement() delegate.FlowElement + func (execution ExecutionEntity) GetDeploymentId() string + func (execution ExecutionEntity) GetProcessDefinitionId() string + func (execution ExecutionEntity) GetProcessInstanceId() string + func (execution ExecutionEntity) GetProcessVariable() map[string]interface{} + func (execution ExecutionEntity) GetSourceActivityExecution() ExecutionEntity + func (execution ExecutionEntity) GetSpecificVariable(variableName string) (Variable, error) + func (execution ExecutionEntity) GetVariable() map[string]interface{} + func (execution ExecutionEntity) HandleVariable(variables []Variable) map[string]interface{} + type ExecutionEntityManager struct + func GetExecutionEntityManager() *ExecutionEntityManager + func (executionEntityManager ExecutionEntityManager) CreateExecution(executionEntity *ExecutionEntity) error + func (executionEntityManager ExecutionEntityManager) DeleteExecution(executionId string) error + func (executionEntityManager ExecutionEntityManager) FindById(executionId string) (ExecutionEntity, error) + func (executionEntityManager ExecutionEntityManager) List(listRequest execution.ListRequest) ([]ExecutionEntity, error) + func (executionEntityManager ExecutionEntityManager) MigrateExecutionActID(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, ...) error + func (executionEntityManager ExecutionEntityManager) MigrateExecutionProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error + func (executionEntityManager ExecutionEntityManager) MigrateProcessInstanceBusinessStatus(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, ...) error + func (executionEntityManager ExecutionEntityManager) MigrateProcessInstanceProcDefIdAndStartActId(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error + func (executionEntityManager ExecutionEntityManager) RecordBusinessStatus(delegateExecution delegate.DelegateExecution) error + type HistoricActivityInstanceEntity struct + ActivityId string + ActivityName string + ActivityType string + Assignee string + CalledProcessInstanceId string + DeleteReason *string + DurationInMillis int + EndTime *time.Time + ExecutionId string + ProcessDefinitionId string + ProcessInstanceId string + StartTime time.Time + TaskId string + TenantId *string + type HistoricActivityInstanceEntityManager struct + func GetHistoricActivityInstanceEntityManager() *HistoricActivityInstanceEntityManager + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) DeleteByExecutionId(entity delegate.DelegateExecution) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) DeleteByProcessInstanceId(processInstanceId, actId string) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) List(listRequest historicactinst.ListRequest) ([]HistoricActivityInstanceEntity, error) + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) MigrateAct(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, ...) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) MigrateProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByExecutionId(element delegate.FlowElement, entity delegate.DelegateExecution, ...) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByExecutionIdAndActId(executionId, activityId string, deleteReason *string) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByProcessInstanceId(processInstanceId string, deleteReason *string) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActivityStart(entity delegate.DelegateExecution) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordSequenceFlow(entity delegate.DelegateExecution) error + func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordTaskId(task model.ActRuTask) error + type HistoricIdentityLinkEntity struct + GroupID *string + ProcInstID *string + TaskID *string + Type *string + UserID *string + type HistoricIdentityLinkEntityManager struct + func GetHistoricIdentityLinkEntityManager() *HistoricIdentityLinkEntityManager + func (historicIdentityLinkEntityManager HistoricIdentityLinkEntityManager) SelectByProcessInstanceId(processInstanceId string) ([]*HistoricIdentityLinkEntity, error) + type HistoricProcessInstanceEntity struct + BusinessKey string + BusinessStatus string + DeleteReason string + DurationInMillis int + EndActivityId string + EndTime *time.Time + ProcessDefinitionId string + ProcessDefinitionName string + ProcessDefinitionUrl string + StartActivityId string + StartTime *time.Time + StartUserId string + SuperProcessInstanceId string + TenantId string + Url string + Variables []variable.Variable + func (historicProcessInstanceEntity *HistoricProcessInstanceEntity) SetProcessDefinitionId(processDefinitionId string) + func (historicProcessInstanceEntity HistoricProcessInstanceEntity) GetProcessDefinitionId() string + type HistoricProcessInstanceEntityManager struct + func GetHistoricProcessInstanceEntityManager() *HistoricProcessInstanceEntityManager + func (historicProcessInstanceEntityManager HistoricProcessInstanceEntityManager) FindById(historicProcessInstanceId string) (HistoricProcessInstanceEntity, error) + func (historicProcessInstanceEntityManager HistoricProcessInstanceEntityManager) List(listRequest historicprocess.ListRequest) ([]HistoricProcessInstanceEntity, error) + type HistoricTaskInstanceEntity struct + Assignee string + Category string + ClaimTime *time.Time + DeleteReason string + Description string + DueDate *time.Time + DurationInMillis int + EndTime *time.Time + ExecutionId string + FormKey string + Name string + Owner string + ParentTaskId string + Priority int + ProcessDefinitionId string + ProcessDefinitionUrl string + ProcessInstanceId string + ProcessInstanceUrl string + StartTime time.Time + TaskDefinitionKey string + TenantId string + Url string + Variables []variable.Variable + WorkTimeInMillis int + func (historicTaskInstanceEntity HistoricTaskInstanceEntity) SetAssignee(assignee string) + type HistoricTaskInstanceEntityManager struct + func GetHistoricTaskInstanceEntityManager() *HistoricTaskInstanceEntityManager + func (historicTaskInstanceEntityManager HistoricTaskInstanceEntityManager) List(listRequest historictask.ListRequest) ([]HistoricTaskInstanceEntity, error) + func (historicTaskInstanceEntityManager HistoricTaskInstanceEntityManager) RecordTaskEnd(taskId string, deleteReason *string) error + type IdentityLinkEntity struct + GroupID *string + ProcDefID *string + ProcInstID *string + Rev *int32 + TaskID *string + Type *string + UserID *string + type IdentityLinkEntityManager struct + func GetIdentityLinkManager() *IdentityLinkEntityManager + func (identityLinkEntityManager IdentityLinkEntityManager) CreateIdentityLink(identityLink model.ActRuIdentitylink) (err error) + func (identityLinkEntityManager IdentityLinkEntityManager) DeleteByProcessInstanceId(processInstanceId string) error + func (identityLinkEntityManager IdentityLinkEntityManager) DeleteIdentityLinksByTaskId(taskId string) error + func (identityLinkEntityManager IdentityLinkEntityManager) SelectByProcessInstanceId(processInstanceId string) ([]*IdentityLinkEntity, error) + type ProcessDefinitionEntity struct + Category string + DeploymentId string + Description string + Key string + Name string + ResourceContent []byte + ResourceName string + Version int + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetDeploymentId() string + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetDescription() string + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetKey() string + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetName() string + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetResourceName() string + func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetVersion() int + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetCategory(category string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetDeploymentId(deploymentId string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetDescription(description string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetKey(key string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetName(name string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetResourceName(resourceName string) + func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetVersion(version int) + type ProcessDefinitionEntityManager struct + func GetProcessDefinitionEntityManager() *ProcessDefinitionEntityManager + func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindByDeploymentId(deploymentId string) (ProcessDefinitionEntity, error) + func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindLatestProcessDefinitionByKey(processDefinitionKey string) (ProcessDefinitionEntity, error) + func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindProcessDefinitionById(processDefinitionId string) (ProcessDefinitionEntity, error) + func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindResourceEntityByProcessDefinitionById(processDefinitionId string) (ResourceEntity, error) + func (processDefinitionEntityManager ProcessDefinitionEntityManager) Insert(processDefinition *model.ActReProcdef) (ProcessDefinitionEntity, error) + type ResourceEntity struct + Bytes []byte + DeploymentId string + Name string + func (resourceEntity *ResourceEntity) GetDeploymentId() string + func (resourceEntity *ResourceEntity) GetName() string + func (resourceEntity *ResourceEntity) SetBytes(bytes []byte) + func (resourceEntity *ResourceEntity) SetDeploymentId(deploymentId string) + func (resourceEntity *ResourceEntity) SetName(name string) + func (resourceEntity ResourceEntity) GetBytes() []byte + type ResourceEntityManager struct + func GetResourceEntityManager() *ResourceEntityManager + func (resourceEntityManager ResourceEntityManager) FindResourceByDeploymentIdAndResourceName(deploymentId, resourceName string) (ResourceEntity, error) + type TaskEntity struct + Assignee *string + Category string + ClaimTime *time.Time + DelegationState string + Description string + DueDate *time.Time + ExecutionId string + ExecutionUrl string + FormKey *string + Owner string + ParentTaskId string + ParentTaskUrl string + Priority int + ProcessDefinitionId string + ProcessDefinitionUrl string + ProcessInstanceId string + ProcessInstanceUrl string + PropagatedStageInstanceId string + ScopeDefinitionId string + ScopeId string + ScopeType string + StartTime time.Time + SubScopeId string + Suspended bool + TaskDefineName string + TaskDefinitionKey string + TenantId *string + Url string + Variables map[string]interface{} + func NewTaskEntity(execution delegate.DelegateExecution, userTask bpmn_model.UserTask) TaskEntity + func (taskEntiy *TaskEntity) GetAssignee() *string + func (taskEntiy *TaskEntity) GetClaimTime() *time.Time + func (taskEntiy *TaskEntity) GetExecutionId() string + func (taskEntiy *TaskEntity) GetTaskDefineKey() string + func (taskEntiy *TaskEntity) SetAssignee(assignee *string) + func (taskEntiy *TaskEntity) SetClaimTime(claimTime *time.Time) + func (taskEntiy *TaskEntity) SetExecutionId(executionId string) + func (taskEntiy *TaskEntity) SetStartTime(startTime time.Time) + func (taskEntiy *TaskEntity) SetTaskDefineKey(taskDefineKey string) + func (taskEntiy *TaskEntity) SetTaskDefineName(taskDefineName string) + func (taskEntiy TaskEntity) GetSpecificVariable(variableName string) (variable.Variable, error) + func (taskEntiy TaskEntity) GetVariable() map[string]interface{} + type TaskEntityManager struct + func GetTaskEntityManager() *TaskEntityManager + func (taskEntityManager TaskEntityManager) ChangeTaskAssignee(taskEntity TaskEntity, userId *string) error + func (taskEntityManager TaskEntityManager) DeleteTask(task TaskEntity, deleteReason *string) error + func (taskEntityManager TaskEntityManager) FindById(id string) (TaskEntity, error) + func (taskEntityManager TaskEntityManager) FindByProcessInstanceId(processInstanceId string) ([]TaskEntity, error) + func (taskEntityManager TaskEntityManager) InsertTask(taskEntity *TaskEntity) error + func (taskEntityManager TaskEntityManager) List(listRequest task.ListRequest) ([]TaskEntity, error) + func (taskEntityManager TaskEntityManager) MigrateNameAndTaskDefKey(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, ...) error + func (taskEntityManager TaskEntityManager) MigrateProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error + type VariableEntity struct + Delete bool + Type string + func (variableEntity VariableEntity) GetType() string + func (variableEntity VariableEntity) SetDeleted(b bool) + type VariableEntityManager struct + func GetVariableEntityManager() *VariableEntityManager + func (variableEntityManager VariableEntityManager) DeleteByProcessInstanceId(processInstanceId string) error + func (variableEntityManager VariableEntityManager) DeleteVariableInstanceByTask(taskId string) + func (variableEntityManager VariableEntityManager) UpsertHistoricVariable(v variable.Variable) (err error) + func (variableEntityManager VariableEntityManager) UpsertVariable(v variable.Variable) error + type VariableScopeImpl struct + ExecutionEntity ExecutionEntity + func (variableScope VariableScopeImpl) GetVariableLocal() (variables map[string]interface{}) + func (variableScope VariableScopeImpl) SetVariable(execution delegate.DelegateExecution, variables map[string]interface{}) error + func (variableScope VariableScopeImpl) SetVariableLocal(variables map[string]interface{}) error
Go to main page