processdeploymentstart

package

v0.0.14 Latest Latest Go to latest Published: Aug 26, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation ¶

Index ¶

type Config
type ProcessDeploymentStart
- func New(config Config, libConfig configuration.Config, auth *auth.Auth, ...) *ProcessDeploymentStart
type ProcessInstance
type SmartServiceRepo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	ProcessEngineWrapperUrl     string `json:"process_engine_wrapper_url"`
	FogProcessDeploymentUrl     string `json:"fog_process_deployment_url"`
	WorkerParamPrefix           string `json:"worker_param_prefix"`
	ProcessDeploymentModuleType string `json:"process_deployment_module_type"`
}

type ProcessDeploymentStart ¶

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

func New ¶

func New(config Config, libConfig configuration.Config, auth *auth.Auth, smartServiceRepo SmartServiceRepo) *ProcessDeploymentStart

func (*ProcessDeploymentStart) Do ¶

func (this *ProcessDeploymentStart) Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)

func (*ProcessDeploymentStart) Start ¶

func (this *ProcessDeploymentStart) Start(token auth.Token, deploymentId string, inputs map[string]interface{}) (instance ProcessInstance, err error)

func (*ProcessDeploymentStart) StartFog ¶

func (this *ProcessDeploymentStart) StartFog(token auth.Token, hubId string, deploymentId string, inputs map[string]interface{}) error

func (*ProcessDeploymentStart) Undo ¶

func (this *ProcessDeploymentStart) Undo(modules []model.Module, reason error)

type ProcessInstance ¶

type ProcessInstance struct {
	Id             string `json:"id,omitempty"`
	DefinitionId   string `json:"definitionId,omitempty"`
	BusinessKey    string `json:"businessKey,omitempty"`
	CaseInstanceId string `json:"caseInstanceId,omitempty"`
	Ended          bool   `json:"ended,omitempty"`
	Suspended      bool   `json:"suspended,omitempty"`
	TenantId       string `json:"tenantId,omitempty"`
}

type SmartServiceRepo ¶

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	UseModuleDeleteInfo(info model.ModuleDeleteInfo) error
	ListExistingModules(processInstanceId string, query model.ModulQuery) (result []model.SmartServiceModule, err error)
}

Source Files ¶

View all Source files

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