worker

type Context interface {
	Complete(tc *TaskComplete) error
	HandleFailure(query TaskFailureRequest) error
	HandleBPMNError(code int, message string) error
	ExtendLock(id string, duration int) error
	Variables() camunda.Variables
	StartLockExtender()
	StopExtender()
	TaskID() string
	TopicName() string
	Retries() int
}

type ContextImpl struct {
	Task *camunda.ResLockedExternalTask
	// contains filtered or unexported fields
}

type Handler func(ctx Context) error

type Options struct {
	// WorkerID for all request (default: `worker-{random_int}`)
	WorkerID string `json:"workerId"`
	// LockDuration lock duration for all external task
	LockDuration time.Duration
	// MaxTasks maximum tasks to receive for 1 request to camunda
	MaxTasks int
	// MaxParallelTaskPerHandler maximum running parallel task per handler
	MaxParallelTaskPerHandler int
	// UsePriority use priority
	UsePriority *bool
	// LongPollingTimeout long polling timeout
	LongPollingTimeout time.Duration
}

type TaskComplete struct {
	// A JSON object containing variable key-value pairs
	Variables camunda.Variables `json:"variables"`
	// A JSON object containing variable key-value pairs.
	// Local variables are set only in the scope of external task
	LocalVariables camunda.Variables `json:"localVariables"`
}

type TaskFailureRequest struct {
	// An message indicating the reason of the failure
	ErrorMessage string `json:"errorMessage,omitempty"`
	// A detailed error description
	ErrorDetails string `json:"errorDetails,omitempty"`
	// A number of how often the task should be retried.
	// Must be >= 0. If this is 0, an incident is created and the task cannot be fetched anymore unless
	// the retries are increased again. The incident's message is set to the errorMessage parameter
	Retries int `json:"retries,omitempty"`
	// A timeout in milliseconds before the external task becomes available again for fetching. Must be >= 0
	RetryTimeout int `json:"retryTimeout,omitempty"`
}

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