mocks

Documentation

Index

• Variables
• type DatabaseMock
  • 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
  • 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, userId string) error
  • func (this *DeviceRepoMock) SetOptions(options []deviceselectionmodel.Selectable)
  • func (this *DeviceRepoMock) SetService(id string, service devicemodel.Service) error
• type ImportsMock
  • 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
  • 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
  • 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
  • func (this *Producer) Produce(key string, message []byte) error

Variables

var Database = &DatabaseMock{
	Deployments:  map[string]messages.DeploymentCommand{},
	Dependencies: map[string]dependencymodel.Dependencies{},
}

var Devices = &DeviceRepoMock{}

var Imports = &ImportsMock{}

var Kafka = &KafkaMock{Produced: map[string][]string{}, Listeners: map[string][]func(msg []byte) error{}}

var ProcessModelRepo = &ProcessModelRepoMock{models: map[string]processmodel.ProcessModel{}}

Types

type DatabaseMock

type DatabaseMock struct {
	Deployments  map[string]messages.DeploymentCommand
	Dependencies map[string]dependencymodel.Dependencies
	// contains filtered or unexported fields
}

func (*DatabaseMock) CheckDeploymentAccess

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

func (*DatabaseMock) DeleteDependencies

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

func (*DatabaseMock) DeleteDeployment

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

func (*DatabaseMock) GetDependencies

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

func (*DatabaseMock) GetDependenciesList

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

func (*DatabaseMock) GetDeployment

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

func (*DatabaseMock) GetDeploymentIds

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

func (*DatabaseMock) GetSelectedDependencies

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

func (*DatabaseMock) New

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

func (*DatabaseMock) SetDependencies

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

func (*DatabaseMock) SetDeployment

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

type DeviceRepoMock

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

func (*DeviceRepoMock) CheckAccess

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

func (*DeviceRepoMock) GetAspectNode

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

func (*DeviceRepoMock) GetBulkDeviceSelection

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

func (*DeviceRepoMock) GetBulkDeviceSelectionV2

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

func (*DeviceRepoMock) GetDevice

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

func (*DeviceRepoMock) GetDeviceGroup

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

func (*DeviceRepoMock) GetDeviceSelection

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

func (*DeviceRepoMock) GetService

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

func (*DeviceRepoMock) New

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

func (*DeviceRepoMock) SetDevice

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

func (*DeviceRepoMock) SetOptions

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

func (*DeviceRepoMock) SetService

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

type ImportsMock

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

func (*ImportsMock) CheckAccess

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

func (*ImportsMock) New

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

func (*ImportsMock) SetImportTypeIds

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

func (*ImportsMock) SetImports

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

type KafkaMock

type KafkaMock struct {
	Produced  map[string][]string
	Listeners map[string][]func(msg []byte) error
	// contains filtered or unexported fields
}

func (*KafkaMock) GetProduced

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

func (*KafkaMock) NewConsumer

func (this *KafkaMock) NewConsumer(ctx context.Context, config config.Config, topic string, listener func(delivery []byte) error) error

func (*KafkaMock) NewProducer

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

type ProcessModelRepoMock

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

func (*ProcessModelRepoMock) GetProcessModel

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

func (*ProcessModelRepoMock) New

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

func (*ProcessModelRepoMock) SetProcessModel

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

type Producer

type Producer struct {
	Topic string
	Kafka *KafkaMock
}

func (*Producer) Produce

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