Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package

Go to main page

Versions in this module

v1

v1.0.1

Oct 17, 2020

v0

v0.14.0

Mar 3, 2020

Changes in this version

+ type BaseStore struct

+ func NewBaseStore(thingDescPath string) *BaseStore

+ func (b *BaseStore) DeleteThingDescriptor(address string) error

+ func (b *BaseStore) GetThingDescriptor(address string) error

+ func (b *BaseStore) SaveThingDescriptor(address string, inclusionReport interface{}) error

+ type LocalRegistryStore struct

+ func (st *LocalRegistryStore) ClearAll() error

+ func (st *LocalRegistryStore) Connect() error

+ func (st *LocalRegistryStore) DeleteLocation(id model.ID) error

+ func (st *LocalRegistryStore) DeleteService(id model.ID) error

+ func (st *LocalRegistryStore) DeleteThing(id model.ID) error

+ func (st *LocalRegistryStore) Disconnect()

+ func (st *LocalRegistryStore) ExtendThingsWithLocation(things []model.Thing) []model.ThingWithLocationView

+ func (st *LocalRegistryStore) GetAllDevices() ([]model.Device, error)

+ func (st *LocalRegistryStore) GetAllLocations() ([]model.Location, error)

+ func (st *LocalRegistryStore) GetAllServices() ([]model.Service, error)

+ func (st *LocalRegistryStore) GetAllThings() ([]model.Thing, error)

+ func (st *LocalRegistryStore) GetBackendName() string

+ func (st *LocalRegistryStore) GetConnection() interface{}

+ func (st *LocalRegistryStore) GetDeviceById(Id model.ID) (*model.DeviceExtendedView, error)

+ func (st *LocalRegistryStore) GetDeviceByIntegrationId(id string) (*model.Device, error)

+ func (st *LocalRegistryStore) GetDeviceByLocationId(locationId model.ID) ([]model.Device, error)

+ func (st *LocalRegistryStore) GetDevicesByLocationId(locationId model.ID) ([]model.Device, error)

+ func (st *LocalRegistryStore) GetDevicesByThingId(locationId model.ID) ([]model.Device, error)

+ func (st *LocalRegistryStore) GetExtendedDevices() ([]model.DeviceExtendedView, error)

+ func (st *LocalRegistryStore) GetExtendedServices(serviceNameFilter string, filterWithoutAlias bool, thingIdFilter model.ID, ...) ([]model.ServiceExtendedView, error)

+ func (st *LocalRegistryStore) GetLocationById(Id model.ID) (*model.Location, error)

+ func (st *LocalRegistryStore) GetLocationByIntegrationId(id string) (*model.Location, error)

+ func (st *LocalRegistryStore) GetServiceByAddress(serviceName string, serviceAddress string) (*model.Service, error)

+ func (st *LocalRegistryStore) GetServiceByFullAddress(address string) (*model.ServiceExtendedView, error)

+ func (st *LocalRegistryStore) GetServiceById(Id model.ID) (*model.Service, error)

+ func (st *LocalRegistryStore) GetState() string

+ func (st *LocalRegistryStore) GetThingByAddress(technology string, address string) (*model.Thing, error)

+ func (st *LocalRegistryStore) GetThingById(Id model.ID) (*model.Thing, error)

+ func (st *LocalRegistryStore) GetThingByIntegrationId(id string) (*model.Thing, error)

+ func (st *LocalRegistryStore) GetThingExtendedViewByAddress(technology string, address string) (*model.ThingExtendedView, error)

+ func (st *LocalRegistryStore) GetThingExtendedViewById(Id model.ID) (*model.ThingExtendedView, error)

+ func (st *LocalRegistryStore) GetThingsByLocationId(locationId model.ID) ([]model.Thing, error)

+ func (st *LocalRegistryStore) Init() error

+ func (st *LocalRegistryStore) LoadConfig(config interface{}) error

+ func (st *LocalRegistryStore) ReindexAll() error

+ func (st *LocalRegistryStore) Stop()

+ func (st *LocalRegistryStore) Sync() error

+ func (st *LocalRegistryStore) UpsertLocation(location *model.Location) (model.ID, error)

+ func (st *LocalRegistryStore) UpsertService(service *model.Service) (model.ID, error)

+ func (st *LocalRegistryStore) UpsertThing(thing *model.Thing) (model.ID, error)

+ type RegistryStorage interface

+ ClearAll func() error

+ Connect func() error

+ DeleteLocation func(id model.ID) error

+ DeleteService func(id model.ID) error

+ DeleteThing func(id model.ID) error

+ Disconnect func()

+ ExtendThingsWithLocation func(things []model.Thing) []model.ThingWithLocationView

+ GetAllDevices func() ([]model.Device, error)

+ GetAllLocations func() ([]model.Location, error)

+ GetAllServices func() ([]model.Service, error)

+ GetAllThings func() ([]model.Thing, error)

+ GetBackendName func() string

+ GetConnection func() interface{}

+ GetDeviceById func(Id model.ID) (*model.DeviceExtendedView, error)

+ GetDeviceByIntegrationId func(id string) (*model.Device, error)

+ GetDevicesByLocationId func(locationId model.ID) ([]model.Device, error)

+ GetDevicesByThingId func(locationId model.ID) ([]model.Device, error)

+ GetExtendedDevices func() ([]model.DeviceExtendedView, error)

+ GetExtendedServices func(serviceNameFilter string, filterWithoutAlias bool, thingIdFilter model.ID, ...) ([]model.ServiceExtendedView, error)

+ GetLocationById func(Id model.ID) (*model.Location, error)

+ GetLocationByIntegrationId func(id string) (*model.Location, error)

+ GetServiceByAddress func(serviceName string, serviceAddress string) (*model.Service, error)

+ GetServiceByFullAddress func(address string) (*model.ServiceExtendedView, error)

+ GetServiceById func(Id model.ID) (*model.Service, error)

+ GetState func() string

+ GetThingByAddress func(technology string, address string) (*model.Thing, error)

+ GetThingById func(Id model.ID) (*model.Thing, error)

+ GetThingByIntegrationId func(id string) (*model.Thing, error)

+ GetThingExtendedViewByAddress func(technology string, address string) (*model.ThingExtendedView, error)

+ GetThingExtendedViewById func(Id model.ID) (*model.ThingExtendedView, error)

+ GetThingsByLocationId func(locationId model.ID) ([]model.Thing, error)

+ Init func() error

+ LoadConfig func(config interface{}) error

+ ReindexAll func() error

+ Stop func()

+ Sync func() error

+ UpsertLocation func(location *model.Location) (model.ID, error)

+ UpsertService func(service *model.Service) (model.ID, error)

+ UpsertThing func(thing *model.Thing) (model.ID, error)

+ func NewThingRegistryStore(storeFile string) RegistryStorage

+ func NewVinculumRegistryStore(config *tpflow.Configs) RegistryStorage

+ type VinculumRegistryStore struct

+ func (VinculumRegistryStore) ClearAll() error

+ func (VinculumRegistryStore) DeleteLocation(id model.ID) error

+ func (VinculumRegistryStore) DeleteService(id model.ID) error

+ func (VinculumRegistryStore) DeleteThing(id model.ID) error

+ func (VinculumRegistryStore) GetDeviceById(Id model.ID) (*model.DeviceExtendedView, error)

+ func (VinculumRegistryStore) GetDeviceByIntegrationId(id string) (*model.Device, error)

+ func (VinculumRegistryStore) GetDevicesByLocationId(locationId model.ID) ([]model.Device, error)

+ func (VinculumRegistryStore) GetExtendedServices(serviceNameFilter string, filterWithoutAlias bool, thingIdFilter model.ID, ...) ([]model.ServiceExtendedView, error)

+ func (VinculumRegistryStore) GetLocationByIntegrationId(id string) (*model.Location, error)

+ func (VinculumRegistryStore) GetServiceByAddress(serviceName string, serviceAddress string) (*model.Service, error)

+ func (VinculumRegistryStore) GetServiceByFullAddress(address string) (*model.ServiceExtendedView, error)

+ func (VinculumRegistryStore) GetServiceById(Id model.ID) (*model.Service, error)

+ func (VinculumRegistryStore) GetState() string

+ func (VinculumRegistryStore) GetThingByAddress(technology string, address string) (*model.Thing, error)

+ func (VinculumRegistryStore) GetThingById(Id model.ID) (*model.Thing, error)

+ func (VinculumRegistryStore) GetThingByIntegrationId(id string) (*model.Thing, error)

+ func (VinculumRegistryStore) GetThingExtendedViewByAddress(technology string, address string) (*model.ThingExtendedView, error)

+ func (VinculumRegistryStore) GetThingExtendedViewById(Id model.ID) (*model.ThingExtendedView, error)

+ func (VinculumRegistryStore) ReindexAll() error

+ func (VinculumRegistryStore) UpsertLocation(location *model.Location) (model.ID, error)

+ func (VinculumRegistryStore) UpsertService(service *model.Service) (model.ID, error)

+ func (VinculumRegistryStore) UpsertThing(thing *model.Thing) (model.ID, error)

+ func (r *VinculumRegistryStore) Connect() error

+ func (r *VinculumRegistryStore) Disconnect()

+ func (r *VinculumRegistryStore) ExtendThingsWithLocation(things []model.Thing) []model.ThingWithLocationView

+ func (r *VinculumRegistryStore) GetAllDevices() ([]model.Device, error)

+ func (r *VinculumRegistryStore) GetAllLocations() ([]model.Location, error)

+ func (r *VinculumRegistryStore) GetAllServices() ([]model.Service, error)

+ func (r *VinculumRegistryStore) GetAllThings() ([]model.Thing, error)

+ func (r *VinculumRegistryStore) GetBackendName() string

+ func (r *VinculumRegistryStore) GetConnection() interface{}

+ func (r *VinculumRegistryStore) GetDevicesByThingId(locationId model.ID) ([]model.Device, error)

+ func (r *VinculumRegistryStore) GetExtendedDevices() ([]model.DeviceExtendedView, error)

+ func (r *VinculumRegistryStore) GetLocationById(Id model.ID) (*model.Location, error)

+ func (r *VinculumRegistryStore) GetThingsByLocationId(locationId model.ID) ([]model.Thing, error)

+ func (r *VinculumRegistryStore) Init() error

+ func (r *VinculumRegistryStore) LoadConfig(config interface{}) error

+ func (r *VinculumRegistryStore) Stop()

+ func (r *VinculumRegistryStore) Sync() error