entitymanager

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 ExecutionEntityManager

+ func (executionEntityManager ExecutionEntityManager) CollectChildren(executionId string) ([]ExecutionEntity, error)

+ func (executionEntityManager ExecutionEntityManager) DeleteChildExecutions(children []ExecutionEntity, deleteReason *string) error

+ func (executionEntityManager ExecutionEntityManager) GetTopKValueFromChildExecutions(children []ExecutionEntity, variableName string, k int) ([]interface{}, error)

type VariableEntityManager

+ func (variableEntityManager VariableEntityManager) GetVariablesByParentIdAndVariableName(executionIds []string, variableName string) ([]variable.Variable, error)

v0.0.5

Feb 9, 2025

Changes in this version

type ExecutionEntity

+ Parent delegate.DelegateExecution

+ ParentId string

+ func CreateChildExecution(parentExecution delegate.DelegateExecution) ExecutionEntity

+ func CreateExecution(execution delegate.DelegateExecution) ExecutionEntity

+ func (execution *ExecutionEntity) GetParent() (delegate.DelegateExecution, error)

+ func (execution *ExecutionEntity) GetParentId() string

+ func (execution *ExecutionEntity) GetVariableLocal(variableName string) (value interface{}, ok bool, err error)

+ func (execution *ExecutionEntity) GetVariablesLocal() (map[string]interface{}, error)

+ func (execution *ExecutionEntity) IsMultiInstanceRoot() bool

+ func (execution *ExecutionEntity) RemoveVariablesLocal(variableNames []string) error

+ func (execution *ExecutionEntity) SetMultiInstanceRoot(isMultiInstanceRoot bool)

+ func (execution *ExecutionEntity) SetParent(parent delegate.DelegateExecution)

+ func (execution *ExecutionEntity) SetParentId(parentId string)

+ func (execution ExecutionEntity) GetVariables() (map[string]interface{}, error)

+ func (execution ExecutionEntity) SetProcessVariables(variables map[string]interface{}) error

+ func (execution ExecutionEntity) SetVariableLocal(variableName string, value interface{}) error

+ func (execution ExecutionEntity) SetVariablesLocal(variables map[string]interface{}) error

type ExecutionEntityManager

+ func (executionEntityManager ExecutionEntityManager) DeleteChildExecution(executionId string, deleteReason *string) error

+ func (executionEntityManager ExecutionEntityManager) DeleteRelatedDataForExecution(executionId string, deleteReason *string) error

type TaskEntity

+ func (taskEntiy *TaskEntity) SetVariables(variables map[string]interface{}) error

type TaskEntityManager

+ func (taskEntityManager TaskEntityManager) FindByExecutionId(executionId string) ([]TaskEntity, error)

v0.0.4

Jan 9, 2025

v0.0.3

Jan 3, 2025

Changes in this version

+ func IsIntegral(val float64) bool

type HistoricActivityInstanceEntity

+ BusinessParameter *string

+ BusinessResult *string

type HistoricActivityInstanceEntityManager

+ func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordBusinessDataByExecutionId(entity delegate.DelegateExecution, businessParameter, businessResult string) error

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

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