Documentation
¶
Overview ¶
Package mockmqtt provides simple standalone mock of mqtt.Client.
Index ¶
- type Client
- func (c *Client) Connect(ctx context.Context, clientID string, opts ...mqtt.ConnectOption) (sessionPresent bool, err error)
- func (c *Client) Disconnect(ctx context.Context) error
- func (c *Client) Handle(handler mqtt.Handler)
- func (c *Client) Ping(ctx context.Context) error
- func (c *Client) Publish(ctx context.Context, message *mqtt.Message) error
- func (c *Client) Serve(message *mqtt.Message)
- func (c *Client) Subscribe(ctx context.Context, subs ...mqtt.Subscription) ([]mqtt.Subscription, error)
- func (c *Client) Unsubscribe(ctx context.Context, subs ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
ConnectFn func(ctx context.Context, clientID string, opts ...mqtt.ConnectOption) (sessionPresent bool, err error)
DisconnectFn func(ctx context.Context) error
PublishFn func(ctx context.Context, message *mqtt.Message) error
SubscribeFn func(ctx context.Context, subs ...mqtt.Subscription) ([]mqtt.Subscription, error)
UnsubscribeFn func(ctx context.Context, subs ...string) error
PingFn func(ctx context.Context) error
// contains filtered or unexported fields
}
Client is a simple mock of mqtt.Client. Handler registered by Handle() can be called by Client.Serve().
func (*Client) Connect ¶
func (c *Client) Connect(ctx context.Context, clientID string, opts ...mqtt.ConnectOption) (sessionPresent bool, err error)
Connect implements mqtt.Client.
func (*Client) Disconnect ¶
Disconnect implements mqtt.Client.
func (*Client) Handle ¶
func (c *Client) Handle(handler mqtt.Handler)
Handle implements mqtt.Client.
Source Files
Click to show internal directories.
Click to hide internal directories.