mqttClient

Documentation

Index

• type Client
  • func RunClient(cfg Config) (*Client, error)
  • func (c *Client) Config() Config
  • func (c *Client) Shutdown()
• type ClientPool
  • func RunPool() (pool *ClientPool)
  • func (p *ClientPool) AddClient(client *Client)
  • func (p *ClientPool) GetClient(clientName string) *Client
  • func (p *ClientPool) RemoveClient(client Client)
  • func (p *ClientPool) Shutdown()
• type Config

Types

type Client

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

func RunClient

func RunClient(cfg Config) (*Client, error)

func (*Client) Config

func (c *Client) Config() Config

func (*Client) Shutdown

func (c *Client) Shutdown()

type ClientPool

type ClientPool struct {
	Clients      map[string]*Client
	ClientsMutex sync.RWMutex
}

func RunPool

func RunPool() (pool *ClientPool)

func (*ClientPool) AddClient

func (p *ClientPool) AddClient(client *Client)

func (*ClientPool) GetClient

func (p *ClientPool) GetClient(clientName string) *Client

func (*ClientPool) RemoveClient

func (p *ClientPool) RemoveClient(client Client)

func (*ClientPool) Shutdown

func (p *ClientPool) Shutdown()

type Config

type Config interface {
	Name() string
	Broker() string
	User() string
	Password() string
	ClientId() string
	Qos() byte
	TopicPrefix() string
	AvailabilityTopic() string
	LogDebug() bool
}