Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v0

v0.0.7

Mar 25, 2024

v0.0.6

Mar 15, 2024

v0.0.5

Feb 12, 2024

v0.0.4

Jan 24, 2024

v0.0.3

Jan 8, 2024

v0.0.2

Jan 3, 2024

v0.0.1

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)