producer

Documentation

Index

• type Producer
  • 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

Types

type Producer

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

func New

func New(conf config.Config) *Producer

func StartSourceMock

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

func (*Producer) Handle

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

func (*Producer) PublishAspect

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

func (*Producer) PublishAspectCommand

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

func (*Producer) PublishAspectDelete

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

func (*Producer) PublishCharacteristic

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

func (*Producer) PublishCharacteristicCommand

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

func (*Producer) PublishCharacteristicDelete

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

func (*Producer) PublishConcept

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

func (*Producer) PublishConceptCommand

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

func (*Producer) PublishConceptDelete

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

func (*Producer) PublishDeviceClass

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

func (*Producer) PublishDeviceClassCommand

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

func (*Producer) PublishDeviceClassDelete

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

func (*Producer) PublishDeviceDelete

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

func (*Producer) PublishDeviceType

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

func (*Producer) PublishDeviceTypeCommand

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

func (*Producer) PublishDeviceTypeDelete

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

func (*Producer) PublishFunction

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

func (*Producer) PublishFunctionCommand

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

func (*Producer) PublishFunctionDelete

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

func (*Producer) PublishHub

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

func (*Producer) PublishLocation

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

func (*Producer) PublishLocationCommand

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

func (*Producer) PublishLocationDelete

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