camunda

Documentation

Index

• func SendEventTrigger(config configuration.Config, eventId string, ...) (err error)
• func Start(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, ...)
• type Camunda
  • func New(config configuration.Config, smartServiceRepo SmartServiceRepository, ...) *Camunda
  • func (this *Camunda) Start(ctx context.Context, wg *sync.WaitGroup)
• type Handler
• type SmartServiceRepository

Functions

func SendEventTrigger

func SendEventTrigger(config configuration.Config, eventId string, variables map[string]model.CamundaVariable) (err error)

func Start

func Start(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, smartServiceRepo SmartServiceRepository, handler Handler)

Types

type Camunda

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

func New

func New(config configuration.Config, smartServiceRepo SmartServiceRepository, handler Handler) *Camunda

func (*Camunda) Start

func (this *Camunda) Start(ctx context.Context, wg *sync.WaitGroup)

type Handler

type Handler interface {
	Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)
	Undo(modules []model.Module, reason error)
}

type SmartServiceRepository

type SmartServiceRepository interface {
	SendWorkerError(task model.CamundaExternalTask, err error) error
	SendWorkerModules(modules []model.Module) (result []model.SmartServiceModule, err error)
}