controller

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller

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

func New

func New(ctx context.Context, config configuration.Config, db interfaces.Database, camunda interfaces.Camunda, m Metric) (ctrl *Controller, err error)

func (*Controller) CreateIncident added in v0.0.8

func (this *Controller) CreateIncident(token string, incident messages.Incident) (err error, code int)

func (*Controller) DeleteIncidentByProcessDefinitionId added in v0.0.8

func (this *Controller) DeleteIncidentByProcessDefinitionId(token string, id string) (err error, code int)

func (*Controller) DeleteIncidentByProcessInstanceId added in v0.0.8

func (this *Controller) DeleteIncidentByProcessInstanceId(token string, id string) (err error, code int)

func (*Controller) FindIncidents

func (this *Controller) FindIncidents(token string, externalTaskId string, processDefinitionId string, processInstanceId string, limit int, offset int, sortBy string, asc bool) (incidents []messages.IncidentMessage, err error, errCode int)

func (*Controller) GetIncident

func (this *Controller) GetIncident(token string, id string) (incident messages.IncidentMessage, err error, errCode int)

func (*Controller) Notify added in v0.0.8

func (this *Controller) Notify(msg notification.Message)

func (*Controller) SetOnIncidentHandler added in v0.0.8

func (this *Controller) SetOnIncidentHandler(token string, handler messages.OnIncident) (err error, code int)

func (*Controller) ValidateIncident added in v0.0.8

func (this *Controller) ValidateIncident(incident messages.Incident) error

type Metric added in v0.0.8

type Metric interface {
	NotifyIncidentMessage()
}

type TopicMutex added in v0.0.8

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

func (*TopicMutex) Lock added in v0.0.8

func (this *TopicMutex) Lock(topic string)

func (*TopicMutex) Unlock added in v0.0.8

func (this *TopicMutex) Unlock(topic string)

Jump to

Keyboard shortcuts

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