publisher

package
v0.2.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 3, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var VoidPublisherError error = nil //errors.New("try to use void publisher")

Functions

func InitTopic 

func InitTopic(bootstrapUrl string, topics ...string) (err error)

Types

type AspectCommand 

type AspectCommand struct {
	Command string        `json:"command"`
	Id      string        `json:"id"`
	Aspect  models.Aspect `json:"aspect"`
}

type CharacteristicCommand 

type CharacteristicCommand struct {
	Command        string                `json:"command"`
	Id             string                `json:"id"`
	Characteristic models.Characteristic `json:"characteristic"`
}

type ConceptCommand 

type ConceptCommand struct {
	Command string         `json:"command"`
	Id      string         `json:"id"`
	Concept models.Concept `json:"concept"`
}

type DeviceClassCommand 

type DeviceClassCommand struct {
	Command     string             `json:"command"`
	Id          string             `json:"id"`
	DeviceClass models.DeviceClass `json:"device_class"`
}

type DeviceCommand 

type DeviceCommand struct {
	Command string        `json:"command"`
	Id      string        `json:"id"`
	Device  models.Device `json:"device"`
}

type DeviceGroupCommand 

type DeviceGroupCommand struct {
	Command     string             `json:"command"`
	Id          string             `json:"id"`
	DeviceGroup models.DeviceGroup `json:"device_group"`
}

type DeviceTypeCommand 

type DeviceTypeCommand struct {
	Command    string            `json:"command"`
	Id         string            `json:"id"`
	DeviceType models.DeviceType `json:"device_type"`
}

type FunctionCommand 

type FunctionCommand struct {
	Command  string          `json:"command"`
	Id       string          `json:"id"`
	Function models.Function `json:"function"`
}

type HubCommand 

type HubCommand struct {
	Command string     `json:"command"`
	Id      string     `json:"id"`
	Hub     models.Hub `json:"hub"`
}

type KeySeparationBalancer 

type KeySeparationBalancer struct {
	SubBalancer kafka.Balancer
	Seperator   string
}

func (*KeySeparationBalancer) Balance 

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

type LocationCommand 

type LocationCommand struct {
	Command  string          `json:"command"`
	Id       string          `json:"id"`
	Location models.Location `json:"location"`
}

type ProtocolCommand 

type ProtocolCommand struct {
	Command  string          `json:"command"`
	Id       string          `json:"id"`
	Protocol models.Protocol `json:"protocol"`
}

type Publisher 

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

func New 

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

func (*Publisher) PublishAspect 

func (this *Publisher) PublishAspect(aspect models.Aspect) (err error)

func (*Publisher) PublishAspectCommand 

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

func (*Publisher) PublishAspectDelete 

func (this *Publisher) PublishAspectDelete(id string) error

func (*Publisher) PublishCharacteristic 

func (this *Publisher) PublishCharacteristic(characteristic models.Characteristic) (err error)

func (*Publisher) PublishCharacteristicCommand 

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

func (*Publisher) PublishCharacteristicDelete 

func (this *Publisher) PublishCharacteristicDelete(id string) error

func (*Publisher) PublishConcept 

func (this *Publisher) PublishConcept(concept models.Concept) (err error)

func (*Publisher) PublishConceptCommand 

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

func (*Publisher) PublishConceptDelete 

func (this *Publisher) PublishConceptDelete(id string) error

func (*Publisher) PublishDevice 

func (this *Publisher) PublishDevice(device models.Device) (err error)

func (*Publisher) PublishDeviceClass 

func (this *Publisher) PublishDeviceClass(deviceClass models.DeviceClass) (err error)

func (*Publisher) PublishDeviceClassCommand 

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

func (*Publisher) PublishDeviceClassDelete 

func (this *Publisher) PublishDeviceClassDelete(id string) error

func (*Publisher) PublishDeviceCommand 

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

func (*Publisher) PublishDeviceDelete 

func (this *Publisher) PublishDeviceDelete(id string) error

func (*Publisher) PublishDeviceGroup 

func (this *Publisher) PublishDeviceGroup(group models.DeviceGroup) (err error)

func (*Publisher) PublishDeviceGroupCommand 

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

func (*Publisher) PublishDeviceGroupDelete 

func (this *Publisher) PublishDeviceGroupDelete(id string) error

func (*Publisher) PublishDeviceType 

func (this *Publisher) PublishDeviceType(device models.DeviceType) (err error)

func (*Publisher) PublishDeviceTypeCommand 

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

func (*Publisher) PublishDeviceTypeDelete 

func (this *Publisher) PublishDeviceTypeDelete(id string) error

func (*Publisher) PublishFunction 

func (this *Publisher) PublishFunction(function models.Function) (err error)

func (*Publisher) PublishFunctionCommand 

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

func (*Publisher) PublishFunctionDelete 

func (this *Publisher) PublishFunctionDelete(id string) error

func (*Publisher) PublishHub 

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

func (*Publisher) PublishHubCommand 

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

func (*Publisher) PublishHubDelete 

func (this *Publisher) PublishHubDelete(id string) error

func (*Publisher) PublishLocation 

func (this *Publisher) PublishLocation(Location models.Location) (err error)

func (*Publisher) PublishLocationCommand 

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

func (*Publisher) PublishLocationDelete 

func (this *Publisher) PublishLocationDelete(id string) error

func (*Publisher) PublishProtocol 

func (this *Publisher) PublishProtocol(protocol models.Protocol) (err error)

func (*Publisher) PublishProtocolCommand 

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

func (*Publisher) PublishProtocolDelete 

func (this *Publisher) PublishProtocolDelete(id string) error

type Void 

type Void struct{}

func (Void) PublishAspect 

func (this Void) PublishAspect(device models.Aspect) (err error)

func (Void) PublishAspectDelete 

func (this Void) PublishAspectDelete(id string) error

func (Void) PublishCharacteristic 

func (this Void) PublishCharacteristic(characteristic models.Characteristic) (err error)

func (Void) PublishCharacteristicDelete 

func (this Void) PublishCharacteristicDelete(id string) error

func (Void) PublishConcept 

func (this Void) PublishConcept(concept models.Concept) (err error)

func (Void) PublishConceptDelete 

func (this Void) PublishConceptDelete(id string) error

func (Void) PublishDevice 

func (this Void) PublishDevice(device models.Device) (err error)

func (Void) PublishDeviceClass 

func (this Void) PublishDeviceClass(device models.DeviceClass) (err error)

func (Void) PublishDeviceClassDelete 

func (this Void) PublishDeviceClassDelete(id string) error

func (Void) PublishDeviceDelete 

func (this Void) PublishDeviceDelete(id string) error

func (Void) PublishDeviceGroup 

func (this Void) PublishDeviceGroup(device models.DeviceGroup) (err error)

func (Void) PublishDeviceGroupDelete 

func (this Void) PublishDeviceGroupDelete(id string) error

func (Void) PublishDeviceType 

func (this Void) PublishDeviceType(device models.DeviceType) (err error)

func (Void) PublishDeviceTypeDelete 

func (this Void) PublishDeviceTypeDelete(id string) error

func (Void) PublishFunction 

func (this Void) PublishFunction(device models.Function) (err error)

func (Void) PublishFunctionDelete 

func (this Void) PublishFunctionDelete(id string) error

func (Void) PublishHub 

func (this Void) PublishHub(hub models.Hub) (err error)

func (Void) PublishHubDelete 

func (this Void) PublishHubDelete(id string) error

func (Void) PublishLocation 

func (this Void) PublishLocation(device models.Location) (err error)

func (Void) PublishLocationDelete 

func (this Void) PublishLocationDelete(id string) error

func (Void) PublishProtocol 

func (this Void) PublishProtocol(device models.Protocol) (err error)

func (Void) PublishProtocolDelete 

func (this Void) PublishProtocolDelete(id string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳