mocks

Dec 19, 2023

Changes in this version

+ var Database = &DatabaseMock

+ var Devices = &DeviceRepoMock

+ var Imports = &ImportsMock

+ var Kafka = &KafkaMock

+ var ProcessModelRepo = &ProcessModelRepoMock

+ type DatabaseMock struct

+ Dependencies map[string]dependencymodel.Dependencies

+ Deployments map[string]messages.DeploymentCommand

+ func (this *DatabaseMock) CheckDeploymentAccess(user string, deploymentId string) (error, int)

+ func (this *DatabaseMock) DeleteDependencies(id string) error

+ func (this *DatabaseMock) DeleteDeployment(id string) error

+ func (this *DatabaseMock) GetDependencies(user string, deploymentId string) (dependencymodel.Dependencies, error, int)

+ func (this *DatabaseMock) GetDependenciesList(user string, limit int, offset int) (result []dependencymodel.Dependencies, err error, code int)

+ func (this *DatabaseMock) GetDeployment(user string, deploymentId string) (deployment *deploymentmodel.Deployment, err error, code int)

+ func (this *DatabaseMock) GetDeploymentIds(user string) (deployments []string, err error)

+ func (this *DatabaseMock) GetSelectedDependencies(user string, ids []string) (result []dependencymodel.Dependencies, err error, code int)

+ func (this *DatabaseMock) New(ctx context.Context, config config.Config) (interfaces.Database, error)

+ func (this *DatabaseMock) SetDependencies(dependencies dependencymodel.Dependencies) error

+ func (this *DatabaseMock) SetDeployment(id string, owner string, deployment *deploymentmodel.Deployment) error

+ type DeviceRepoMock struct

+ func (this *DeviceRepoMock) CheckAccess(token auth.Token, kind string, ids []string) (map[string]bool, error)

+ func (this *DeviceRepoMock) GetAspectNode(token auth.Token, id string) (aspectNode devicemodel.AspectNode, err error)

+ func (this *DeviceRepoMock) GetBulkDeviceSelection(token auth.Token, bulk deviceselectionmodel.BulkRequest) (result deviceselectionmodel.BulkResult, err error, code int)

+ func (this *DeviceRepoMock) GetBulkDeviceSelectionV2(token auth.Token, bulk deviceselectionmodel.BulkRequestV2) (result deviceselectionmodel.BulkResult, err error, code int)

+ func (this *DeviceRepoMock) GetDevice(token auth.Token, id string) (devicemodel.Device, error, int)

+ func (this *DeviceRepoMock) GetDeviceGroup(token auth.Token, id string) (result devicemodel.DeviceGroup, err error, code int)

+ func (this *DeviceRepoMock) GetDeviceSelection(token auth.Token, descriptions deviceselectionmodel.FilterCriteriaAndSet, ...) (result []deviceselectionmodel.Selectable, err error, code int)

+ func (this *DeviceRepoMock) GetService(token auth.Token, id string) (devicemodel.Service, error, int)

+ func (this *DeviceRepoMock) New(ctx context.Context, config config.Config) (interfaces.Devices, error)

+ func (this *DeviceRepoMock) SetDevice(id string, device devicemodel.Device)

+ func (this *DeviceRepoMock) SetOptions(options []deviceselectionmodel.Selectable)

+ func (this *DeviceRepoMock) SetService(id string, service devicemodel.Service)

+ type ImportsMock struct

+ func (this *ImportsMock) CheckAccess(_ auth.Token, ids []string, alsoCheckTypes bool) (b bool, err error)

+ func (this *ImportsMock) New(_ config.Config) (interfaces.Imports, error)

+ func (this *ImportsMock) SetImportTypeIds(importTypeIds []string)

+ func (this *ImportsMock) SetImports(imports []importmodel.Import)

+ type KafkaMock struct

+ Listeners map[string][]func(msg []byte) error

+ Produced map[string][]string

+ func (this *KafkaMock) GetProduced(topic string) []string

+ func (this *KafkaMock) NewConsumer(ctx context.Context, config config.Config, topic string, ...) error

+ func (this *KafkaMock) NewProducer(ctx context.Context, config config.Config, topic string) (interfaces.Producer, error)

+ type ProcessModelRepoMock struct

+ func (this *ProcessModelRepoMock) GetProcessModel(impersonate auth.Token, id string) (result processmodel.ProcessModel, err error, errCode int)

+ func (this *ProcessModelRepoMock) New(ctx context.Context, config config.Config) (interfaces.ProcessRepo, error)

+ func (this *ProcessModelRepoMock) SetProcessModel(id string, processmodel processmodel.ProcessModel)

+ type Producer struct

+ Kafka *KafkaMock

+ Topic string

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