producer

Dec 19, 2023

Changes in this version

+ type Producer struct

+ func New(conf config.Config) *Producer

+ func StartSourceMock(config config.Config, control listener.Controller) (prod *Producer, err error)

+ func (this *Producer) Handle(topic string, handler listener.Listener)

+ func (this *Producer) PublishAspect(aspect models.Aspect, userId string) (err error)

+ func (this *Producer) PublishAspectCommand(cmd listener.AspectCommand) error

+ func (this *Producer) PublishAspectDelete(id string, userId string) error

+ func (this *Producer) PublishCharacteristic(characteristic models.Characteristic, userId string) (err error)

+ func (this *Producer) PublishCharacteristicCommand(cmd listener.CharacteristicCommand) error

+ func (this *Producer) PublishCharacteristicDelete(id string, userId string) error

+ func (this *Producer) PublishConcept(concept models.Concept, userId string) (err error)

+ func (this *Producer) PublishConceptCommand(cmd listener.ConceptCommand) error

+ func (this *Producer) PublishConceptDelete(id string, userId string) error

+ func (this *Producer) PublishDeviceClass(deviceclass models.DeviceClass, userId string) (err error)

+ func (this *Producer) PublishDeviceClassCommand(cmd listener.DeviceClassCommand) error

+ func (this *Producer) PublishDeviceClassDelete(id string, userId string) error

+ func (this *Producer) PublishDeviceDelete(id string, owner string) error

+ func (this *Producer) PublishDeviceType(deviceType models.DeviceType, userId string) (err error)

+ func (this *Producer) PublishDeviceTypeCommand(cmd listener.DeviceTypeCommand) error

+ func (this *Producer) PublishDeviceTypeDelete(id string, userId string) error

+ func (this *Producer) PublishFunction(function models.Function, userId string) (err error)

+ func (this *Producer) PublishFunctionCommand(cmd listener.FunctionCommand) error

+ func (this *Producer) PublishFunctionDelete(id string, userId string) error

+ func (this *Producer) PublishHub(hub models.Hub) (err error)

+ func (this *Producer) PublishLocation(location models.Location, userId string) (err error)

+ func (this *Producer) PublishLocationCommand(cmd listener.LocationCommand) error

+ func (this *Producer) PublishLocationDelete(id string, userId string) error