interfaces

Documentation

Index

• type CamundaInterface
• type FactoryInterface
• type Metrics

Types

type CamundaInterface

type CamundaInterface interface {
	ProvideTasks(ctx context.Context) (<-chan []messages.CamundaExternalTask, <-chan error, error)
	CompleteTask(taskInfo messages.TaskInfo, outputName string, output interface{}) (err error)
	SetRetry(taskid string, tenantId string, number int64)
	Error(externalTaskId string, processInstanceId string, processDefinitionId string, msg string, tenantId string)
	GetWorkerId() string
	UnlockTask(taskInfo messages.TaskInfo) (err error)
}

type FactoryInterface

type FactoryInterface interface {
	Get(configType util.Config, producer com.ProducerInterface, metrics Metrics) (CamundaInterface, error)
}

type Metrics

type Metrics interface {
	LogCamundaCompleteTask()
	LogCamundaCompleteTaskError()
	LogIncident()
	LogCamundaLoadedTasks(count int)
	LogCamundaGetShardsError()
	LogCamundaGetTasksError()

	LogTaskMarshallingLatency(requestKind string, userId string, serviceId string, functionId string, latency time.Duration)
	LogTaskReceived(task messages.CamundaExternalTask)
	LogTaskLastEventValueRequest(task messages.GroupTaskMetadataElement)
	LogTaskCommandSend(task messages.GroupTaskMetadataElement)
	LogTaskCommandResponseReceived(task messages.TaskInfo)
	LogTaskCompleted(task messages.TaskInfo)
}