paho package

import "code.pfad.fr/fritzgox/internal/paho"

Index ¶

• type Client
  • func Connect(brokerURL string, retained bool) (Client, error)
  • func (c Client) Close() error
  • func (p Client) Get(topic string) ([]byte, error)
  • func (c Client) Publish(topic string, payload []byte) error
  • func (p Client) Subscribe(topic string, handle func(topic string, payload []byte)) error
  • func (c Client) Unsubscribe(topic string) error
  • func (c Client) WithPrefix(topicPrefix string) Client

type Client ¶

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

func Connect ¶

func Connect(brokerURL string, retained bool) (Client, error)

func (Client) Close ¶

func (c Client) Close() error

func (Client) Get ¶

func (p Client) Get(topic string) ([]byte, error)

func (Client) Publish ¶

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

func (Client) Subscribe ¶

func (p Client) Subscribe(topic string, handle func(topic string, payload []byte)) error

func (Client) Unsubscribe ¶

func (c Client) Unsubscribe(topic string) error

func (Client) WithPrefix ¶

func (c Client) WithPrefix(topicPrefix string) Client

WithPrefix returns a client with another prefix set.

Source Files ¶

paho.go