Documentation
¶
Index ¶
- Constants
- func New(opts ...TransportOption) transport.Transport
- type Transport
- func (tr *Transport) Close() error
- func (tr *Transport) Connect(ctx context.Context, creds transport.Credentials) error
- func (tr *Transport) RegisterDirectMethods(ctx context.Context, mux transport.MethodDispatcher) error
- func (tr *Transport) RetrieveTwinProperties(ctx context.Context) ([]byte, error)
- func (tr *Transport) Send(ctx context.Context, msg *common.Message) error
- func (tr *Transport) SetLogger(logger logger.Logger)
- func (tr *Transport) SubscribeEvents(ctx context.Context, mux transport.MessageDispatcher) error
- func (tr *Transport) SubscribeTwinUpdates(ctx context.Context, mux transport.TwinStateDispatcher) error
- func (tr *Transport) UpdateTwinProperties(ctx context.Context, b []byte) (int, error)
- type TransportOption
Constants ¶
View Source
const DefaultQoS = 1
DefaultQoS is the default quality of service value.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(opts ...TransportOption) transport.Transport
New returns new Transport transport. See more: https://docs.microsoft.com/en-us/azure/iot-hub/iot-hub-mqtt-support
Types ¶
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
func (*Transport) RegisterDirectMethods ¶
func (*Transport) RetrieveTwinProperties ¶
func (*Transport) SubscribeEvents ¶
func (*Transport) SubscribeTwinUpdates ¶
type TransportOption ¶
type TransportOption func(tr *Transport)
TransportOption is a transport configuration option.
func WithClientOptionsConfig ¶
func WithClientOptionsConfig(fn func(opts *mqtt.ClientOptions)) TransportOption
WithClientOptionsConfig configures the mqtt client options structure, use it only when you know EXACTLY what you're doing, because changing some of opts attributes may lead to unexpected behaviour.
Typical usecase is to change adjust connect or reconnect interval.
func WithLogger ¶
func WithLogger(l logger.Logger) TransportOption
WithLogger sets logger for errors and warnings plus debug messages when it's enabled.
Source Files
Click to show internal directories.
Click to hide internal directories.