mocks

package

v0.0.5 Latest Latest Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/SENERGY-Platform/process-deployment

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type DatabaseMock
type DeviceRepoMock
type ImportsMock
type KafkaMock
type ProcessModelRepoMock
type Producer
- func (this *Producer) Produce(key string, message []byte) error

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

var Devices = &DeviceRepoMock{devices: map[string]devicemodel.Device{}, services: map[string]devicemodel.Service{}}

View Source

var Imports = &ImportsMock{}

View Source

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

View Source

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

Functions ¶

This section is empty.

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)

func (*DeviceRepoMock) SetOptions ¶

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

func (*DeviceRepoMock) SetService ¶

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

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

Source Files ¶

View all Source files

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