producer

Documentation

Index

• func GetKafkaWriter(broker string, topic string, debug bool) (writer *kafka.Writer, err error)
• type AspectCommand
• type DeviceCommand
• type HubCommand
• type KeySeparationBalancer
  • func (this *KeySeparationBalancer) Balance(msg kafka.Message, partitions ...int) (partition int)
• type Producer
  • func New(conf config.Config) (*Producer, error)
  • func (this *Producer) PublishAspectCommand(cmd AspectCommand) error
  • func (this *Producer) PublishAspectDelete(id string, userId string) error
  • func (this *Producer) PublishAspectUpdate(aspect models.Aspect, userId string) error
  • func (this *Producer) PublishDevice(device models.Device, userId string) error
  • func (this *Producer) PublishDeviceCommand(cmd DeviceCommand) error
  • func (this *Producer) PublishDeviceDelete(id string, userId string) error
  • func (this *Producer) PublishDeviceRights(deviceId string, userId string, rights model.ResourceRights) (err error)
  • func (this *Producer) PublishHub(hub models.Hub, userId string) (err error)
  • func (this *Producer) PublishHubCommand(cmd HubCommand) error
  • func (this *Producer) SendDone(msg donewait.DoneMsg) error

Functions

func GetKafkaWriter

func GetKafkaWriter(broker string, topic string, debug bool) (writer *kafka.Writer, err error)

Types

type AspectCommand

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

type DeviceCommand

type DeviceCommand struct {
	Command string                `json:"command"`
	Id      string                `json:"id"`
	Owner   string                `json:"owner"`
	Device  models.Device         `json:"device"`
	Rights  *model.ResourceRights `json:"rights,omitempty"`
}

type HubCommand

type HubCommand struct {
	Command string     `json:"command"`
	Id      string     `json:"id"`
	Owner   string     `json:"owner"`
	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 Producer

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

func New

func New(conf config.Config) (*Producer, error)

func (*Producer) PublishAspectCommand

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

func (*Producer) PublishAspectDelete

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

func (*Producer) PublishAspectUpdate

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

func (*Producer) PublishDevice

func (this *Producer) PublishDevice(device models.Device, userId string) error

func (*Producer) PublishDeviceCommand

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

func (*Producer) PublishDeviceDelete

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

func (*Producer) PublishDeviceRights

func (this *Producer) PublishDeviceRights(deviceId string, userId string, rights model.ResourceRights) (err error)

func (*Producer) PublishHub

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

func (*Producer) PublishHubCommand

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

func (*Producer) SendDone

func (this *Producer) SendDone(msg donewait.DoneMsg) error