events

Documentation

Index

• func SecureProcessScripts(xml string) (result string, err error)
• type Events
  • func New(config configuration.Config, cqrs kafka.Interface, vid *vid.Vid, ...) (events *Events, err error)
  • func (this *Events) GetPublisher() kafka.Interface
  • func (this *Events) HandleDeploymentCreate(owner string, id string, name string, xml string, svg string, source string, ...) (err error)
  • func (this *Events) HandleDeploymentDelete(vid string, userId string) error
  • func (this *Events) PublishIncidentDeleteByProcessInstanceEvent(instanceId string, definitionId string) error
  • func (this *Events) PublishIncidentHandling(handing messages.OnIncident) error
  • func (this *Events) PublishIncidentsDeleteByProcessDefinitionEvent(definitionId string) error

Functions

func SecureProcessScripts

func SecureProcessScripts(xml string) (result string, err error)

Types

type Events

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

func New

func New(config configuration.Config, cqrs kafka.Interface, vid *vid.Vid, camunda *camunda.Camunda, processIo *processio.ProcessIo) (events *Events, err error)

func (*Events) GetPublisher

func (this *Events) GetPublisher() kafka.Interface

func (*Events) HandleDeploymentCreate

func (this *Events) HandleDeploymentCreate(owner string, id string, name string, xml string, svg string, source string, incidentHandling *messages.IncidentHandling) (err error)

func (*Events) HandleDeploymentDelete

func (this *Events) HandleDeploymentDelete(vid string, userId string) error

func (*Events) PublishIncidentDeleteByProcessInstanceEvent

func (this *Events) PublishIncidentDeleteByProcessInstanceEvent(instanceId string, definitionId string) error

func (*Events) PublishIncidentHandling

func (this *Events) PublishIncidentHandling(handing messages.OnIncident) error

func (*Events) PublishIncidentsDeleteByProcessDefinitionEvent

func (this *Events) PublishIncidentsDeleteByProcessDefinitionEvent(definitionId string) error