publisher

package

Go to main page

Versions in this module

v0

v0.0.14

May 27, 2024

v0.0.13

May 27, 2024

v0.0.12

May 7, 2024

Changes in this version

type AspectCommand

+ StrictWaitBeforeDone bool

type CharacteristicCommand

+ StrictWaitBeforeDone bool

type ConceptCommand

+ StrictWaitBeforeDone bool

type DeviceClassCommand

+ StrictWaitBeforeDone bool

type DeviceCommand

+ StrictWaitBeforeDone bool

type DeviceGroupCommand

+ StrictWaitBeforeDone bool

type DeviceTypeCommand

+ StrictWaitBeforeDone bool

type FunctionCommand

+ StrictWaitBeforeDone bool

type HubCommand

+ StrictWaitBeforeDone bool

type LocationCommand

+ StrictWaitBeforeDone bool

type ProtocolCommand

+ StrictWaitBeforeDone bool

v0.0.2

Jan 2, 2024

v0.0.1

Dec 19, 2023

Changes in this version

+ var VoidPublisherError = errors.New("try to use void publisher")

+ type AspectCommand struct

+ Aspect models.Aspect

+ Command string

+ Id string

+ Owner string

+ type CharacteristicCommand struct

+ Characteristic models.Characteristic

+ Command string

+ Id string

+ Owner string

+ type CommandWithRights = permmodel.CommandWithRights

+ type ConceptCommand struct

+ Command string

+ Concept models.Concept

+ Id string

+ Owner string

+ type DeviceClassCommand struct

+ Command string

+ DeviceClass models.DeviceClass

+ Id string

+ Owner string

+ type DeviceCommand struct

+ Command string

+ Device models.Device

+ Id string

+ Owner string

+ type DeviceGroupCommand struct

+ Command string

+ DeviceGroup models.DeviceGroup

+ Id string

+ Owner string

+ type DeviceTypeCommand struct

+ Command string

+ DeviceType models.DeviceType

+ Id string

+ Owner string

+ type FunctionCommand struct

+ Command string

+ Function models.Function

+ Id string

+ Owner string

+ type HubCommand struct

+ Command string

+ Hub models.Hub

+ Id string

+ Owner string

+ type KeySeparationBalancer struct

+ Seperator string

+ SubBalancer kafka.Balancer

+ func (this *KeySeparationBalancer) Balance(msg kafka.Message, partitions ...int) (partition int)

+ type LocationCommand struct

+ Command string

+ Id string

+ Location models.Location

+ Owner string

+ type ProtocolCommand struct

+ Command string

+ Id string

+ Owner string

+ Protocol models.Protocol

+ type Publisher struct

+ func New(conf config.Config, ctx context.Context) (*Publisher, error)

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

+ func (this *Publisher) PublishAspectCommand(cmd AspectCommand) error

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

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

+ func (this *Publisher) PublishCharacteristicCommand(cmd CharacteristicCommand) error

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

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

+ func (this *Publisher) PublishConceptCommand(cmd ConceptCommand) error

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

+ func (this *Publisher) PublishDevice(device models.Device, userId string) (err error)

+ func (this *Publisher) PublishDeviceClass(deviceClass models.DeviceClass, userId string) (err error)

+ func (this *Publisher) PublishDeviceClassCommand(cmd DeviceClassCommand) error

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

+ func (this *Publisher) PublishDeviceCommand(cmd DeviceCommand) error

+ func (this *Publisher) PublishDeviceDelete(id string, userId string) error

+ func (this *Publisher) PublishDeviceGroup(group models.DeviceGroup, userId string) (err error)

+ func (this *Publisher) PublishDeviceGroupCommand(cmd DeviceGroupCommand) error

+ func (this *Publisher) PublishDeviceGroupDelete(id string, userId string) error

+ func (this *Publisher) PublishDeviceType(device models.DeviceType, userId string) (err error)

+ func (this *Publisher) PublishDeviceTypeCommand(cmd DeviceTypeCommand) error

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

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

+ func (this *Publisher) PublishFunctionCommand(cmd FunctionCommand) error

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

+ func (this *Publisher) PublishHub(hub models.Hub, userId string) (err error)

+ func (this *Publisher) PublishHubCommand(cmd HubCommand) error

+ func (this *Publisher) PublishHubDelete(id string, userId string) error

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

+ func (this *Publisher) PublishLocationCommand(cmd LocationCommand) error

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

+ func (this *Publisher) PublishProtocol(protocol models.Protocol, userId string) (err error)

+ func (this *Publisher) PublishProtocolCommand(cmd ProtocolCommand) error

+ func (this *Publisher) PublishProtocolDelete(id string, userId string) error

+ func (this *Publisher) PublishRights(kind string, id string, element permmodel.ResourceRightsBase) error

+ type Void struct

+ func (this Void) PublishAspect(device models.Aspect, userID string) (err error)

+ func (this Void) PublishAspectDelete(id string, userID string) error

+ func (this Void) PublishCharacteristic(characteristic models.Characteristic, userID string) (err error)

+ func (this Void) PublishCharacteristicDelete(id string, userID string) error

+ func (this Void) PublishConcept(concept models.Concept, userID string) (err error)

+ func (this Void) PublishConceptDelete(id string, userID string) error

+ func (this Void) PublishDevice(device models.Device, userID string) (err error)

+ func (this Void) PublishDeviceClass(device models.DeviceClass, userID string) (err error)

+ func (this Void) PublishDeviceClassDelete(id string, userID string) error

+ func (this Void) PublishDeviceDelete(id string, userID string) error

+ func (this Void) PublishDeviceGroup(device models.DeviceGroup, userID string) (err error)

+ func (this Void) PublishDeviceGroupDelete(id string, userID string) error

+ func (this Void) PublishDeviceType(device models.DeviceType, userID string) (err error)

+ func (this Void) PublishDeviceTypeDelete(id string, userID string) error

+ func (this Void) PublishFunction(device models.Function, userID string) (err error)

+ func (this Void) PublishFunctionDelete(id string, userID string) error

+ func (this Void) PublishHub(hub models.Hub, userID string) (err error)

+ func (this Void) PublishHubDelete(id string, userID string) error

+ func (this Void) PublishLocation(device models.Location, userID string) (err error)

+ func (this Void) PublishLocationDelete(id string, userID string) error

+ func (this Void) PublishProtocol(device models.Protocol, userID string) (err error)

+ func (this Void) PublishProtocolDelete(id string, userID string) error

+ func (this Void) PublishRights(kind string, id string, element permmodel.ResourceRightsBase) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL