worker

Documentation

Index

• Constants
• func StartDoneEventHandling(ctx context.Context, wg *sync.WaitGroup, config Config, ...) error
• type Config
• type DeviceGroupHelperResult
• type DoneNotification
• type ProcessDeploymentStart
  • 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

Constants

const DeviceGroupIdOutputFieldName = "device_group_id"

const DeviceIdPrefix = devicemodel.URN_PREFIX + "device:"

const ModuleUpdateVersionField = "module_update_version"

Functions

func StartDoneEventHandling

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

Types

type Config

type Config struct {
	DeviceManagerUrl            string `json:"device_manager_url"`
	DeviceSelectionUrl          string `json:"device_selection_url"`
	WorkerParamPrefix           string `json:"worker_param_prefix"`
	CreateDeviceGroupModuleType string `json:"create_device_group_module_type"`
	DefaultNamePrefix           string `json:"default_name_prefix"`
	AttributeOrigin             string `json:"attribute_origin"`
	Debug                       bool   `json:"debug"`

	KafkaUrl             string `json:"kafka_url"`
	KafkaConsumerGroup   string `json:"kafka_consumer_group"`
	PermissionsDoneTopic string `json:"permissions_done_topic"`
}

type DeviceGroupHelperResult

type DeviceGroupHelperResult struct {
	Criteria []devicemodel.DeviceGroupFilterCriteria `json:"criteria"`
}

type DoneNotification

type DoneNotification struct {
	ResourceKind string `json:"resource_kind"`
	ResourceId   string `json:"resource_id"`
	Handler      string `json:"handler"` // == github.com/SENERGY-Platform/permission-search
	Command      string `json:"command"` // PUT | DELETE | RIGHTS
}

type ProcessDeploymentStart

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config Config, libConfig configuration.Config, auth *auth.Auth, smartServiceRepo SmartServiceRepo) (*ProcessDeploymentStart, error)

func (*ProcessDeploymentStart) Do

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

func (*ProcessDeploymentStart) Undo

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

type SmartServiceRepo

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