publisher

package

Go to main page

Versions in this module

v0

v0.0.17

Jun 19, 2024

v0.0.16

Jun 18, 2024

v0.0.15

Jun 17, 2024

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.11

May 2, 2024

v0.0.10

Apr 26, 2024

v0.0.9

Mar 18, 2024

v0.0.8

Mar 15, 2024

v0.0.7

Mar 14, 2024

v0.0.6

Mar 13, 2024

v0.0.5

Mar 13, 2024

v0.0.4

Feb 14, 2024

v0.0.3

Feb 9, 2024

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