mqtt

Documentation

Index

• func NewMqttApi(config *MqttApiConfig, pusher bmw.Pusher) bmw.API
• type Config
  • func NewConfig(conf string) (c *Config, err error)
• type MqttAPI
  • func (mqttApi *MqttAPI) StartServe(host, port string) error
• type MqttApiConfig
• type MqttJob
• type MqttJobConsumer
  • func NewMqttJobConsumer(jobChan chan interface{}, config *mqttConfig) *MqttJobConsumer
  • func (mjc *MqttJobConsumer) GetJob() interface{}
  • func (mjc *MqttJobConsumer) Handle(job interface{}) error
  • func (mjc *MqttJobConsumer) Start()
• type MqttPoolFactory
  • func (f *MqttPoolFactory) ActivateObject(object *Pool.PooledObject) error
  • func (f *MqttPoolFactory) DestroyObject(object *Pool.PooledObject) error
  • func (this *MqttPoolFactory) MakeObject() (*Pool.PooledObject, error)
  • func (f *MqttPoolFactory) PassivateObject(object *Pool.PooledObject) error
  • func (f *MqttPoolFactory) ValidateObject(object *Pool.PooledObject) bool
• type MqttWorker
  • func NewMqttWorker(config *Config) *MqttWorker

Functions

func NewMqttApi

func NewMqttApi(config *MqttApiConfig, pusher bmw.Pusher) bmw.API

Types

type Config

type Config struct {
	Api       *MqttApiConfig
	Mqtt      *mqttConfig
	Beanstalk *producer.BeanstalkConfig
}

func NewConfig

func NewConfig(conf string) (c *Config, err error)

NewConfig new a config.

type MqttAPI

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

func (*MqttAPI) StartServe

func (mqttApi *MqttAPI) StartServe(host, port string) error

type MqttApiConfig

type MqttApiConfig struct {
	Host string
	Port string
}

type MqttJob

type MqttJob struct {
	Topic    string `json:"topic"`
	Body     string `json:"body"`
	Qos      byte   `json:"qos"`
	Retained bool   `json:"retained"`
}

type MqttJobConsumer

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

get job from go-chan, handle it

func NewMqttJobConsumer

func NewMqttJobConsumer(jobChan chan interface{}, config *mqttConfig) *MqttJobConsumer

func (*MqttJobConsumer) GetJob

func (mjc *MqttJobConsumer) GetJob() interface{}

func (*MqttJobConsumer) Handle

func (mjc *MqttJobConsumer) Handle(job interface{}) error

func (*MqttJobConsumer) Start

func (mjc *MqttJobConsumer) Start()

type MqttPoolFactory

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

func (*MqttPoolFactory) ActivateObject

func (f *MqttPoolFactory) ActivateObject(object *Pool.PooledObject) error

func (*MqttPoolFactory) DestroyObject

func (f *MqttPoolFactory) DestroyObject(object *Pool.PooledObject) error

func (*MqttPoolFactory) MakeObject

func (this *MqttPoolFactory) MakeObject() (*Pool.PooledObject, error)

func (*MqttPoolFactory) PassivateObject

func (f *MqttPoolFactory) PassivateObject(object *Pool.PooledObject) error

func (*MqttPoolFactory) ValidateObject

func (f *MqttPoolFactory) ValidateObject(object *Pool.PooledObject) bool

type MqttWorker

type MqttWorker struct {
	bmw.DefaultWorker
	Config *Config
}

MqttWorker represents a worker which receives http request to send messages to mqtt broker

func NewMqttWorker

func NewMqttWorker(config *Config) *MqttWorker

NewMqttWorker makes a new MqttWorker