controller

package
v1.0.22 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const UserId = model.UserId

Variables

This section is empty.

Functions

func ReplaceTaskTopics added in v1.0.17 

func ReplaceTaskTopics(xml string, fromToMap map[string]string) (result string, err error)

Types

type CamundaDeploymentId 

type CamundaDeploymentId = string

type Controller 

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

func New 

func New(config configuration.Config, ctx context.Context) (ctrl *Controller, err error)

func (*Controller) CreateDeployment 

func (this *Controller) CreateDeployment(deployment model.FogDeploymentMessage) (id string, err error)

func (*Controller) DeleteDeployment 

func (this *Controller) DeleteDeployment(id string) error

func (*Controller) DeleteProcessInstance 

func (this *Controller) DeleteProcessInstance(id string) error

func (*Controller) DeleteProcessInstanceHistory 

func (this *Controller) DeleteProcessInstanceHistory(id string) error

func (*Controller) DeployConditionalEventOperators 

func (this *Controller) DeployConditionalEventOperators(metadata metadata.Metadata) error

func (*Controller) DeployIncidentsHandlerForDeploymentId 

func (this *Controller) DeployIncidentsHandlerForDeploymentId(camundaDeplId string, handling deploymentmodel.IncidentHandling) error

func (*Controller) HandleIncident 

func (this *Controller) HandleIncident(incident camundamodel.Incident) error

func (*Controller) NotifyDeploymentDelete 

func (this *Controller) NotifyDeploymentDelete(extra string)

func (*Controller) NotifyDeploymentUpdate 

func (this *Controller) NotifyDeploymentUpdate(extra string)

func (*Controller) NotifyHistoryDelete 

func (this *Controller) NotifyHistoryDelete(extra string)

func (*Controller) NotifyHistoryUpdate 

func (this *Controller) NotifyHistoryUpdate(extra string)

func (*Controller) NotifyIncident added in v1.0.18 

func (this *Controller) NotifyIncident(extra string)

func (*Controller) NotifyInstanceDelete 

func (this *Controller) NotifyInstanceDelete(extra string)

func (*Controller) NotifyInstanceUpdate 

func (this *Controller) NotifyInstanceUpdate(extra string)

func (*Controller) NotifyProcessDefDelete 

func (this *Controller) NotifyProcessDefDelete(extra string)

func (*Controller) NotifyProcessDefUpdate 

func (this *Controller) NotifyProcessDefUpdate(extra string)

func (*Controller) RemoveConditionalEventOperators 

func (this *Controller) RemoveConditionalEventOperators(deploymentId string) error

func (*Controller) SendCurrentDeployments 

func (this *Controller) SendCurrentDeployments() error

func (*Controller) SendCurrentHistories 

func (this *Controller) SendCurrentHistories() error

func (*Controller) SendCurrentIncidents added in v1.0.18 

func (this *Controller) SendCurrentIncidents() (count int, err error)

func (*Controller) SendCurrentInstances 

func (this *Controller) SendCurrentInstances() error

func (*Controller) SendCurrentProcessDefs 

func (this *Controller) SendCurrentProcessDefs() error

func (*Controller) SendCurrentStates 

func (this *Controller) SendCurrentStates() (err error)

func (*Controller) StartDeployment 

func (this *Controller) StartDeployment(id string, parameter map[string]interface{}) error

func (*Controller) UpdateDeploymentEvents 

func (this *Controller) UpdateDeploymentEvents(camundaDeploymentId string, descriptions []eventmodel.EventDesc, deviceMapping map[string]string, serviceMapping map[string]string) error

type DeploymentInPg 

type DeploymentInPg struct {
	Id             string `json:"id_"`
	Name           string `json:"name_"`
	DeploymentTime string `json:"deploy_time_"`
	Source         string `json:"source_"`
	TenantId       string `json:"tenant_id_"`
}

{"id_":"1b3e90fe-750a-11eb-8c7e-0242ac110006","name_":"test","deploy_time_":"2021-02-22T12:33:03.214","source_":"test","tenant_id_":"user"}}

type EventRepo 

type EventRepo interface {
	AddDeployment(deployment metadata.Metadata) error
	RemoveDeployment(deploymentId string) error
}

type OnIncident 

type OnIncident struct {
	ProcessDefinitionId string `json:"process_definition_id" bson:"process_definition_id"`
	Restart             bool   `json:"restart" bson:"restart"`
	Notify              bool   `json:"notify" bson:"notify"`
}

type ProcessDefInPg 

type ProcessDefInPg struct {
	Id                string `json:"id_"`
	Key               string `json:"key_"`
	Category          string `json:"category_"`
	Name              string `json:"name_"`
	Version           int    `json:"version_"`
	Resource          string `json:"resource_name_"`
	DeploymentId      string `json:"deployment_id_"`
	Diagram           string `json:"dgrm_resource_name_"`
	Suspended         int    `json:"suspension_state_"`
	TenantId          string `json:"tenant_id_"`
	VersionTag        string `json:"version_tag_"`
	HistoryTimeToLive int    `json:"history_ttl_"`
}

{"id_":"ExampleId:1:686e7a53-750c-11eb-b54c-0242ac110006","rev_":1,"category_":"http://bpmn.io/schema/bpmn","name_":"ExampleName","key_":"ExampleId","version_":1,"deployment_id_":"685ee9f0-750c-11eb-b54c-0242ac110006","resource_name_":"test.bpmn","dgrm_resource_name_":"test.svg","has_start_form_key_":false,"suspension_state_":1,"tenant_id_":"user","version_tag_":null,"history_ttl_":null,"startable_":true}

type ProcessIncidentInPg added in v1.0.18 

type ProcessIncidentInPg struct {
	Id                  string `json:"id_"`
	Message             string `json:"incident_msg_"`
	ActivityId          string `json:"activity_id_"`
	ProcessInstanceId   string `json:"proc_inst_id_"`
	ProcessDefinitionId string `json:"proc_def_id_"`
}

public.act_ru_incident (id_, rev_, incident_timestamp_, incident_msg_, incident_type_, execution_id_, activity_id_, proc_inst_id_, proc_def_id_, cause_incident_id_, root_cause_incident_id_, configuration_, tenant_id_, job_def_id_) VALUES ('6da046d1-5580-11ef-9030-0242ac11000a', 1, '2024-08-08 12:19:15.517000', 'Unable to evaluate script while executing activity ”Task_0fi26gl” in the process definition with id ”script_err:1:631e00d6-5580-11ef-9030-0242ac11000a”:TypeError: Cannot read property "batz" from undefined in <eval> at line number 2', 'failedJob', '6614ab9a-5580-11ef-9030-0242ac11000a', 'IntermediateThrowEvent_1jxyivh', '6613e848-5580-11ef-9030-0242ac11000a', 'script_err:1:631e00d6-5580-11ef-9030-0242ac11000a', '6da046d1-5580-11ef-9030-0242ac11000a', '6da046d1-5580-11ef-9030-0242ac11000a', '66156eec-5580-11ef-9030-0242ac11000a', 'senergy', '631e27e7-5580-11ef-9030-0242ac11000a');

type ProcessInstanceHistoryInPg 

type ProcessInstanceHistoryInPg struct {
	Id                     string  `json:"id_"`
	SuperProcessInstanceId string  `json:"super_process_instance_id_"`
	SuperCaseInstanceId    string  `json:"super_case_instance_id_"`
	CaseInstanceId         string  `json:"case_inst_id_"`
	ProcessDefinitionKey   string  `json:"proc_def_key_"`
	ProcessDefinitionId    string  `json:"proc_def_id_"`
	BusinessKey            string  `json:"business_key_"`
	StartTime              string  `json:"start_time_"`
	EndTime                string  `json:"end_time_"`
	DurationInMillis       float64 `json:"duration_"`
	StartUserId            string  `json:"start_user_id_"`
	StartActivityId        string  `json:"start_act_id_"`
	DeleteReason           string  `json:"delete_reason_"`
	TenantId               string  `json:"tenant_id_"`
	State                  string  `json:"state_"`
}

{"id_":"6b84bb04-750c-11eb-b54c-0242ac110006","proc_inst_id_":"6b84bb04-750c-11eb-b54c-0242ac110006","business_key_":null,"proc_def_key_":"ExampleId","proc_def_id_":"ExampleId:1:686e7a53-750c-11eb-b54c-0242ac110006","start_time_":"2021-02-22T12:49:36.886","end_time_":null,"removal_time_":null,"duration_":null,"start_user_id_":null,"start_act_id_":"StartEvent_1","end_act_id_":null,"super_process_instance_id_":null,"root_proc_inst_id_":"6b84bb04-750c-11eb-b54c-0242ac110006","super_case_instance_id_":null,"case_inst_id_":null,"delete_reason_":null,"tenant_id_":"user","state_":"ACTIVE"}

type ProcessInstanceInPg 

type ProcessInstanceInPg struct {
	Id               string  `json:"id_"`
	DefinitionId     string  `json:"proc_def_id_"`
	BusinessKey      string  `json:"business_key_"`
	CaseInstanceId   string  `json:"case_inst_id_"`
	Active           bool    `json:"is_active_"`
	TenantId         string  `json:"tenant_id_"`
	EndTime          *string `json:"end_time_"`
	ParentInstanceId *string `json:"parent_id_"` //usable to check if process instance ist root element
}

{"id_":"6b84bb04-750c-11eb-b54c-0242ac110006","rev_":1,"root_proc_inst_id_":"6b84bb04-750c-11eb-b54c-0242ac110006","proc_inst_id_":"6b84bb04-750c-11eb-b54c-0242ac110006","business_key_":null,"parent_id_":null,"proc_def_id_":"ExampleId:1:686e7a53-750c-11eb-b54c-0242ac110006","super_exec_":null,"super_case_exec_":null,"case_inst_id_":null,"act_id_":null,"act_inst_id_":"6b84bb04-750c-11eb-b54c-0242ac110006","is_active_":false,"is_concurrent_":false,"is_scope_":true,"is_event_scope_":false,"suspension_state_":1,"cached_ent_state_":0,"sequence_counter_":2,"tenant_id_":"user"}

Source Files

View all Source files

Directories

Path Synopsis
Package etree provides XML services through an Element Tree abstraction.
 Package etree provides XML services through an Element Tree abstraction.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.