Documentation ¶
Index ¶
- type VinculumIntegration
- func (mg *VinculumIntegration) ProcessVincDeviceUpdate(devices []primefimp.Device) error
- func (mg *VinculumIntegration) ProcessVincRoomUpdate(rooms []primefimp.Room) error
- func (mg *VinculumIntegration) ProcessVincServiceUpdate(devName string, roomId int, thingID model.ID, ...) error
- func (mg *VinculumIntegration) SetMsgTransport(msgTransport *fimpgo.MqttTransport)
- func (mg *VinculumIntegration) SyncDevice() error
- func (mg *VinculumIntegration) SyncRooms() error
- type VinculumRegistryStoreBackend
- func (st *VinculumRegistryStoreBackend) Connect() error
- func (st *VinculumRegistryStoreBackend) DeleteLocation(id model.ID) error
- func (st *VinculumRegistryStoreBackend) DeleteService(id model.ID) error
- func (st *VinculumRegistryStoreBackend) DeleteThing(id model.ID) error
- func (st *VinculumRegistryStoreBackend) Disconnect()
- func (st *VinculumRegistryStoreBackend) ExtendThingsWithLocation(things []model.Thing) []model.ThingWithLocationView
- func (st *VinculumRegistryStoreBackend) GetAllLocations() ([]model.Location, error)
- func (st *VinculumRegistryStoreBackend) GetAllServices() ([]model.Service, error)
- func (st *VinculumRegistryStoreBackend) GetAllThings() ([]model.Thing, error)
- func (st *VinculumRegistryStoreBackend) GetConnection() interface{}
- func (st *VinculumRegistryStoreBackend) GetExtendedServices(serviceNameFilter string, filterWithoutAlias bool, thingIdFilter model.ID, ...) ([]model.ServiceExtendedView, error)
- func (st *VinculumRegistryStoreBackend) GetLocationById(Id model.ID) (*model.Location, error)
- func (st *VinculumRegistryStoreBackend) GetLocationByIntegrationId(id string) (*model.Location, error)
- func (st *VinculumRegistryStoreBackend) GetServiceByAddress(serviceName string, serviceAddress string) (*model.Service, error)
- func (st *VinculumRegistryStoreBackend) GetServiceByFullAddress(address string) (*model.ServiceExtendedView, error)
- func (st *VinculumRegistryStoreBackend) GetServiceById(Id model.ID) (*model.Service, error)
- func (st *VinculumRegistryStoreBackend) GetState() string
- func (st *VinculumRegistryStoreBackend) GetThingByAddress(technology string, address string) (*model.Thing, error)
- func (st *VinculumRegistryStoreBackend) GetThingById(Id model.ID) (*model.Thing, error)
- func (st *VinculumRegistryStoreBackend) GetThingByIntegrationId(id string) (*model.Thing, error)
- func (st *VinculumRegistryStoreBackend) GetThingExtendedViewByAddress(technology string, address string) (*model.ThingExtendedView, error)
- func (st *VinculumRegistryStoreBackend) GetThingExtendedViewById(Id model.ID) (*model.ThingExtendedView, error)
- func (st *VinculumRegistryStoreBackend) GetThingsByLocationId(locationId model.ID) ([]model.Thing, error)
- func (st *VinculumRegistryStoreBackend) Init() error
- func (st *VinculumRegistryStoreBackend) LoadConfig(config interface{}) error
- func (st *VinculumRegistryStoreBackend) Stop()
- func (st *VinculumRegistryStoreBackend) UpsertLocation(location *model.Location) (model.ID, error)
- func (st *VinculumRegistryStoreBackend) UpsertService(service *model.Service) (model.ID, error)
- func (st *VinculumRegistryStoreBackend) UpsertThing(thing *model.Thing) (model.ID, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VinculumIntegration ¶
type VinculumIntegration struct {
// contains filtered or unexported fields
}
func NewVinculumIntegration ¶
func NewVinculumIntegration(registry storage.RegistryStorage, msgTransport *fimpgo.MqttTransport) *VinculumIntegration
func (*VinculumIntegration) ProcessVincDeviceUpdate ¶
func (mg *VinculumIntegration) ProcessVincDeviceUpdate(devices []primefimp.Device) error
func (*VinculumIntegration) ProcessVincRoomUpdate ¶
func (mg *VinculumIntegration) ProcessVincRoomUpdate(rooms []primefimp.Room) error
func (*VinculumIntegration) ProcessVincServiceUpdate ¶
func (*VinculumIntegration) SetMsgTransport ¶
func (mg *VinculumIntegration) SetMsgTransport(msgTransport *fimpgo.MqttTransport)
func (*VinculumIntegration) SyncDevice ¶
func (mg *VinculumIntegration) SyncDevice() error
func (*VinculumIntegration) SyncRooms ¶
func (mg *VinculumIntegration) SyncRooms() error
type VinculumRegistryStoreBackend ¶ added in v0.14.0
type VinculumRegistryStoreBackend struct {
// contains filtered or unexported fields
}
func NewVinculumRegistryStoreBackend ¶ added in v0.14.0
func NewVinculumRegistryStoreBackend(storeFile string) *VinculumRegistryStoreBackend
func (*VinculumRegistryStoreBackend) Connect ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) Connect() error
func (*VinculumRegistryStoreBackend) DeleteLocation ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) DeleteLocation(id model.ID) error
func (*VinculumRegistryStoreBackend) DeleteService ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) DeleteService(id model.ID) error
func (*VinculumRegistryStoreBackend) DeleteThing ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) DeleteThing(id model.ID) error
func (*VinculumRegistryStoreBackend) Disconnect ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) Disconnect()
func (*VinculumRegistryStoreBackend) ExtendThingsWithLocation ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) ExtendThingsWithLocation(things []model.Thing) []model.ThingWithLocationView
func (*VinculumRegistryStoreBackend) GetAllLocations ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetAllLocations() ([]model.Location, error)
func (*VinculumRegistryStoreBackend) GetAllServices ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetAllServices() ([]model.Service, error)
func (*VinculumRegistryStoreBackend) GetAllThings ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetAllThings() ([]model.Thing, error)
func (*VinculumRegistryStoreBackend) GetConnection ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetConnection() interface{}
func (*VinculumRegistryStoreBackend) GetExtendedServices ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetExtendedServices(serviceNameFilter string, filterWithoutAlias bool, thingIdFilter model.ID, locationIdFilter model.ID) ([]model.ServiceExtendedView, error)
GetExtendedServices return services enhanced with location Alias
func (*VinculumRegistryStoreBackend) GetLocationById ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) GetLocationByIntegrationId ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetLocationByIntegrationId(id string) (*model.Location, error)
func (*VinculumRegistryStoreBackend) GetServiceByAddress ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) GetServiceByFullAddress ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetServiceByFullAddress(address string) (*model.ServiceExtendedView, error)
func (*VinculumRegistryStoreBackend) GetServiceById ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) GetState ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetState() string
func (*VinculumRegistryStoreBackend) GetThingByAddress ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) GetThingById ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) GetThingByIntegrationId ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetThingByIntegrationId(id string) (*model.Thing, error)
func (*VinculumRegistryStoreBackend) GetThingExtendedViewByAddress ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetThingExtendedViewByAddress(technology string, address string) (*model.ThingExtendedView, error)
func (*VinculumRegistryStoreBackend) GetThingExtendedViewById ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) GetThingExtendedViewById(Id model.ID) (*model.ThingExtendedView, error)
GetThingExtendedViewById return thing enhanced with linked services and location Alias
func (*VinculumRegistryStoreBackend) GetThingsByLocationId ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) Init ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) Init() error
func (*VinculumRegistryStoreBackend) LoadConfig ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) LoadConfig(config interface{}) error
func (*VinculumRegistryStoreBackend) Stop ¶ added in v0.14.0
func (st *VinculumRegistryStoreBackend) Stop()
func (*VinculumRegistryStoreBackend) UpsertLocation ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) UpsertService ¶ added in v0.14.0
func (*VinculumRegistryStoreBackend) UpsertThing ¶ added in v0.14.0
Click to show internal directories.
Click to hide internal directories.