controller

Documentation

Index

• Constants
• type CamundaDeploymentId
• type Controller
  • func New(config configuration.Config, ctx context.Context) (ctrl *Controller, err error)
  • func (this *Controller) CreateDeployment(deployment model.FogDeploymentMessage) (err error)
  • func (this *Controller) DeleteDeployment(id string) error
  • func (this *Controller) DeleteProcessInstance(id string) error
  • func (this *Controller) DeleteProcessInstanceHistory(id string) error
  • func (this *Controller) DeployConditionalEventOperators(metadata metadata.Metadata) error
  • func (this *Controller) DeployIncidentsHandlerForDeploymentId(camundaDeplId string, handling deploymentmodel.IncidentHandling) error
  • func (this *Controller) HandleIncident(incident camundamodel.Incident) error
  • func (this *Controller) NotifyDeploymentDelete(extra string)
  • func (this *Controller) NotifyDeploymentUpdate(extra string)
  • func (this *Controller) NotifyHistoryDelete(extra string)
  • func (this *Controller) NotifyHistoryUpdate(extra string)
  • func (this *Controller) NotifyInstanceDelete(extra string)
  • func (this *Controller) NotifyInstanceUpdate(extra string)
  • func (this *Controller) NotifyProcessDefDelete(extra string)
  • func (this *Controller) NotifyProcessDefUpdate(extra string)
  • func (this *Controller) RemoveConditionalEventOperators(deploymentId string) error
  • func (this *Controller) SendCurrentDeployments() error
  • func (this *Controller) SendCurrentHistories() error
  • func (this *Controller) SendCurrentInstances() error
  • func (this *Controller) SendCurrentProcessDefs() error
  • func (this *Controller) SendCurrentStates() (err error)
  • func (this *Controller) StartDeployment(id string, parameter map[string]interface{}) error
  • func (this *Controller) UpdateDeploymentEvents(camundaDeploymentId string, descriptions []eventmodel.EventDesc, ...) error
• type DeploymentInPg
• type EventRepo
• type OnIncident
• type ProcessDefInPg
• type ProcessInstanceHistoryInPg
• type ProcessInstanceInPg

Constants

const UserId = model.UserId

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) (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) 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) 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 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"}