interfaces

Documentation

Index

• type Database
• type DatabaseFactory
• type DeploymentParser
• type DeploymentStringifier
• type Devices
• type DevicesFactory
• type Imports
• type ImportsFactory
• type ProcessRepo
• type ProcessRepoFactory
• type Producer
• type SourcingFactory

Types

type Database

type Database interface {
	CheckDeploymentAccess(user string, deploymentId string) (error, int)
	DeleteDeployment(id string) error
	GetDeployment(user string, deploymentId string) (deployment *deploymentmodel.Deployment, err error, code int)
	SetDeployment(id string, owner string, deploymentV1 *deploymentmodel.Deployment) error
	GetDeploymentIds(user string) (deployments []string, err error)
	GetDependencies(user string, deploymentId string) (dependencymodel.Dependencies, error, int)
	GetDependenciesList(user string, limit int, offset int) ([]dependencymodel.Dependencies, error, int)
	GetSelectedDependencies(user string, ids []string) ([]dependencymodel.Dependencies, error, int)
	SetDependencies(dependencies dependencymodel.Dependencies) error
	DeleteDependencies(id string) error
}

type DatabaseFactory

type DatabaseFactory interface {
	New(ctx context.Context, config config.Config) (Database, error)
}

type DeploymentParser

type DeploymentParser interface {
	PrepareDeployment(xml string) (deploymentmodel.Deployment, error)
	EstimateStartParameter(xml string) ([]deploymentmodel.ProcessStartParameter, error)
}

type DeploymentStringifier

type DeploymentStringifier interface {
	Deployment(deployment deploymentmodel.Deployment, userId string, token auth.Token) (string, error)
}

type Devices

type Devices interface {
	GetDevice(token auth.Token, id string) (devicemodel.Device, error, int)
	GetService(token auth.Token, id string) (devicemodel.Service, error, int)
	GetDeviceGroup(token auth.Token, id string) (result devicemodel.DeviceGroup, err error, code int)
	CheckAccess(token auth.Token, kind string, ids []string) (map[string]bool, error)
	GetDeviceSelection(token auth.Token, descriptions deviceselectionmodel.FilterCriteriaAndSet, filterByInteraction devicemodel.Interaction) (result []deviceselectionmodel.Selectable, err error, code int)
	GetBulkDeviceSelection(token auth.Token, bulk deviceselectionmodel.BulkRequest) (result deviceselectionmodel.BulkResult, err error, code int)
	GetBulkDeviceSelectionV2(token auth.Token, bulk deviceselectionmodel.BulkRequestV2) (result deviceselectionmodel.BulkResult, err error, code int)
	GetAspectNode(token auth.Token, id string) (aspectNode devicemodel.AspectNode, err error)
}

type DevicesFactory

type DevicesFactory interface {
	New(ctx context.Context, config config.Config) (Devices, error)
}

type Imports

type Imports interface {
	CheckAccess(token auth.Token, ids []string, alsoCheckTypes bool) (bool, error)
}

type ImportsFactory

type ImportsFactory interface {
	New(config config.Config) (Imports, error)
}

type ProcessRepo

type ProcessRepo interface {
	GetProcessModel(impersonate auth.Token, id string) (result processmodel.ProcessModel, err error, errCode int)
}

type ProcessRepoFactory

type ProcessRepoFactory interface {
	New(ctx context.Context, config config.Config) (ProcessRepo, error)
}

type Producer

type Producer interface {
	Produce(key string, message []byte) error
}

type SourcingFactory

type SourcingFactory interface {
	NewConsumer(ctx context.Context, config config.Config, topic string, listener func(delivery []byte) error) error
	NewProducer(ctx context.Context, config config.Config, topic string) (Producer, error)
}