Versions in this module Expand all Collapse all v1 v1.0.3 Apr 18, 2023 v1.0.1 Apr 18, 2023 Changes in this version + type Context struct + Task *camundaclientgo.ResLockedExternalTask + func (c *Context) Complete(query QueryComplete) error + func (c *Context) ExtendLock(newDurationMS int) error + func (c *Context) HandleBPMNError(query QueryHandleBPMNError) error + func (c *Context) HandleFailure(query QueryHandleFailure) error + type Handler func(ctx *Context) error + type Options struct + AsyncResponseTimeout *int + LockDuration time.Duration + LongPollingTimeout time.Duration + MaxParallelTaskPerHandler int + MaxTasks int + UsePriority *bool + WorkerId string + type Processor struct + func NewProcessor(client *camundaclientgo.Client, options *Options, logger func(err error)) *Processor + func (p *Processor) AddHandler(topics []*camundaclientgo.QueryFetchAndLockTopic, handler Handler) + func (p *Processor) Shutdown() + type QueryComplete struct + LocalVariables *map[string]camunda_client_go.Variable + Variables *map[string]camunda_client_go.Variable + type QueryHandleBPMNError struct + ErrorCode *string + ErrorMessage *string + Variables *map[string]camunda_client_go.Variable + type QueryHandleFailure struct + ErrorDetails *string + ErrorMessage *string + Retries *int + RetryTimeout *int