Documentation
¶
Index ¶
- type Controller
- func (this *Controller) CreateIncident(incident messages.Incident) (err error)
- func (this *Controller) DeleteIncidentByProcessDefinitionId(id string) error
- func (this *Controller) DeleteIncidentByProcessInstanceId(id string) error
- func (this *Controller) HandleIncidentMessage(msg []byte) error
- func (this *Controller) Notify(msg notification.Message)
- func (this *Controller) SetOnIncidentHandler(handler messages.OnIncident) error
- type Metric
- type MsgVersionWrapper
- type TopicMutex
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, camunda interfaces.Camunda, db interfaces.Database, m Metric) (ctrl *Controller, err error)
func (*Controller) CreateIncident ¶
func (this *Controller) CreateIncident(incident messages.Incident) (err error)
func (*Controller) DeleteIncidentByProcessDefinitionId ¶
func (this *Controller) DeleteIncidentByProcessDefinitionId(id string) error
func (*Controller) DeleteIncidentByProcessInstanceId ¶
func (this *Controller) DeleteIncidentByProcessInstanceId(id string) error
func (*Controller) HandleIncidentMessage ¶
func (this *Controller) HandleIncidentMessage(msg []byte) error
func (*Controller) Notify ¶ added in v0.0.3
func (this *Controller) Notify(msg notification.Message)
func (*Controller) SetOnIncidentHandler ¶
func (this *Controller) SetOnIncidentHandler(handler messages.OnIncident) error
type MsgVersionWrapper ¶
type MsgVersionWrapper struct {
MsgVersion int64 `json:"msg_version"`
}
type TopicMutex ¶ added in v0.0.9
type TopicMutex struct {
// contains filtered or unexported fields
}
func (*TopicMutex) Lock ¶ added in v0.0.9
func (this *TopicMutex) Lock(topic string)
func (*TopicMutex) Unlock ¶ added in v0.0.9
func (this *TopicMutex) Unlock(topic string)
Source Files
Click to show internal directories.
Click to hide internal directories.