amqp

Documentation

Index

• type ClientPublisher
  • func NewMsgClientPublisher(logger logging.Logger, amqp *network.Amqp) ClientPublisher
• type ConnectorPublisher
  • func NewMsgConnectorPublisher(logger logging.Logger, amqp *network.Amqp) ConnectorPublisher

Types

type ClientPublisher

type ClientPublisher interface {
	SendRegisteredDevice(thingID, token string, err error) error
	SendUnregisteredDevice(thingID string, err error) error
	SendUpdatedSchema(thingID string, err error) error
	SendDevicesList(things []*entities.Thing, err error) error
	SendAuthStatus(thingID string, err error) error
	SendUpdateData(thingID string, data []entities.Data) error
	SendRequestData(thingID string, sensorIds []int) error
}

ClientPublisher is the interface with methods that the publisher should have

func NewMsgClientPublisher

func NewMsgClientPublisher(logger logging.Logger, amqp *network.Amqp) ClientPublisher

NewMsgClientPublisher constructs the msgClientPublisher

type ConnectorPublisher

type ConnectorPublisher interface {
	SendRegisterDevice(string, string) error
	SendUnregisterDevice(string) error
	SendUpdateSchema(string, []entities.Schema) error
	SendPublishData(string, []entities.Data) error
}

ConnectorPublisher handle messages received from a service

func NewMsgConnectorPublisher

func NewMsgConnectorPublisher(logger logging.Logger, amqp *network.Amqp) ConnectorPublisher

NewMsgConnectorPublisher constructs the Connector