controller

package

Go to main page

Versions in this module

v0

v0.0.20

Dec 18, 2024

v0.0.19

Dec 2, 2024

v0.0.18

Sep 6, 2024

v0.0.17

Sep 6, 2024

v0.0.16

Sep 6, 2024

v0.0.15

Aug 23, 2024

v0.0.14

Aug 21, 2024

v0.0.13

Aug 20, 2024

v0.0.12

Aug 20, 2024

Changes in this version

type ReleaseInterface

+ GetMarkedReleases func() (markedAsDeleted []model.SmartServiceReleaseExtended, ...)

+ ListReleases func(options model.ListReleasesOptions) ([]model.SmartServiceReleaseExtended, error)

+ MarkReleaseAsFinished func(id string) (err error)

+ MarlReleaseAsDeleted func(id string) (error, int)

v0.0.11

Jul 9, 2024

v0.0.10

Jul 1, 2024

v0.0.9

May 3, 2024

Changes in this version

type InstanceInterface

+ ListInstancesOfRelease func(userId string, releaseId string) (result []model.SmartServiceInstance, err error, code int)

v0.0.8

Mar 20, 2024

v0.0.7

Mar 20, 2024

v0.0.6

Mar 15, 2024

v0.0.5

Feb 13, 2024

v0.0.4

Feb 12, 2024

v0.0.3

Jan 23, 2024

v0.0.2

Jan 3, 2024

v0.0.1

Dec 19, 2023

Changes in this version

+ const ErrMissingCamundaProcessInstance

+ func FMap3[I1 any, I2 any, I3 any, ResultType any, NewResultType any](f func(in1 I1, in2 I2, in3 I3) (ResultType, error), ...) func(in1 I1, in2 I2, in3 I3) (NewResultType, error)

+ func ListContains[T any](list []T, check func(a T) bool) bool

+ func ListFilter[T any](in []T, filter func(T) bool) (out []T)

+ func ListMap[From any, To any](from []From, converter func(From) To) (to []To)

+ func ValidateDesign(xml string) (err error)

+ type Camunda interface

+ CheckInstanceReady func(smartServiceInstanceId string) (finished bool, missing bool, err error)

+ DeleteInstance func(instance model.HistoricProcessInstance) (err error)

+ DeployRelease func(owner string, release model.SmartServiceReleaseExtended) (err error, isInvalidCamundaDeployment bool)

+ GetProcessInstanceBusinessKey func(processInstanceId string) (string, error, int)

+ GetProcessInstanceList func() (result []model.HistoricProcessInstance, err error)

+ RemoveRelease func(id string) error

+ Start func(result model.SmartServiceInstance) error

+ StartMaintenance func(releaseId string, procedure model.MaintenanceProcedure, id string, ...) error

+ StopInstance func(smartServiceInstanceId string) error

+ type Consumer = func(ctx context.Context, config configuration.Config, topic string, ...) error

+ type Controller struct

+ func New(ctx context.Context, config configuration.Config, db Database, ...) (ctrl *Controller, err error)

+ func (this *Controller) AddModule(token auth.Token, instanceId string, module model.SmartServiceModuleInit) (result model.SmartServiceModule, err error, code int)

+ func (this *Controller) AddModuleForProcessInstance(processInstanceId string, module model.SmartServiceModuleInit) (result model.SmartServiceModule, err error, code int)

+ func (this *Controller) AddModules(token auth.Token, instanceId string, modules []model.SmartServiceModuleInit) (result []model.SmartServiceModule, err error, code int)

+ func (this *Controller) AddModulesForProcessInstance(processInstanceId string, modules []model.SmartServiceModuleInit) (result []model.SmartServiceModule, err error, code int)

+ func (this *Controller) Cleanup(ignoreModuleDeleteError bool) (result []error)

+ func (this *Controller) CreateInstance(token auth.Token, releaseId string, ...) (result model.SmartServiceInstance, err error, code int)

+ func (this *Controller) CreateRelease(token auth.Token, element model.SmartServiceRelease) (result model.SmartServiceRelease, err error, code int)

+ func (this *Controller) DeleteDesign(token auth.Token, id string) (error, int)

+ func (this *Controller) DeleteInstance(token auth.Token, id string, ignoreModuleDeleteError bool) (error, int)

+ func (this *Controller) DeleteModule(token auth.Token, id string, ignoreModuleDeleteError bool) (error, int)

+ func (this *Controller) DeleteRelease(token auth.Token, releaseId string) (error, int)

+ func (this *Controller) DeleteVariable(token auth.Token, instanceId string, name string) (error, int)

+ func (this *Controller) GetCharacteristic(token string, id string) (characteristic *model.Characteristic, err error)

+ func (this *Controller) GetDesign(token auth.Token, id string) (result model.SmartServiceDesign, err error, code int)

+ func (this *Controller) GetExtendedRelease(token auth.Token, id string) (result model.SmartServiceReleaseExtended, err error, code int)

+ func (this *Controller) GetInstance(token auth.Token, id string) (result model.SmartServiceInstance, err error, code int)

+ func (this *Controller) GetInstanceByProcessInstanceId(processInstanceId string) (result model.SmartServiceInstance, err error, code int)

+ func (this *Controller) GetInstanceUserIdByProcessInstanceId(processInstanceId string) (string, error, int)

+ func (this *Controller) GetMaintenanceProcedureOfInstance(token auth.Token, instanceId string, publicEventId string) (maintenanceProcedure model.MaintenanceProcedure, ...)

+ func (this *Controller) GetMaintenanceProcedureParametersOfInstance(token auth.Token, instanceId string, publicEventId string) ([]model.SmartServiceExtendedParameter, error, int)

+ func (this *Controller) GetMaintenanceProceduresOfInstance(token auth.Token, instanceId string) (maintenanceProcedure []model.MaintenanceProcedure, ...)

+ func (this *Controller) GetModule(token auth.Token, id string) (model.SmartServiceModule, error, int)

+ func (this *Controller) GetNewId() string

+ func (this *Controller) GetRelease(token auth.Token, id string) (result model.SmartServiceRelease, err error, code int)

+ func (this *Controller) GetReleaseParameter(token auth.Token, id string) (result []model.SmartServiceExtendedParameter, err error, code int)

+ func (this *Controller) GetReleaseParameterWithoutAuthCheck(token auth.Token, id string) (result []model.SmartServiceExtendedParameter, err error, code int)

+ func (this *Controller) GetVariable(token auth.Token, instanceId string, name string) (model.SmartServiceInstanceVariable, error, int)

+ func (this *Controller) GetVariablesMap(token auth.Token, instanceId string, query model.VariableQueryOptions) (map[string]interface{}, error, int)

+ func (this *Controller) GetVariablesMapOfProcessInstance(processInstanceId string) (map[string]interface{}, error, int)

+ func (this *Controller) HandleRelease(cmd ReleaseCommand) (err error)

+ func (this *Controller) HandleReleaseDelete(userId string, id string) error

+ func (this *Controller) HandleReleaseMessage(delivery []byte) error

+ func (this *Controller) HandleReleaseSave(owner string, release model.SmartServiceReleaseExtended) (err error)

+ func (this *Controller) ListDesigns(token auth.Token, query model.DesignQueryOptions) ([]model.SmartServiceDesign, error, int)

+ func (this *Controller) ListExtendedReleases(token auth.Token, query model.ReleaseQueryOptions) (result []model.SmartServiceReleaseExtended, err error, code int)

+ func (this *Controller) ListInstances(token auth.Token, query model.InstanceQueryOptions) (result []model.SmartServiceInstance, err error, code int)

+ func (this *Controller) ListModules(token auth.Token, query model.ModuleQueryOptions) ([]model.SmartServiceModule, error, int)

+ func (this *Controller) ListModulesOfProcessInstance(processInstanceId string, query model.ModuleQueryOptions) (result []model.SmartServiceModule, err error, code int)

+ func (this *Controller) ListReleases(token auth.Token, query model.ReleaseQueryOptions) (result []model.SmartServiceRelease, err error, code int)

+ func (this *Controller) ListVariables(token auth.Token, instanceId string, query model.VariableQueryOptions) ([]model.SmartServiceInstanceVariable, error, int)

+ func (this *Controller) ListVariablesOfProcessInstance(processInstanceId string, query model.VariableQueryOptions) (result []model.SmartServiceInstanceVariable, err error, code int)

+ func (this *Controller) RedeployInstance(token auth.Token, id string, parameters []model.SmartServiceParameter, ...) (result model.SmartServiceInstance, err error, code int)

+ func (this *Controller) SetDesign(token auth.Token, element model.SmartServiceDesign) (result model.SmartServiceDesign, err error, code int)

+ func (this *Controller) SetInstanceError(token auth.Token, instanceId string, errMsg string) (error, int)

+ func (this *Controller) SetInstanceErrorByProcessInstanceId(processInstanceId string, errMsg string) (error, int)

+ func (this *Controller) SetModuleForProcessInstance(processInstanceId string, module model.SmartServiceModuleInit, moduleId string) (result model.SmartServiceModule, err error, code int)

+ func (this *Controller) SetVariable(token auth.Token, variable model.SmartServiceInstanceVariable) (result model.SmartServiceInstanceVariable, err error, code int)

+ func (this *Controller) SetVariableForProcessInstance(processInstanceId string, element model.SmartServiceInstanceVariable) (result model.SmartServiceInstanceVariable, err error, code int)

+ func (this *Controller) SetVariablesMapOfProcessInstance(processInstanceId string, mappedVariableValues map[string]interface{}) (err error, code int)

+ func (this *Controller) StartMaintenanceProcedure(token auth.Token, instanceId string, publicEventId string, ...) (error, int)

+ func (this *Controller) UpdateInstanceInfo(token auth.Token, id string, element model.SmartServiceInstanceInfo) (result model.SmartServiceInstance, err error, code int)

+ func (this *Controller) ValidateDesign(token auth.Token, element model.SmartServiceDesign) (err error, code int)

+ func (this *Controller) ValidateModule(userId string, element model.SmartServiceModule) (error, int)

+ func (this *Controller) ValidateVariable(element model.SmartServiceInstanceVariable) (error, int)

+ type Database interface

+ type DesignsInterface interface

+ DeleteDesign func(id string, userId string) (error, int)

+ GetDesign func(id string, userId string) (model.SmartServiceDesign, error, int)

+ ListDesigns func(userId string, query model.DesignQueryOptions) ([]model.SmartServiceDesign, error, int)

+ SetDesign func(element model.SmartServiceDesign) (error, int)

+ type GenericProducerFactory func(ctx context.Context, config configuration.Config, topic string) (T, error)

+ type InstanceInterface interface

+ DeleteInstance func(id string, userId string) (error, int)

+ GetInstance func(id string, userId string) (model.SmartServiceInstance, error, int)

+ ListInstances func(userId string, query model.InstanceQueryOptions) (result []model.SmartServiceInstance, err error, code int)

+ SetInstance func(element model.SmartServiceInstance) (error, int)

+ type MaintenanceInterface interface

+ AddToRunningMaintenanceIds func(instanceId string, maintenanceId string) error

+ RemoveFromRunningMaintenanceIds func(instanceId string, removeMaintenanceIds []string) error

+ type ModuleInterface interface

+ DeleteModule func(id string, userId string) (error, int)

+ GetModule func(id string, userId string) (model.SmartServiceModule, error, int)

+ ListAllModules func(query model.ModuleQueryOptions) (result []model.SmartServiceModule, err error, code int)

+ ListModules func(userId string, query model.ModuleQueryOptions) ([]model.SmartServiceModule, error, int)

+ SetInstanceError func(id string, userId string, errMsg string) error

+ SetModule func(element model.SmartServiceModule) (error, int)

+ SetModules func(element []model.SmartServiceModule) (error, int)

+ type PermSearchCharacteristicsWrapper struct

+ Raw model.Characteristic

+ type Permissions interface

+ CheckAccess func(token auth.Token, topic string, id string, right string) (bool, error)

+ GetResourceRights func(token string, topic string, id string) (rights permissions.ResourceRights, err error)

+ Query func(token string, query permissions.QueryMessage, result interface{}) (err error, code int)

+ SetResourceRights func(token string, topic string, id string, rights permissions.ResourceRights, ...) error

+ type Producer interface

+ Produce func(key string, message []byte) error

+ type ProducerFactory = GenericProducerFactory[Producer]

+ func NewProducerFactory[T Producer](f GenericProducerFactory[T]) (result ProducerFactory)

+ type ReleaseCommand struct

+ Command string

+ Id string

+ Owner string

+ Release *model.SmartServiceReleaseExtended

+ type ReleaseInterface interface

+ DeleteRelease func(id string) (error, int)

+ GetRelease func(id string) (model.SmartServiceReleaseExtended, error, int)

+ GetReleaseListByIds func(ids []string, sort string) ([]model.SmartServiceReleaseExtended, error)

+ GetReleasesByDesignId func(designId string) ([]model.SmartServiceReleaseExtended, error)

+ SetRelease func(element model.SmartServiceReleaseExtended) (error, int)

+ SetReleaseError func(id string, errMsg string) error

+ type ReleasePermissionsWrapper struct

+ DesignId string

+ Id string

+ Permissions map[string]bool

+ Shared bool

+ type Selectables interface

+ Get func(token auth.Token, searchedEntities []string, criteria []model.Criteria) (result []model.Selectable, err error, code int)

+ type UserTokenProvider = func(userid string) (token auth.Token, err error)

+ type VariableInterface interface

+ DeleteVariable func(instanceId string, userId string, variableName string) (error, int)

+ GetVariable func(instanceId string, userId string, variableName string) (result model.SmartServiceInstanceVariable, err error, code int)

+ ListAllVariables func(query model.VariableQueryOptions) (result []model.SmartServiceInstanceVariable, err error, code int)

+ ListVariables func(instanceId string, userId string, query model.VariableQueryOptions) (result []model.SmartServiceInstanceVariable, err error, code int)

+ SetVariable func(element model.SmartServiceInstanceVariable) (model.SmartServiceInstanceVariable, error, int)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL