worker

Documentation

Index

• Variables
• type Criteria
• type Interaction
• type SmartServiceParameter
• type SmartServiceParameters
• type SmartServiceRepo
• type Worker
  • func New(config configuration.Config, libConfig libconfiguration.Config, ...) (*Worker, error)
  • func (this *Worker) Do(task lib_model.CamundaExternalTask) (modules []lib_model.Module, outputs map[string]interface{}, err error)
  • func (this *Worker) Undo(modules []lib_model.Module, reason error)

Variables

var MissingVariableUsage = errors.New("missing variable")

Types

type Criteria

type Criteria struct {
	Interaction   *Interaction `json:"interaction" bson:"interaction"`
	FunctionId    *string      `json:"function_id" bson:"function_id"`
	DeviceClassId *string      `json:"device_class_id" bson:"device_class_id"`
	AspectId      *string      `json:"aspect_id" bson:"aspect_id"`
}

type Interaction

type Interaction string

const (
	EVENT             Interaction = "event"
	REQUEST           Interaction = "request"
	EVENT_AND_REQUEST Interaction = "event+request"
)

type SmartServiceParameter

type SmartServiceParameter struct {
	Id         string      `json:"id"`
	Value      interface{} `json:"value"`
	Label      string      `json:"label"`
	ValueLabel string      `json:"value_label,omitempty"`
}

type SmartServiceParameters

type SmartServiceParameters []SmartServiceParameter

type SmartServiceRepo

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	UseModuleDeleteInfo(info lib_model.ModuleDeleteInfo) error
	ListExistingModules(processInstanceId string, query lib_model.ModulQuery) (result []lib_model.SmartServiceModule, err error)
	GetSmartServiceInstance(processInstanceId string) (result lib_model.SmartServiceInstance, err error)
}

type Worker

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

func New

func New(config configuration.Config, libConfig libconfiguration.Config, auth *auth.Auth, smartServiceRepo SmartServiceRepo, w *watcher.Watcher) (*Worker, error)

func (*Worker) Do

func (this *Worker) Do(task lib_model.CamundaExternalTask) (modules []lib_model.Module, outputs map[string]interface{}, err error)

func (*Worker) Undo

func (this *Worker) Undo(modules []lib_model.Module, reason error)