worker

Dec 19, 2023

Changes in this version

+ const DeviceGroupIdOutputFieldName

+ const DeviceIdPrefix

+ const ModuleUpdateVersionField

+ func StartDoneEventHandling(ctx context.Context, wg *sync.WaitGroup, config Config, ...) error

+ type Config struct

+ AttributeOrigin string

+ CreateDeviceGroupModuleType string

+ Debug bool

+ DefaultNamePrefix string

+ DeviceManagerUrl string

+ DeviceSelectionUrl string

+ KafkaConsumerGroup string

+ KafkaUrl string

+ PermissionsDoneTopic string

+ WorkerParamPrefix string

+ type DeviceGroupHelperResult struct

+ Criteria []devicemodel.DeviceGroupFilterCriteria

+ type DoneNotification struct

+ Command string

+ Handler string

+ ResourceId string

+ ResourceKind string

+ type ProcessDeploymentStart struct

+ func New(ctx context.Context, wg *sync.WaitGroup, config Config, ...) (*ProcessDeploymentStart, error)

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

+ func (this *ProcessDeploymentStart) Undo(modules []model.Module, reason error)

+ type SmartServiceRepo interface

+ GetInstanceUser func(instanceId string) (userId string, err error)

+ ListExistingModules func(processInstanceId string, query model.ModulQuery) (result []model.SmartServiceModule, err error)

+ UseModuleDeleteInfo func(info model.ModuleDeleteInfo) error