processdeploymentstart

package

v0.0.20 Latest Latest Go to latest Published: May 12, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

Index ¶

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

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"`
	ProcessSyncUrl              string `json:"process_sync_url"`
	WorkerParamPrefix           string `json:"worker_param_prefix"`
	ProcessDeploymentModuleType string `json:"process_deployment_module_type"`

	HealthCheckInterval string `json:"health_check_interval"`
}

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) CheckFogProcess ¶ added in v0.0.18

func (this *ProcessDeploymentStart) CheckFogProcess(token auth.Token, hubId string, businessKey string) (found bool, state State, err error)

func (*ProcessDeploymentStart) CheckProcess ¶ added in v0.0.18

func (this *ProcessDeploymentStart) CheckProcess(token auth.Token, businessKey string) (found bool, state State, err error)

func (*ProcessDeploymentStart) Do ¶

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

func (*ProcessDeploymentStart) GetFogProcessInstances ¶ added in v0.0.18

func (this *ProcessDeploymentStart) GetFogProcessInstances(token auth.Token, hubId string, businessKey string) (result model.HistoricProcessInstances, err error)

func (*ProcessDeploymentStart) Start ¶

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

func (*ProcessDeploymentStart) StartFog ¶

func (this *ProcessDeploymentStart) StartFog(token auth.Token, hubId string, deploymentId string, inputs map[string]interface{}, businessKey string) 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)
}

type State ¶ added in v0.0.18

type State int

const (
	Unknown State = iota
	Completed
	Active
	Terminated
)

Source Files ¶

View all Source files

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