camunda

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)
  • func (this *Camunda) CompleteTask(taskInfo messages.TaskInfo, outputName string, output interface{}) (err error)
  • func (this *Camunda) Error(externalTaskId string, processInstanceId string, processDefinitionId string, ...)
  • func (this *Camunda) GetTasks() (tasks []messages.CamundaExternalTask, err error)
  • func (this *Camunda) GetWorkerId() string
  • func (this *Camunda) SetRetry(taskid string, tenantId string, retries int64)
  • func (this *Camunda) UnlockTask(taskInfo messages.TaskInfo) (err error)
• type FactoryType
  • func (FactoryType) Get(config util.Config, producer com.ProducerInterface, metrics interfaces.Metrics) (interfaces.CamundaInterface, error)
• type Shards

Variables

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

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)

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, msg string, tenantId string)

func (*Camunda) GetTasks

func (this *Camunda) GetTasks() (tasks []messages.CamundaExternalTask, err error)

func (*Camunda) GetWorkerId

func (this *Camunda) GetWorkerId() string

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)
}