camunda

package

v0.0.41 Latest Latest Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation ¶

Index ¶

Variables
type Camunda
- func NewCamunda(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics) (result *Camunda, err error)
- func NewCamundaWithShards(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics, ...) (result *Camunda, err error)
type FactoryType
- func (FactoryType) Get(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics) (interfaces.CamundaInterface, error)
type Shards
type TopicMutex
- func (this *TopicMutex) Lock(topic string)
- func (this *TopicMutex) Unlock(topic string)

Constants ¶

This section is empty.

Variables ¶

View Source

var UnableToCompleteErrResp = errors.New("unable to complete task")

Functions ¶

This section is empty.

Types ¶

type Camunda ¶

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

func NewCamunda ¶

func NewCamunda(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics) (result *Camunda, err error)

func NewCamundaWithShards ¶

func NewCamundaWithShards(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics, shards Shards) (result *Camunda, err error)

func (*Camunda) CompleteTask ¶

func (this *Camunda) CompleteTask(taskInfo messages.TaskInfo, outputName string, output interface{}) (err error)

func (*Camunda) Error ¶

func (this *Camunda) Error(externalTaskId string, processInstanceId string, processDefinitionId string, businessKey string, msg string, tenantId string)

func (*Camunda) GetWorkerId ¶

func (this *Camunda) GetWorkerId() string

func (*Camunda) ProvideTasks ¶ added in v0.0.29

func (this *Camunda) ProvideTasks(ctx context.Context) (<-chan []messages.CamundaExternalTask, <-chan error, error)

func (*Camunda) SetRetry ¶

func (this *Camunda) SetRetry(taskid string, tenantId string, retries int64)

func (*Camunda) UnlockTask ¶

func (this *Camunda) UnlockTask(taskInfo messages.TaskInfo) (err error)

type FactoryType ¶

type FactoryType struct{}

var Factory FactoryType

func (FactoryType) Get ¶

func (FactoryType) Get(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics) (interfaces.CamundaInterface, error)

type Shards ¶

type Shards interface {
	GetShards() (result []string, err error)
	GetShardForUser(userId string) (shardUrl string, err error)
}

type TopicMutex ¶ added in v0.0.33

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

func (*TopicMutex) Lock ¶ added in v0.0.33

func (this *TopicMutex) Lock(topic string)

func (*TopicMutex) Unlock ¶ added in v0.0.33

func (this *TopicMutex) Unlock(topic string)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
interfaces
shards

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL