testdb

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = errors.New("not found")
View Source 
var PermissionCheckFailed = errors.New("permission check failed")

Functions

func NewTestDB 

func NewTestDB(config config.Config) database.Database

Types

type DB 

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

func (*DB) AddAspectNode 

func (db *DB) AddAspectNode(_ context.Context, node models.AspectNode) error

func (*DB) AspectIsUsed 

func (db *DB) AspectIsUsed(ctx context.Context, id string) (result bool, where []string, err error)

func (*DB) CharacteristicIsUsed 

func (db *DB) CharacteristicIsUsed(ctx context.Context, id string) (result bool, where []string, err error)

func (*DB) CharacteristicIsUsedWithConceptInDeviceType 

func (db *DB) CharacteristicIsUsedWithConceptInDeviceType(ctx context.Context, characteristicId string, conceptId string) (result bool, where []string, err error)

func (*DB) CheckBool added in v0.0.12 

func (this *DB) CheckBool(token string, kind string, id string, action model.AuthAction) (allowed bool, err error)

func (*DB) CheckMultiple added in v0.0.12 

func (this *DB) CheckMultiple(token string, kind string, ids []string, action model.AuthAction) (result map[string]bool, err error)

func (*DB) ConceptIsUsed 

func (db *DB) ConceptIsUsed(ctx context.Context, id string) (result bool, where []string, err error)

func (*DB) DeviceClassIsUsed 

func (db *DB) DeviceClassIsUsed(ctx context.Context, id string) (result bool, where []string, err error)

func (*DB) Disconnect 

func (db *DB) Disconnect()

func (*DB) EnsureInitialRights added in v0.0.12 

func (this *DB) EnsureInitialRights(resourceKind string, resourceId string, owner string) error

func (*DB) FunctionIsUsed 

func (db *DB) FunctionIsUsed(ctx context.Context, id string) (result bool, where []string, err error)

func (*DB) GetAdminUsers added in v0.0.18 

func (this *DB) GetAdminUsers(token string, topic string, resourceId string) (admins []string, err error)

func (*DB) GetAspect 

func (db *DB) GetAspect(_ context.Context, id string) (result models.Aspect, exists bool, err error)

func (*DB) GetAspectNode 

func (db *DB) GetAspectNode(_ context.Context, id string) (result models.AspectNode, exists bool, err error)

func (*DB) GetCharacteristic 

func (db *DB) GetCharacteristic(_ context.Context, id string) (result models.Characteristic, exists bool, err error)

func (*DB) GetConceptWithCharacteristics 

func (db *DB) GetConceptWithCharacteristics(_ context.Context, id string) (result models.ConceptWithCharacteristics, exists bool, err error)

func (*DB) GetConceptWithoutCharacteristics 

func (db *DB) GetConceptWithoutCharacteristics(_ context.Context, id string) (result models.Concept, exists bool, err error)

func (*DB) GetConfigurableCandidates 

func (db *DB) GetConfigurableCandidates(_ context.Context, serviceId string) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDevice 

func (db *DB) GetDevice(_ context.Context, id string) (device model.DeviceWithConnectionState, exists bool, err error)

func (*DB) GetDeviceByLocalId 

func (db *DB) GetDeviceByLocalId(_ context.Context, ownerId string, localId string) (device model.DeviceWithConnectionState, exists bool, err error)

func (*DB) GetDeviceClass 

func (db *DB) GetDeviceClass(_ context.Context, id string) (result models.DeviceClass, exists bool, err error)

func (*DB) GetDeviceGroup 

func (db *DB) GetDeviceGroup(_ context.Context, id string) (deviceGroup models.DeviceGroup, exists bool, err error)

func (*DB) GetDeviceType 

func (db *DB) GetDeviceType(_ context.Context, id string) (deviceType models.DeviceType, exists bool, err error)

func (*DB) GetDeviceTypeCriteriaByAspectIds added in v0.0.6 

func (db *DB) GetDeviceTypeCriteriaByAspectIds(ctx context.Context, ids []string, includeModified bool) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDeviceTypeCriteriaByCharacteristicIds added in v0.0.6 

func (db *DB) GetDeviceTypeCriteriaByCharacteristicIds(ctx context.Context, ids []string, includeModified bool) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDeviceTypeCriteriaByDeviceClassIds added in v0.0.6 

func (db *DB) GetDeviceTypeCriteriaByDeviceClassIds(ctx context.Context, ids []string, includeModified bool) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDeviceTypeCriteriaByFunctionIds added in v0.0.6 

func (db *DB) GetDeviceTypeCriteriaByFunctionIds(ctx context.Context, ids []string, includeModified bool) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDeviceTypeCriteriaForDeviceTypeIdsAndFilterCriteria 

func (db *DB) GetDeviceTypeCriteriaForDeviceTypeIdsAndFilterCriteria(ctx context.Context, deviceTypeIds []interface{}, criteria model.FilterCriteria, includeModified bool) (result []model.DeviceTypeCriteria, err error)

func (*DB) GetDeviceTypeIdsByFilterCriteria 

func (db *DB) GetDeviceTypeIdsByFilterCriteria(ctx context.Context, criteria []model.FilterCriteria, interactionsFilter []string, includeModified bool) (result []interface{}, err error)

func (*DB) GetDeviceTypeIdsByFilterCriteriaV2 

func (db *DB) GetDeviceTypeIdsByFilterCriteriaV2(ctx context.Context, criteria []model.FilterCriteria, includeModified bool) (result []interface{}, err error)

func (*DB) GetDeviceTypesByServiceId 

func (db *DB) GetDeviceTypesByServiceId(_ context.Context, serviceId string) (result []models.DeviceType, err error)

func (*DB) GetFunction 

func (db *DB) GetFunction(_ context.Context, id string) (result models.Function, exists bool, err error)

func (*DB) GetHub 

func (db *DB) GetHub(_ context.Context, id string) (hub model.HubWithConnectionState, exists bool, err error)

func (*DB) GetHubsByDeviceId added in v0.0.20 

func (db *DB) GetHubsByDeviceId(_ context.Context, id string) (hubs []model.HubWithConnectionState, err error)

func (*DB) GetLocation 

func (db *DB) GetLocation(_ context.Context, id string) (result models.Location, exists bool, err error)

func (*DB) GetPermissionsInfo added in v0.1.0 

func (this *DB) GetPermissionsInfo(token string, kind string, id string) (requestingUser string, permissions models.Permissions, err error)

func (*DB) GetProtocol 

func (db *DB) GetProtocol(_ context.Context, id string) (result models.Protocol, exists bool, err error)

func (*DB) ListAccessibleResourceIds added in v0.0.20 

func (this *DB) ListAccessibleResourceIds(token string, topic string, limit int64, offset int64, action model.AuthAction) (result []string, err error)

func (*DB) ListAllAspectNodes 

func (db *DB) ListAllAspectNodes(_ context.Context) ([]models.AspectNode, error)

func (*DB) ListAllAspects 

func (db *DB) ListAllAspects(_ context.Context) ([]models.Aspect, error)

func (*DB) ListAllCharacteristics 

func (db *DB) ListAllCharacteristics(_ context.Context) ([]models.Characteristic, error)

func (*DB) ListAllControllingFunctionsByDeviceClass 

func (db *DB) ListAllControllingFunctionsByDeviceClass(_ context.Context, class string) ([]models.Function, error)

func (*DB) ListAllDeviceClasses 

func (db *DB) ListAllDeviceClasses(_ context.Context) ([]models.DeviceClass, error)

func (*DB) ListAllDeviceClassesUsedWithControllingFunctions 

func (db *DB) ListAllDeviceClassesUsedWithControllingFunctions(_ context.Context) ([]models.DeviceClass, error)

func (*DB) ListAllFunctionsByDeviceClass 

func (db *DB) ListAllFunctionsByDeviceClass(_ context.Context, class string) ([]models.Function, error)

func (*DB) ListAllFunctionsByType 

func (db *DB) ListAllFunctionsByType(_ context.Context, rdfType string) (result []models.Function, err error)

func (*DB) ListAllMeasuringFunctionsByAspect 

func (db *DB) ListAllMeasuringFunctionsByAspect(_ context.Context, aspect string, ancestors bool, descendants bool) ([]models.Function, error)

func (*DB) ListAspectNodesByIdList 

func (db *DB) ListAspectNodesByIdList(_ context.Context, ids []string) (result []models.AspectNode, err error)

func (*DB) ListAspectNodesWithMeasuringFunction 

func (db *DB) ListAspectNodesWithMeasuringFunction(_ context.Context, ancestors bool, descendants bool) ([]models.AspectNode, error)

func (*DB) ListAspectsWithMeasuringFunction 

func (db *DB) ListAspectsWithMeasuringFunction(_ context.Context, ancestors bool, descendants bool) ([]models.Aspect, error)

func (*DB) ListDeviceGroups 

func (db *DB) ListDeviceGroups(_ context.Context, limit int64, offset int64, sort string) (result []models.DeviceGroup, err error)

func (*DB) ListDeviceTypes 

func (db *DB) ListDeviceTypes(ctx context.Context, limit int64, offset int64, sort string, filter []model.FilterCriteria, interactionsFilter []string, includeModified bool) (result []models.DeviceType, err error)

func (*DB) ListDeviceTypesV2 

func (db *DB) ListDeviceTypesV2(ctx context.Context, limit int64, offset int64, sort string, filter []model.FilterCriteria, includeModified bool) (result []models.DeviceType, err error)

func (*DB) ListDevices added in v0.1.0 

func (db *DB) ListDevices(ctx context.Context, options model.DeviceListOptions) (devices []model.DeviceWithConnectionState, err error)

func (*DB) ListHubs added in v0.1.0 

func (db *DB) ListHubs(ctx context.Context, options model.HubListOptions) (hubs []model.HubWithConnectionState, err error)

func (*DB) ListProtocols 

func (db *DB) ListProtocols(_ context.Context, limit int64, offset int64, sort string) ([]models.Protocol, error)

func (*DB) RemoveAspect 

func (db *DB) RemoveAspect(_ context.Context, id string) error

func (*DB) RemoveAspectNodesByRootId 

func (db *DB) RemoveAspectNodesByRootId(_ context.Context, id string) error

func (*DB) RemoveCharacteristic 

func (db *DB) RemoveCharacteristic(_ context.Context, id string) error

func (*DB) RemoveConcept 

func (db *DB) RemoveConcept(_ context.Context, id string) error

func (*DB) RemoveDevice 

func (db *DB) RemoveDevice(_ context.Context, id string) error

func (*DB) RemoveDeviceClass 

func (db *DB) RemoveDeviceClass(_ context.Context, id string) error

func (*DB) RemoveDeviceGroup 

func (db *DB) RemoveDeviceGroup(_ context.Context, id string) error

func (*DB) RemoveDeviceType 

func (db *DB) RemoveDeviceType(_ context.Context, id string) error

func (*DB) RemoveFunction 

func (db *DB) RemoveFunction(_ context.Context, id string) error

func (*DB) RemoveHub 

func (db *DB) RemoveHub(_ context.Context, id string) error

func (*DB) RemoveLocation 

func (db *DB) RemoveLocation(_ context.Context, id string) error

func (*DB) RemoveProtocol 

func (db *DB) RemoveProtocol(_ context.Context, id string) error

func (*DB) RemoveRights added in v0.0.12 

func (this *DB) RemoveRights(topic string, id string) error

func (*DB) RunStartupMigrations added in v0.0.15 

func (db *DB) RunStartupMigrations(producer model.MigrationPublisher) error

func (*DB) SetAspect 

func (db *DB) SetAspect(_ context.Context, aspect models.Aspect) error

func (*DB) SetAspectNode 

func (db *DB) SetAspectNode(_ context.Context, node models.AspectNode) error

func (*DB) SetCharacteristic 

func (db *DB) SetCharacteristic(_ context.Context, characteristic models.Characteristic) error

func (*DB) SetConcept 

func (db *DB) SetConcept(_ context.Context, concept models.Concept) error

func (*DB) SetDevice 

func (db *DB) SetDevice(_ context.Context, device model.DeviceWithConnectionState) error

func (*DB) SetDeviceClass 

func (db *DB) SetDeviceClass(_ context.Context, class models.DeviceClass) error

func (*DB) SetDeviceConnectionState added in v0.1.0 

func (db *DB) SetDeviceConnectionState(ctx context.Context, id string, state models.ConnectionState) error

func (*DB) SetDeviceGroup 

func (db *DB) SetDeviceGroup(_ context.Context, deviceGroup models.DeviceGroup) error

func (*DB) SetDeviceType 

func (db *DB) SetDeviceType(_ context.Context, deviceType models.DeviceType) error

func (*DB) SetFunction 

func (db *DB) SetFunction(_ context.Context, function models.Function) error

func (*DB) SetHub 

func (db *DB) SetHub(_ context.Context, hub model.HubWithConnectionState) error

func (*DB) SetHubConnectionState added in v0.1.0 

func (db *DB) SetHubConnectionState(ctx context.Context, id string, state models.ConnectionState) error

func (*DB) SetLocation 

func (db *DB) SetLocation(_ context.Context, location models.Location) error

func (*DB) SetProtocol 

func (db *DB) SetProtocol(_ context.Context, protocol models.Protocol) error

func (*DB) SetRights added in v0.0.12 

func (this *DB) SetRights(resourceKind string, resourceId string, rights model.ResourceRights) error

type GetOptions added in v0.0.20 

type GetOptions struct {
	CheckPermission bool
	UserId          string
	GroupIds        []string
	Permissions     []model.AuthAction
}

type Resource added in v0.0.20 

type Resource struct {
	Id      string `json:"id"`
	TopicId string `json:"topic_id"`
	model.ResourceRights
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.