client

Documentation

Index

• Variables
• type Client
  • func NewClient(target string, nats *nats.Conn) *Client
  • func (c *Client) PublishOnMqttTopic(topic string, payload []byte) error
  • func (c *Client) RegisterMqttTopic(topic string) (schema.RegisterSubResponseType, error)
  • func (c *Client) RequestReply(topic string, payload []byte, timeout int32) ([]byte, error)
  • func (c *Client) UnregisterNatsSubject(subject string) error

Variables

var (

	// DataCodec is the parsed dataSchema.avsc
	DataCodec *goavro.Codec = avro.CreateSchema(dataSchema)
)

Types

type Client

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

Client is a struct containing client relevant data

func NewClient

func NewClient(target string, nats *nats.Conn) *Client

NewClient creates a new client for talking to `mqtt-bridge`

func (*Client) PublishOnMqttTopic

func (c *Client) PublishOnMqttTopic(topic string, payload []byte) error

PublishOnMqttTopic is used to to send to a specific MQTT topic.

func (*Client) RegisterMqttTopic

func (c *Client) RegisterMqttTopic(topic string) (schema.RegisterSubResponseType, error)

RegisterMqttTopic is used to let a client register to a specific MQTT topic. This functions returns a nats subject the client can subscribe to in order to read the forwarded message.

func (*Client) RequestReply

func (c *Client) RequestReply(topic string, payload []byte, timeout int32) ([]byte, error)

RequestReply is used to to send to a specific MQTT topic.

func (*Client) UnregisterNatsSubject

func (c *Client) UnregisterNatsSubject(subject string) error

UnregisterNatsSubject is used to unregister a client from a specific nats subject previously registered using 'RegisterMqttTopic'.