mqtt

Dec 11, 2023

Changes in this version

type BaseClient

+ func (c *BaseClient) Stats() BaseStats

+ type BaseStats struct

+ CountPingError int

+ PingDelayMax time.Duration

+ PingDelayMin time.Duration

+ PingDelayRecent time.Duration

Apr 14, 2023

Changes in this version

type ReconnectOption

+ func WithAlwaysResubscribe(always bool) ReconnectOption

type ReconnectOptions

+ AlwaysResubscribe bool

Jan 13, 2023

Changes in this version

type RetryStats

+ CountConnect int

+ CountConnectError int

+ CountSetClient int

Oct 20, 2021

Changes in this version

type ReconnectOption

+ func WithRetryClient(cli *RetryClient) ReconnectOption

type ReconnectOptions

+ RetryClient *RetryClient

+ type RequestTimeoutError struct

+ func (e *RequestTimeoutError) Error() string

type RetryClient

+ DirectlyPublishQoS0 bool

+ OnError func(error)

+ ResponseTimeout time.Duration

Oct 18, 2021

Changes in this version

+ type ReconnectClient interface

type RetryClient

+ func (c *RetryClient) Stats() RetryStats

+ type RetryStats struct

+ QueuedRetries int

+ QueuedTasks int

+ TotalRetries int

+ TotalTasks int

+ type Retryer interface

+ Client func() *BaseClient

+ Resubscribe func(ctx context.Context)

+ Retry func(ctx context.Context)

+ SetClient func(ctx context.Context, cli *BaseClient)

+ Stats func() RetryStats

Jul 2, 2021

Changes in this version

type BaseClient

+ func DialContext(ctx context.Context, urlStr string, opts ...DialOption) (*BaseClient, error)

type BaseClientStoreDialer

+ func (d *BaseClientStoreDialer) DialContext(ctx context.Context) (*BaseClient, error)

type Dialer

+ DialContext func(context.Context) (*BaseClient, error)

type DialerFunc

+ func (d DialerFunc) DialContext(ctx context.Context) (*BaseClient, error)

+ type NoContextDialer struct

+ func (d *NoContextDialer) DialContext(context.Context) (*BaseClient, error)

+ type NoContextDialerIface interface

+ Dial func() (*BaseClient, error)

type URLDialer

+ func (d *URLDialer) DialContext(ctx context.Context) (*BaseClient, error)

Jun 8, 2021

Changes in this version

+ var ErrNotConnected = errors.New("not connected")

Mar 24, 2021

Changes in this version

+ type BaseClientStoreDialer struct

+ func (d *BaseClientStoreDialer) BaseClient() *BaseClient

+ func (d *BaseClientStoreDialer) Dial() (*BaseClient, error)

Feb 16, 2021

Changes in this version

+ type ErrorWithRetry interface

+ Retry func(context.Context, *BaseClient) error

Oct 31, 2020

Changes in this version

type Error

+ File string

+ Line int

Oct 27, 2020

Changes in this version

type BaseClient

+ func (c *BaseClient) SetErrorOnce(err error)

type RetryClient

+ func (c *RetryClient) Client() ClientCloser

May 30, 2020

Changes in this version

+ var ErrClosedClient = errors.New("operation on closed client")

May 22, 2020

Changes in this version

+ var ErrInvalidQoS = errors.New("invalid QoS")

+ var ErrPayloadLenExceeded = errors.New("payload length exceeded")

type BaseClient

+ MaxPayloadLen int

+ func (c *BaseClient) ValidateMessage(message *Message) error

type DialOption

+ func WithMaxPayloadLen(l int) DialOption

type DialOptions

+ MaxPayloadLen int

Apr 24, 2020

Changes in this version

type DialOption

+ func WithTLSCertFiles(host, caFile, certFile, privateKeyFile string) DialOption

Feb 4, 2020

Changes in this version

+ type ServeAsync struct

+ func (m *ServeAsync) Serve(message *Message)

Jan 6, 2020

Changes in this version

type DialOption

+ func WithConnStateHandler(handler func(ConnState, error)) DialOption

type DialOptions

+ ConnState func(ConnState, error)

+ type Error struct

+ Err error

+ Failure string

+ func (e *Error) Error() string

+ func (e *Error) Is(target error) bool

+ func (e *Error) Unwrap() error

Dec 25, 2019

Changes in this version

type ConnState

+ func (s ConnState) String() string

type RetryClient

+ func (c *RetryClient) Retry(ctx context.Context) error

Dec 24, 2019

Changes in this version

+ var ErrConnectionFailed = errors.New("connection failed")

+ type ConnectionError struct

+ Code ConnectionReturnCode

+ Err error

+ func (e *ConnectionError) Error() string

+ func (e *ConnectionError) Unwrap() error

Dec 24, 2019

Changes in this version

type RetryClient

+ func (c *RetryClient) Disconnect(ctx context.Context) error

+ func (c *RetryClient) Ping(ctx context.Context) error

+ func (c *RetryClient) Unsubscribe(ctx context.Context, subs ...string) error

Dec 24, 2019

Changes in this version

+ type DialerFunc func() (ClientCloser, error)

+ func (d DialerFunc) Dial() (ClientCloser, error)

Dec 23, 2019

Changes in this version

+ type ReconnectOption func(*ReconnectOptions) error

+ func WithConnectOption(connOpts ...ConnectOption) ReconnectOption

+ func WithPingInterval(interval time.Duration) ReconnectOption

+ func WithReconnectWait(base, max time.Duration) ReconnectOption

+ func WithTimeout(timeout time.Duration) ReconnectOption

+ type ReconnectOptions struct

+ ConnectOptions []ConnectOption

+ PingInterval time.Duration

+ ReconnectWaitBase time.Duration

+ ReconnectWaitMax time.Duration

+ Timeout time.Duration

Dec 23, 2019

Changes in this version

type ConnectOption

+ func WithProtocolLevel(level ProtocolLevel) ConnectOption

type ConnectOptions

+ ProtocolLevel ProtocolLevel

+ type ProtocolLevel byte

+ const ProtocolLevel3

+ const ProtocolLevel4

Dec 23, 2019

Changes in this version

+ var ErrInvalidPacketLength = errors.New("invalid packet length")

+ var ErrInvalidRune = errors.New("invalid rune in UTF-8 string")

Dec 23, 2019

Changes in this version

+ var ErrKeepAliveDisabled = errors.New("keep alive disabled")

+ var ErrPingTimeout = errors.New("ping timeout")

+ func KeepAlive(ctx context.Context, cli ClientCloser, interval, timeout time.Duration) error

type BaseClient

+ func (c *BaseClient) Done() <-chan struct{}

+ func (c *BaseClient) Err() error

+ func (c *BaseClient) Handle(handler Handler)

type Client

+ func NewReconnectClient(ctx context.Context, dialer Dialer, clientID string, opts ...ConnectOption) Client

+ Handle func(Handler)

+ type ClientCloser interface

+ type Closer interface

+ Close func() error

+ Done func() <-chan struct{}

+ Err func() error

type ConnectOption

+ func WithKeepAlive(interval uint16) ConnectOption

+ type Dialer interface

+ Dial func() (ClientCloser, error)

+ type RetryClient struct

+ func (c *RetryClient) Connect(ctx context.Context, clientID string, opts ...ConnectOption) (sessionPresent bool, err error)

+ func (c *RetryClient) Handle(handler Handler)

+ func (c *RetryClient) Publish(ctx context.Context, message *Message) error

+ func (c *RetryClient) Resubscribe(ctx context.Context) error

+ func (c *RetryClient) SetClient(ctx context.Context, cli Client)

+ func (c *RetryClient) Subscribe(ctx context.Context, subs ...Subscription) error

+ type URLDialer struct

+ Options []DialOption

+ URL string

+ func (d *URLDialer) Dial() (ClientCloser, error)

Dec 22, 2019

Changes in this version

+ var ErrInvalidPacket = errors.New("invalid packet")

Dec 22, 2019

Changes in this version

+ var ErrClosedTransport = errors.New("read/write on closed transport")

+ var ErrInvalidSubAck = errors.New("invalid SUBACK")

+ var ErrInvalidTopicFilter = errors.New("invalid topic filter")

+ var ErrUnsupportedProtocol = errors.New("unsupported protocol")

+ type BaseClient struct

+ ConnState func(ConnState, error)

+ Handler Handler

+ Transport io.ReadWriteCloser

+ func Dial(urlStr string, opts ...DialOption) (*BaseClient, error)

+ func (c *BaseClient) Close() error

+ func (c *BaseClient) Connect(ctx context.Context, clientID string, opts ...ConnectOption) error

+ func (c *BaseClient) Disconnect(ctx context.Context) error

+ func (c *BaseClient) Ping(ctx context.Context) error

+ func (c *BaseClient) Publish(ctx context.Context, message *Message) error

+ func (c *BaseClient) Subscribe(ctx context.Context, subs ...Subscription) error

+ func (c *BaseClient) Unsubscribe(ctx context.Context, subs ...string) error

+ type Client interface

+ Connect func(ctx context.Context, clientID string, opts ...ConnectOption) error

+ Disconnect func(ctx context.Context) error

+ Ping func(ctx context.Context) error

+ Publish func(ctx context.Context, message *Message) error

+ Subscribe func(ctx context.Context, subs ...Subscription) error

+ Unsubscribe func(ctx context.Context, subs ...string) error

+ type ConnState int

+ const StateActive

+ const StateClosed

+ const StateDisconnected

+ const StateIdle

+ const StateNew

+ type ConnectOption func(*ConnectOptions) error

+ func WithCleanSession(cleanSession bool) ConnectOption

+ func WithKeepalive(interval uint16) ConnectOption

+ func WithUserNamePassword(userName, password string) ConnectOption

+ func WithWill(will *Message) ConnectOption

+ type ConnectOptions struct

+ CleanSession bool

+ KeepAlive uint16

+ Password string

+ UserName string

+ Will *Message

+ type ConnectionReturnCode byte

+ const BadUserNameOrPassword

+ const ConnectionAccepted

+ const IdentifierRejected

+ const NotAuthorized

+ const ServerUnavailable

+ const UnacceptableProtocolVersion

+ func (c ConnectionReturnCode) String() string

+ type DialOption func(*DialOptions) error

+ func WithDialer(dialer *net.Dialer) DialOption

+ func WithTLSConfig(config *tls.Config) DialOption

+ type DialOptions struct

+ Dialer *net.Dialer

+ TLSConfig *tls.Config

+ type Handler interface

+ Serve func(*Message)

+ type HandlerFunc func(*Message)

+ func (h HandlerFunc) Serve(message *Message)

+ type Message struct

+ Dup bool

+ ID uint16

+ Payload []byte

+ QoS QoS

+ Retain bool

+ Topic string

+ type QoS uint8

+ const QoS0

+ const QoS1

+ const QoS2

+ const SubscribeFailure

+ type ServeMux struct

+ func (m *ServeMux) Handle(filter string, handler Handler) error

+ func (m *ServeMux) HandleFunc(filter string, handler func(*Message)) error

+ func (m *ServeMux) Serve(message *Message)

+ type Subscription struct

+ QoS QoS

+ Topic string