rpc

Documentation

Index

• type Handler
  • func NewHandler(ctx context.Context, opts HandlerOpts) (*Handler, error)
  • func (h *Handler) Request(ctx context.Context, pb *paho.Publish) (resp *paho.Publish, err error)
• type HandlerOpts

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, opts HandlerOpts) (*Handler, error)

func (*Handler) Request

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

type HandlerOpts

type HandlerOpts struct {
	Conn             *autopaho.ConnectionManager
	Router           paho.Router
	ResponseTopicFmt string
	ClientID         string
}