datamanager

package

Go to main page

Versions in this module

v0

v0.0.7

Feb 17, 2025

v0.0.6

Feb 17, 2025

Changes in this version

type VariableDataManager

+ func (defineManager VariableDataManager) SelectByExecutionIdsAndName(executionIds []string, name string) ([]variable.Variable, error)

v0.0.5

Feb 9, 2025

Changes in this version

type TaskDataManager

+ func (taskManager TaskDataManager) FindByExecutionId(executionId string) ([]model.ActRuTask, error)

type VariableDataManager

+ func (defineManager VariableDataManager) SelectByExecutionIdAndName(name string, executionId string) (variable.Variable, bool, error)

+ func (variableManager VariableDataManager) DeleteByExecutionIdAndNames(executionId string, variableNames []string) error

+ func (variableManager VariableDataManager) SelectByExecutionId(executionId string) ([]variable.Variable, error)

+ func (variableManager VariableDataManager) SelectByTaskIdAndName(name string, taskId string) (variable.Variable, bool, error)

v0.0.4

Jan 9, 2025

v0.0.3

Jan 3, 2025

Changes in this version

type HistoricActinstDataManager

+ func (historicActinstManager HistoricActinstDataManager) RecordBusinessDataByExecutionId(executionId string, businessParameter, businessResult *string) error

type TaskDataManager

+ func (taskManager TaskDataManager) GetUniqTaskDefKeys(listRequest task.ListRequest) ([]model.ActRuTask, error)

v0.0.2

Dec 16, 2024

v0.0.1

Dec 16, 2024

Changes in this version

+ type ActHiProcinstDTO struct

+ ProcessDefinitionName string

+ type DeploymentDataManager struct

+ func GetDeploymentDataManager() *DeploymentDataManager

+ type ExecutionDataManager struct

+ func GetExecutionDataManager() *ExecutionDataManager

+ func (executionDataManager *ExecutionDataManager) CreateProcessInstance(processInstance *model.ActRuExecution) error

+ func (executionDataManager *ExecutionDataManager) GetProcessInstance(processInstanceId string) (model.ActRuExecution, error)

+ func (executionDataManager *ExecutionDataManager) MigrateExecutionActID(procDefId, oldActivityId, newActivityId string) error

+ func (executionDataManager *ExecutionDataManager) MigrateExecutionProcDefID(oldProcDefId, newProcDefId string) error

+ func (executionDataManager *ExecutionDataManager) MigrateProcessInstance(oldProcDefId, newProcDefId, startActId string) error

+ func (executionDataManager *ExecutionDataManager) MigrateProcessInstanceBusinessStatus(procDefId, oldActivityId, newActivityId string) error

+ func (executionDataManager *ExecutionDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error

+ func (executionDataManager ExecutionDataManager) DeleteProcessInstance(execution delegate.DelegateExecution, deleteReason *string) error

+ func (executionDataManager ExecutionDataManager) List(listRequest execution.ListRequest) ([]model.ActRuExecution, error)

+ type HistoricActinstDataManager struct

+ func GetHistoricActinstDataManager() *HistoricActinstDataManager

+ func (historicActinstManager HistoricActinstDataManager) ChangeTaskAssignee(taskId string, userId *string) (err error)

+ func (historicActinstManager HistoricActinstDataManager) DeleteByExecutionId(executionId string) error

+ func (historicActinstManager HistoricActinstDataManager) DeleteByProcessInstanceId(processInstanceId, actId string) error

+ func (historicActinstManager HistoricActinstDataManager) List(listRequest historicactinst.ListRequest) ([]model.ActHiActinst, error)

+ func (historicActinstManager HistoricActinstDataManager) MigrateAct(procDefId, oldActivityId, newActivityId, newName, newType string) error

+ func (historicActinstManager HistoricActinstDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error

+ func (historicActinstManager HistoricActinstDataManager) RecordActEndByExecutionId(executionId string, actId string, deleteReason *string) error

+ func (historicActinstManager HistoricActinstDataManager) RecordActEndByProcessInstanceId(processInstanceId string, deleteReason *string) error

+ func (historicActinstManager HistoricActinstDataManager) RecordTaskId(task model.ActRuTask) error

+ type HistoricIdentityLinkDataManager struct

+ func GetHistoricIdentityLinkDataManager() *HistoricIdentityLinkDataManager

+ func (historicIdentityLinkDataManager HistoricIdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]model.ActHiIdentitylink, error)

+ type HistoricProcessDataManager struct

+ func GetHistoricProcessDataManager() *HistoricProcessDataManager

+ func (historicProcessManager HistoricProcessDataManager) List(listRequest historicprocess.ListRequest) ([]ActHiProcinstDTO, error)

+ func (historicProcessManager HistoricProcessDataManager) MarkEnded(processInstanceId string, endActID *string, deleteReason *string) (err error)

+ func (historicProcessManager HistoricProcessDataManager) Migrate(oldProcDefId, newProcDefId, startActId string) error

+ func (historicProcessManager HistoricProcessDataManager) MigrateBusinessStatus(procDefId, oldActivityId, newActivityId string) error

+ func (historicProcessManager HistoricProcessDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error

+ type HistoricTaskDataManager struct

+ func GetHistoricTaskDataManager() *HistoricTaskDataManager

+ func (historicTaskManager HistoricTaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error

+ func (historicTaskManager HistoricTaskDataManager) List(listRequest historictask.ListRequest) ([]model.ActHiTaskinst, error)

+ func (historicTaskManager HistoricTaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error

+ func (historicTaskManager HistoricTaskDataManager) RecordTaskEnd(id string, deleteReason *string) error

+ type HistoricVariableDataManager struct

+ func GetHistoricVariableDataManager() *HistoricVariableDataManager

+ func (historicVariableDataManager HistoricVariableDataManager) Upsert(varinst variable.HistoricVariable) error

+ type IdentityLinkDataManager struct

+ func GetIdentityLinkDataManager() *IdentityLinkDataManager

+ func (identityLinkManager IdentityLinkDataManager) DeleteByProcessInstanceId(processInstanceId string) error

+ func (identityLinkManager IdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]ActRuIdentitylink, error)

+ func (identityLinkManager IdentityLinkDataManager) SelectByTaskId(taskId string) ([]ActRuIdentitylink, error)

+ type ProcessDefinitionDataManager struct

+ func GetProcessDefinitionDataManager() *ProcessDefinitionDataManager

+ func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByDeploymentId(deploymentId string) (model.ActReProcdef, error)

+ func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByKey(key string) (model.ActReProcdef, error)

+ type ResourceDataManager struct

+ func GetResourceDataManager() *ResourceDataManager

+ func (define ResourceDataManager) FindResourceByDeploymentIdAndResourceName(deploymentId, resourceName string) (ActGeBytearray, error)

+ type TaskDataManager struct

+ func GetTaskDataManager() *TaskDataManager

+ func (taskManager TaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error

+ func (taskManager TaskDataManager) FindByProcessInstanceId(processInstanceId string) ([]model.ActRuTask, error)

+ func (taskManager TaskDataManager) GetById(id int64) (model.ActRuTask, error)

+ func (taskManager TaskDataManager) List(listRequest task.ListRequest) ([]model.ActRuTask, error)

+ func (taskManager TaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error

+ func (taskManager TaskDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error

+ func (taskManager TaskDataManager) QueryUndoTask(userId, groupId string) (taskResult []task.TaskDTO, err error)

+ type VariableDataManager struct

+ func GetVariableDataManager() *VariableDataManager

+ func (defineManager VariableDataManager) SelectByProcessInstanceIdAndName(name string, processInstanceId string) (variable.Variable, error)

+ func (variableManager VariableDataManager) Delete(variableId string) error

+ func (variableManager VariableDataManager) DeleteByExecutionId(executionId string) error

+ func (variableManager VariableDataManager) DeleteByProcessInstanceId(processInstanceId string) error

+ func (variableManager VariableDataManager) SelectByProcessInstanceId(processInstanceId string) ([]variable.Variable, error)

+ func (variableManager VariableDataManager) SelectByTaskId(taskId string) ([]variable.Variable, error)

+ func (variableManager VariableDataManager) SelectTaskId(name string, taskId string) (variable.Variable, error)

+ func (variableManager VariableDataManager) Upsert(varinst variable.Variable) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL