core

Documentation

Overview

Package smqtt implements functions for manipulation of MQTT API. It provides a gin-like way to create MQTT API.

Package core provides way to send MQTT message.

Index

• func ClientError(err_str string) error
• func InternalError(err_str string) error
• func ParamRequiredError(param_name string) error
• type ClientConfig
• type Core
  • func NewCore(conf *ClientConfig) (*Core, error)
  • func (c *Core) Pub(topic string, qos byte, retained bool, data interface{}) error

Functions

func ClientError

func ClientError(err_str string) error

func InternalError

func InternalError(err_str string) error

func ParamRequiredError

func ParamRequiredError(param_name string) error

Types

type ClientConfig

type ClientConfig struct {
	Broker         string
	ClientId       string
	CaCertPath     string
	ClientCertPath string
	ClientKeyPath  string
	KeepAlive      int
	PingTimeout    int
	CleanSession   bool
	OrderMatters   bool
}

type Core

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

Core allows us to send MQTT message

func NewCore

func NewCore(conf *ClientConfig) (*Core, error)

NewCore returns a Responser that can send MQTT message with MQTT client c

func (*Core) Pub

func (c *Core) Pub(topic string, qos byte, retained bool, data interface{}) error

Pub is used to send MQTT message