Versions in this module Expand all Collapse all v0 v0.9.2 Oct 11, 2023 Changes in this version + const DefaultQoS + var ErrNotImplemented = errors.New("not implemented") + type ModuleTransport struct + func NewModuleTransport(opts ...TransportOption) *ModuleTransport + func (tr *ModuleTransport) Connect(ctx context.Context, creds transport.Credentials) error + func (tr *ModuleTransport) Send(ctx context.Context, msg *common.Message) error + func (tr *ModuleTransport) SubscribeEvents(ctx context.Context, mux transport.MessageDispatcher) error + func (tr *ModuleTransport) SubscribeTwinUpdates(ctx context.Context, mux transport.TwinStateDispatcher) error + type Transport struct + func New(opts ...TransportOption) *Transport + func (tr *Transport) Close() error + func (tr *Transport) Connect(ctx context.Context, creds transport.Credentials) error + func (tr *Transport) CreateModule(ctx context.Context, m *iotservice.Module) (*iotservice.Module, error) + func (tr *Transport) DeleteModule(ctx context.Context, m *iotservice.Module) error + func (tr *Transport) GetBlobSharedAccessSignature(ctx context.Context, blobName string) (string, string, error) + func (tr *Transport) GetModule(ctx context.Context, moduleID string) (*iotservice.Module, error) + func (tr *Transport) ListModules(ctx context.Context) ([]*iotservice.Module, error) + func (tr *Transport) NotifyUploadComplete(ctx context.Context, correlationID string, success bool, statusCode int, ...) 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) UpdateModule(ctx context.Context, m *iotservice.Module) (*iotservice.Module, error) + func (tr *Transport) UpdateTwinProperties(ctx context.Context, b []byte) (int, error) + func (tr *Transport) UploadToBlob(ctx context.Context, sasURI string, file io.Reader, size int64) error + type TransportOption func(tr *Transport) + func WithClientOptionsConfig(fn func(opts *mqtt.ClientOptions)) TransportOption + func WithLogger(l logger.Logger) TransportOption + func WithModelID(modelID string) TransportOption + func WithWebSocket(enable bool) TransportOption
Go to main page