backend

Documentation

Index

• type Client
  • func New(config configuration.Config, ctx context.Context, handler Handler) (*Client, error)
  • func (this *Client) GetMqttClient() paho.Client
  • func (this *Client) SendDeploymentDelete(id string) error
  • func (this *Client) SendDeploymentKnownIds(ids []string) error
  • func (this *Client) SendDeploymentMetadata(metadata metadata.Metadata) error
  • func (this *Client) SendDeploymentUpdate(instance camundamodel.Deployment) error
  • func (this *Client) SendIncident(incident camundamodel.Incident) error
  • func (this *Client) SendProcessDefinitionDelete(id string) error
  • func (this *Client) SendProcessDefinitionKnownIds(ids []string) error
  • func (this *Client) SendProcessDefinitionUpdate(instance model.ProcessDefinition) error
  • func (this *Client) SendProcessHistoryDelete(id string) error
  • func (this *Client) SendProcessHistoryKnownIds(ids []string) error
  • func (this *Client) SendProcessHistoryUpdate(instance model.HistoricProcessInstance) error
  • func (this *Client) SendProcessInstanceDelete(id string) error
  • func (this *Client) SendProcessInstanceKnownIds(ids []string) error
  • func (this *Client) SendProcessInstanceUpdate(instance model.ProcessInstance) error
• type EventDescriptionsUpdate
• type Handler

Types

type Client

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

func New

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

func (*Client) GetMqttClient

func (this *Client) GetMqttClient() paho.Client

func (*Client) SendDeploymentDelete

func (this *Client) SendDeploymentDelete(id string) error

func (*Client) SendDeploymentKnownIds

func (this *Client) SendDeploymentKnownIds(ids []string) error

func (*Client) SendDeploymentMetadata

func (this *Client) SendDeploymentMetadata(metadata metadata.Metadata) error

func (*Client) SendDeploymentUpdate

func (this *Client) SendDeploymentUpdate(instance camundamodel.Deployment) error

func (*Client) SendIncident

func (this *Client) SendIncident(incident camundamodel.Incident) error

func (*Client) SendProcessDefinitionDelete

func (this *Client) SendProcessDefinitionDelete(id string) error

func (*Client) SendProcessDefinitionKnownIds

func (this *Client) SendProcessDefinitionKnownIds(ids []string) error

func (*Client) SendProcessDefinitionUpdate

func (this *Client) SendProcessDefinitionUpdate(instance model.ProcessDefinition) error

func (*Client) SendProcessHistoryDelete

func (this *Client) SendProcessHistoryDelete(id string) error

func (*Client) SendProcessHistoryKnownIds

func (this *Client) SendProcessHistoryKnownIds(ids []string) error

func (*Client) SendProcessHistoryUpdate

func (this *Client) SendProcessHistoryUpdate(instance model.HistoricProcessInstance) error

func (*Client) SendProcessInstanceDelete

func (this *Client) SendProcessInstanceDelete(id string) error

func (*Client) SendProcessInstanceKnownIds

func (this *Client) SendProcessInstanceKnownIds(ids []string) error

func (*Client) SendProcessInstanceUpdate

func (this *Client) SendProcessInstanceUpdate(instance model.ProcessInstance) error

type EventDescriptionsUpdate

type EventDescriptionsUpdate struct {
	CamundaDeploymentId string                 `json:"camunda_deployment_id"`
	EventDescriptions   []eventmodel.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 {
	DeleteProcessInstanceHistory(id string) error
	DeleteProcessInstance(id string) error
	DeleteDeployment(id string) error
	StartDeployment(id string, parameter map[string]interface{}) error
	CreateDeployment(payload model.FogDeploymentMessage) (id string, err error)
	UpdateDeploymentEvents(camundaDeploymentId string, descriptions []eventmodel.EventDesc, id map[string]string, localId map[string]string) error
	HandleIncident(incident camundamodel.Incident) error
}