processor

Oct 7, 2022

Changes in this version

type Context

+ func (c *Context) ExtendLock(newDurationMS int) error

Jun 8, 2022

Changes in this version

type Processor

+ func (p *Processor) Shutdown()

Apr 17, 2022

Changes in this version

+ type Context struct

+ Task *camundaclientgo.ResLockedExternalTask

+ func (c *Context) Complete(query QueryComplete) 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)

+ 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