controller

Nov 21, 2025

Changes in this version

+ func SetProcessId(xml string, id string) (result string, err error)

type Controller

+ func (this *Controller) DeployProcessWithoutWardenHandling(networkId string, deployment model.DeploymentWithEventDesc) (err error)

+ func (this *Controller) MigrateToWarden(token string, networkId string) (error, int)

+ func (this *Controller) StartDeploymentWithoutWardenHandling(networkId string, deploymentId string, businessKey string, ...) (err error, errCode int)

+ func (this *Controller) StopProcessInstanceWithoutWardenHandling(instance model.ProcessInstance) (err error, errCode int)

Jan 20, 2025

Changes in this version

+ var IsMarkedAsMissingErr = errors.New("is market as missing (you may try to redeploy)")

type Controller

+ func (this *Controller) ApiSyncDeployments(token string, networkId string) (error, int)

Dec 19, 2023

Changes in this version

+ var HistoryMayOnlyDeletedIfFinishedOrPlaceholderErr = errors.New(...)

+ var IsMarkedForDeleteErr = errors.New("is market for deletion")

+ var IsPlaceholderProcessErr = errors.New("is placeholder process")

+ type BaseDeviceRepoFactory = func(token string, deviceRepoUrl string, permissionsSearchUrl string) eventinterfaces.Devices

+ type Controller struct

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

+ func NewDefault(conf configuration.Config, ctx context.Context) (ctrl *Controller, err error)

+ func (this *Controller) ApiCheckAccess(request *http.Request, networkId string, rights string) (err error, errCode int)

+ func (this *Controller) ApiCheckAccessMultiple(request *http.Request, networkIds []string, rights string) (err error, errCode int)

+ func (this *Controller) ApiCheckAccessReturnToken(request *http.Request, networkId string, rights string) (token string, err error, errCode int)

+ func (this *Controller) ApiCreateDeployment(token string, networkId string, deployment deploymentmodel.Deployment) (err error, errCode int)

+ func (this *Controller) ApiDeleteDeployment(networkId string, deploymentId string) (err error, errCode int)

+ func (this *Controller) ApiDeleteHistoricProcessInstance(networkId string, id string) (err error, errCode int)

+ func (this *Controller) ApiDeleteIncident(networkId string, id string) (err error, errCode int)

+ func (this *Controller) ApiDeleteProcessInstance(networkId string, id string) (err error, errCode int)

+ func (this *Controller) ApiListDeployments(networkIds []string, limit int64, offset int64, sort string) (result []model.Deployment, err error, errCode int)

+ func (this *Controller) ApiListHistoricProcessInstance(networkIds []string, query model.HistoryQuery, limit int64, offset int64, ...) (result []model.HistoricProcessInstance, total int64, err error, errCode int)

+ func (this *Controller) ApiListIncidents(networkIds []string, processInstanceId string, limit int64, offset int64, ...) (result []model.Incident, err error, errCode int)

+ func (this *Controller) ApiListNetworks(request *http.Request) (result []SearchHub, err error, errCode int)

+ func (this *Controller) ApiListProcessDefinitions(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessDefinition, err error, errCode int)

+ func (this *Controller) ApiListProcessInstances(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessInstance, err error, errCode int)

+ func (this *Controller) ApiReadDeployment(networkId string, deploymentId string) (result model.Deployment, err error, errCode int)

+ func (this *Controller) ApiReadDeploymentMetadata(networkId string, deploymentId string) (result model.DeploymentMetadata, err error, errCode int)

+ func (this *Controller) ApiReadHistoricProcessInstance(networkId string, id string) (result model.HistoricProcessInstance, err error, errCode int)

+ func (this *Controller) ApiReadIncident(networkId string, id string) (result model.Incident, err error, errCode int)

+ func (this *Controller) ApiReadProcessDefinition(networkId string, id string) (result model.ProcessDefinition, err error, errCode int)

+ func (this *Controller) ApiReadProcessInstance(networkId string, id string) (result model.ProcessInstance, err error, errCode int)

+ func (this *Controller) ApiSearchDeployments(networkIds []string, search string, limit int64, offset int64, sort string) (result []model.Deployment, err error, errCode int)

+ func (this *Controller) ApiStartDeployment(networkId string, deploymentId string, parameter map[string]interface{}) (err error, errCode int)

+ func (this *Controller) DeleteDeployment(networkId string, deploymentId string)

+ func (this *Controller) DeleteHistoricProcessInstance(networkId string, historicInstanceId string)

+ func (this *Controller) DeleteIncident(networkId string, incidentId string)

+ func (this *Controller) DeleteProcessDefinition(networkId string, definitionId string)

+ func (this *Controller) DeleteProcessInstance(networkId string, instanceId string)

+ func (this *Controller) DeleteUnknownDeployments(networkId string, knownIds []string)

+ func (this *Controller) DeleteUnknownHistoricProcessInstances(networkId string, knownIds []string)

+ func (this *Controller) DeleteUnknownIncidents(networkId string, knownIds []string)

+ func (this *Controller) DeleteUnknownProcessDefinitions(networkId string, knownIds []string)

+ func (this *Controller) DeleteUnknownProcessInstances(networkId string, knownIds []string)

+ func (this *Controller) ExtendDeployments(deployments []model.Deployment) (result []model.ExtendedDeployment)

+ func (this *Controller) ListDeploymentMetadata(query model.MetadataQuery) (result []model.DeploymentMetadata, err error)

+ func (this *Controller) LogNetworkInteraction(networkId string)

+ func (this *Controller) RemoveOldEntities(maxAge time.Duration) error

+ func (this *Controller) SetErrCode(err error) int

+ func (this *Controller) UpdateDeployment(networkId string, deployment camundamodel.Deployment)

+ func (this *Controller) UpdateDeploymentMetadata(networkId string, metadata model.Metadata)

+ func (this *Controller) UpdateDeviceGroup(token string, deviceGroupId string) error

+ func (this *Controller) UpdateHistoricProcessInstance(networkId string, historicProcessInstance camundamodel.HistoricProcessInstance)

+ func (this *Controller) UpdateIncident(networkId string, incident camundamodel.Incident)

+ func (this *Controller) UpdateProcessDefinition(networkId string, processDefinition camundamodel.ProcessDefinition)

+ func (this *Controller) UpdateProcessInstance(networkId string, instance camundamodel.ProcessInstance)

+ type DeviceGroupCommand struct

+ Command string

+ DeviceGroup models.DeviceGroup

+ Id string

+ Owner string

+ type DeviceProvider = func(token string, baseUrl string, deviceId string) (result models.Device, err error, code int)

+ type Devices interface

+ GetConcept func(token auth.Token, conceptId string) (result model.Concept, err error, code int)

+ GetDevice func(token auth.Token, id string) (devicemodel.Device, error, int)

+ GetDeviceInfosOfDevices func(token auth.Token, deviceIds []string) (devices []model.Device, deviceTypeIds []string, err error, code int)

+ GetDeviceInfosOfGroup func(token auth.Token, groupId string) (devices []model.Device, deviceTypeIds []string, err error, code int)

+ GetDeviceTypeSelectables func(token auth.Token, criteria []model.FilterCriteria) (result []model.DeviceTypeSelectable, err error, code int)

+ GetFunction func(token auth.Token, functionId string) (result model.Function, err error, code int)

+ GetService func(token auth.Token, serviceId string) (result models.Service, err error, code int)

+ type DoneNotification struct

+ Command string

+ Handler string

+ Id string

+ type SearchHub struct

+ DeviceIds []string

+ DeviceLocalIds []string

+ Id string

+ Name string

+ type Security interface

+ CheckBool func(token string, kind string, id string, rights string) (allowed bool, err error)

+ CheckMultiple func(token string, kind string, ids []string, rights string) (result map[string]bool, err error)

+ GetAdminToken func() (token string, err error)

+ List func(token string, resource string, limit string, offset string, rights string) (result []security.ListElement, err error)

+ ListElements func(token string, resource string, limit string, offset string, rights string, ...) (err error)