backend

package

v1.0.33 Latest Latest Go to latest Published: Aug 13, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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, businessKey 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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL