mqtt

Documentation

Index

• Constants
• func EmptyPublisher(ctx context.Context, topic string, payload []byte) error
• type Interface
  • func (i *Interface) Connected(ctx context.Context, publisher Publisher) error
  • func (i *Interface) Disconnected()
  • func (i *Interface) IncomingMessage(ctx context.Context, topic string, payload []byte) error
  • func (i *Interface) IncomingMessageDevices(ctx context.Context, topic []string, payload []byte) error
  • func (i *Interface) IncomingMessageDevicesWith(ctx context.Context, topic []string, payload []byte, d da.Device) error
  • func (i *Interface) IncomingMessageDevicesWithCapabilities(ctx context.Context, topic []string, payload []byte, d da.Device) error
  • func (i *Interface) Start()
  • func (i *Interface) Stop()
• type Publisher

Constants

const DefaultMqttOutputLayer string = "mqtt"

const MaximumServiceUpdateTime = 1 * time.Second

const UnknownDevice = mqttError("unknown device")

const UnknownOutputLayer = mqttError("output layer requested could not be found")

const UnknownTopic = mqttError("unknown topic")

Functions

func EmptyPublisher

func EmptyPublisher(ctx context.Context, topic string, payload []byte) error

Types

type Interface

type Interface struct {
	Publisher Publisher

	DeviceOrganiser *state.DeviceOrganiser
	GatewayMux      state.GatewayMapper
	EventSubscriber state.EventSubscriber
	OutputStack     layers.OutputStack
	DeviceInvoker   invoker.Invoker

	Logger logwrap.Logger

	PublishStateOnConnect  bool
	PublishAggregatedState bool
	PublishIndividualState bool
	// contains filtered or unexported fields
}

func (*Interface) Connected

func (i *Interface) Connected(ctx context.Context, publisher Publisher) error

func (*Interface) Disconnected

func (i *Interface) Disconnected()

func (*Interface) IncomingMessage

func (i *Interface) IncomingMessage(ctx context.Context, topic string, payload []byte) error

func (*Interface) IncomingMessageDevices

func (i *Interface) IncomingMessageDevices(ctx context.Context, topic []string, payload []byte) error

func (*Interface) IncomingMessageDevicesWith

func (i *Interface) IncomingMessageDevicesWith(ctx context.Context, topic []string, payload []byte, d da.Device) error

func (*Interface) IncomingMessageDevicesWithCapabilities

func (i *Interface) IncomingMessageDevicesWithCapabilities(ctx context.Context, topic []string, payload []byte, d da.Device) error

func (*Interface) Start

func (i *Interface) Start()

func (*Interface) Stop

func (i *Interface) Stop()

type Publisher

type Publisher func(ctx context.Context, topic string, payload []byte) error