mgw

Documentation

Index

• type EventDescriptionsUpdate
• type Handler
• type Mgw
  • func New(config configuration.Config, ctx context.Context, handler Handler) (*Mgw, error)
  • func (this *Mgw) SendDeploymentCommand(networkId string, deployment model.DeploymentWithEventDesc) error
  • func (this *Mgw) SendDeploymentDeleteCommand(networkId string, deploymentId string) error
  • func (this *Mgw) SendDeploymentEventUpdateCommand(networkId string, camundaDeploymentId string, ...) error
  • func (this *Mgw) SendDeploymentStartCommand(networkId string, deploymentId string, parameter map[string]interface{}) error
  • func (this *Mgw) SendProcessHistoryDeleteCommand(networkId string, processInstanceHistoryId string) error
  • func (this *Mgw) SendProcessStopCommand(networkId string, processInstanceId string) error

Types

type EventDescriptionsUpdate

type EventDescriptionsUpdate struct {
	CamundaDeploymentId string             `json:"camunda_deployment_id"`
	EventDescriptions   []model2.EventDesc `json:"event_descriptions"`
	DeviceIdToLocalId   map[string]string  `json:"device_id_to_local_id"`
	ServiceIdToLocalId  map[string]string  `json:"service_id_to_local_id"`
}

type Handler

type Handler interface {
	UpdateDeployment(networkId string, deployment camundamodel.Deployment)
	DeleteDeployment(networkId string, deploymentId string)
	DeleteUnknownDeployments(networkId string, knownIds []string)
	UpdateIncident(networkId string, incident camundamodel.Incident)
	DeleteIncident(networkId string, incidentId string)
	DeleteUnknownIncidents(networkId string, knownIds []string)
	UpdateHistoricProcessInstance(networkId string, historicProcessInstance camundamodel.HistoricProcessInstance)
	DeleteHistoricProcessInstance(networkId string, historicInstanceId string)
	DeleteUnknownHistoricProcessInstances(networkId string, knownIds []string)
	UpdateProcessDefinition(networkId string, processDefinition camundamodel.ProcessDefinition)
	DeleteProcessDefinition(networkId string, definitionId string)
	DeleteUnknownProcessDefinitions(networkId string, knownIds []string)
	UpdateProcessInstance(networkId string, instance camundamodel.ProcessInstance)
	DeleteProcessInstance(networkId string, instanceId string)
	DeleteUnknownProcessInstances(networkId string, knownIds []string)
	UpdateDeploymentMetadata(networkId string, metadata model.Metadata)
	LogNetworkInteraction(networkId string)
}

type Mgw

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

func New

func New(config configuration.Config, ctx context.Context, handler Handler) (*Mgw, error)

func (*Mgw) SendDeploymentCommand

func (this *Mgw) SendDeploymentCommand(networkId string, deployment model.DeploymentWithEventDesc) error

func (*Mgw) SendDeploymentDeleteCommand

func (this *Mgw) SendDeploymentDeleteCommand(networkId string, deploymentId string) error

func (*Mgw) SendDeploymentEventUpdateCommand

func (this *Mgw) SendDeploymentEventUpdateCommand(networkId string, camundaDeploymentId string, eventDescriptions []model2.EventDesc, deviceMapping map[string]string, serviceMapping map[string]string) error

func (*Mgw) SendDeploymentStartCommand

func (this *Mgw) SendDeploymentStartCommand(networkId string, deploymentId string, parameter map[string]interface{}) error

func (*Mgw) SendProcessHistoryDeleteCommand

func (this *Mgw) SendProcessHistoryDeleteCommand(networkId string, processInstanceHistoryId string) error

func (*Mgw) SendProcessStopCommand

func (this *Mgw) SendProcessStopCommand(networkId string, processInstanceId string) error