rpc

Documentation

Index

• type Handler
  • func NewHandler(ctx context.Context, c *paho.Client) (*Handler, error)
  • func (h *Handler) Request(ctx context.Context, pb *paho.Publish) (*paho.Publish, error)

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, c *paho.Client) (*Handler, error)

func (*Handler) Request

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