mqtt_notification_gateway

Documentation

Index

• func New(broker, topic string, client mqtt.Client) gateway.Notification
• type MqttGateway
  • func (g *MqttGateway) Endpoint() notification.Endpoint
  • func (g *MqttGateway) SendMessage(ctx context.Context, message string) error
  • func (g *MqttGateway) Type() notification.TopicType

Functions

func New

func New(broker, topic string, client mqtt.Client) gateway.Notification

Types

type MqttGateway

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

func (*MqttGateway) Endpoint

func (g *MqttGateway) Endpoint() notification.Endpoint

func (*MqttGateway) SendMessage

func (g *MqttGateway) SendMessage(ctx context.Context, message string) error

func (*MqttGateway) Type

func (g *MqttGateway) Type() notification.TopicType