rpc

README

paho-mqtt-rpc

Paho MQTT v5 RPC extension. forked from https://github.com/eclipse/paho.golang/tree/master/paho/extensions/rpc and added some features:

• Request timeout

Documentation

Index

• Variables
• type Handler
  • func NewHandler(ctx context.Context, in HandlerInput) (*Handler, error)
  • func (h *Handler) Request(ctx context.Context, pb *paho.Publish) (*paho.Publish, error)
• type HandlerInput

Variables

var (
	ErrRequestTimeout = errors.New("request timeout")
)

Types

type Handler

type Handler struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Handler is the struct providing a request/response functionality for the paho MQTT v5 client

func NewHandler

func NewHandler(ctx context.Context, in HandlerInput) (*Handler, error)

func (*Handler) Request

func (h *Handler) Request(ctx context.Context, pb *paho.Publish) (*paho.Publish, error)

type HandlerInput

type HandlerInput struct {
	Server         string
	Username       *string
	Password       *string
	RequestTimeout time.Duration
}