iotdevice

Documentation

Index

• Variables
• type Client
  • func New(transport transport.Transport, creds transport.Credentials, ...) (*Client, error)
  • func NewFromConnectionString(transport transport.Transport, cs string, opts ...ClientOption) (*Client, error)
  • func NewFromX509Cert(transport transport.Transport, deviceID, hostName string, crt *tls.Certificate, ...) (*Client, error)
  • func NewFromX509FromFile(transport transport.Transport, deviceID, hostname, certFile, keyFile string, ...) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Connect(ctx context.Context) error
  • func (c *Client) DeviceID() string
  • func (c *Client) RegisterMethod(ctx context.Context, name string, fn DirectMethodHandler) error
  • func (c *Client) RetrieveTwinState(ctx context.Context) (desired TwinState, reported TwinState, err error)
  • func (c *Client) SendEvent(ctx context.Context, payload []byte, opts ...SendOption) error
  • func (c *Client) SubscribeEvents(ctx context.Context) (*EventSub, error)
  • func (c *Client) SubscribeTwinUpdates(ctx context.Context) (*TwinStateSub, error)
  • func (c *Client) UnregisterMethod(name string)
  • func (c *Client) UnsubscribeEvents(sub *EventSub)
  • func (c *Client) UnsubscribeTwinUpdates(sub *TwinStateSub)
  • func (c *Client) UpdateTwinState(ctx context.Context, s TwinState) (int, error)
• type ClientOption
  • func WithLogger(l logger.Logger) ClientOption
• type DirectMethodHandler
• type EventSub
  • func (s *EventSub) C() <-chan *common.Message
  • func (s *EventSub) Err() error
• type SendOption
  • func WithSendCorrelationID(cid string) SendOption
  • func WithSendMessageID(mid string) SendOption
  • func WithSendProperties(m map[string]string) SendOption
  • func WithSendProperty(k, v string) SendOption
  • func WithSendQoS(qos int) SendOption
• type SharedAccessKeyCredentials
  • func ParseConnectionString(cs string) (*SharedAccessKeyCredentials, error)
  • func (c *SharedAccessKeyCredentials) GetCertificate() *tls.Certificate
  • func (c *SharedAccessKeyCredentials) GetDeviceID() string
  • func (c *SharedAccessKeyCredentials) GetHostName() string
• type TwinState
  • func (s TwinState) Version() int
• type TwinStateSub
  • func (s *TwinStateSub) C() <-chan TwinState
  • func (s *TwinStateSub) Err() error
• type X509Credentials
  • func (c *X509Credentials) GetCertificate() *tls.Certificate
  • func (c *X509Credentials) GetDeviceID() string
  • func (c *X509Credentials) GetHostName() string
  • func (c *X509Credentials) Token(resource string, lifetime time.Duration) (*common.SharedAccessSignature, error)

Variables

var ErrClosed = errors.New("closed")

ErrClosed the client is already closed.

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is iothub device client.

func New

func New(
	transport transport.Transport, creds transport.Credentials, opts ...ClientOption,
) (*Client, error)

New returns new iothub client.

func NewFromConnectionString

func NewFromConnectionString(
	transport transport.Transport, cs string, opts ...ClientOption,
) (*Client, error)

NewFromConnectionString creates a device client based on the given connection string.

func NewFromX509Cert

func NewFromX509Cert(
	transport transport.Transport,
	deviceID, hostName string, crt *tls.Certificate,
	opts ...ClientOption,
) (*Client, error)

func NewFromX509FromFile

func NewFromX509FromFile(
	transport transport.Transport,
	deviceID, hostname, certFile, keyFile string,
	opts ...ClientOption,
) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

Close closes transport connection.

func (*Client) Connect

func (c *Client) Connect(ctx context.Context) error

Connect connects to the iothub all subsequent calls will block until this function finishes with no error so it's clien's responsibility to connect in the background by running it in a goroutine and control other method invocations or call in in a synchronous way.

func (*Client) DeviceID

func (c *Client) DeviceID() string

DeviceID returns iothub device id.

func (*Client) RegisterMethod

func (c *Client) RegisterMethod(ctx context.Context, name string, fn DirectMethodHandler) error

RegisterMethod registers the given direct method handler, returns an error when method is already registered. If f returns an error and empty body its error string used as value of the error attribute in the result json.

func (*Client) RetrieveTwinState

func (c *Client) RetrieveTwinState(ctx context.Context) (desired TwinState, reported TwinState, err error)

RetrieveTwinState returns desired and reported twin device states.

func (*Client) SendEvent

func (c *Client) SendEvent(ctx context.Context, payload []byte, opts ...SendOption) error

SendEvent sends a device-to-cloud message. Panics when event is nil.

func (*Client) SubscribeEvents

func (c *Client) SubscribeEvents(ctx context.Context) (*EventSub, error)

SubscribeEvents subscribes to cloud-to-device events and returns a subscription struct.

func (*Client) SubscribeTwinUpdates

func (c *Client) SubscribeTwinUpdates(ctx context.Context) (*TwinStateSub, error)

SubscribeTwinUpdates registers fn as a desired state changes handler.

func (*Client) UnregisterMethod

func (c *Client) UnregisterMethod(name string)

UnregisterMethod unregisters the named method.

func (*Client) UnsubscribeEvents

func (c *Client) UnsubscribeEvents(sub *EventSub)

UnsubscribeEvents makes the given subscription to stop receiving messages.

func (*Client) UnsubscribeTwinUpdates

func (c *Client) UnsubscribeTwinUpdates(sub *TwinStateSub)

UnsubscribeTwinUpdates unsubscribes the given handler from twin state updates.

func (*Client) UpdateTwinState

func (c *Client) UpdateTwinState(ctx context.Context, s TwinState) (int, error)

UpdateTwinState updates twin device's state and returns new version. To remove any attribute set its value to nil.

type ClientOption

type ClientOption func(c *Client)

ClientOption is a client configuration option.

func WithLogger

func WithLogger(l logger.Logger) ClientOption

WithLogger changes default logger, default it an stdout logger.

type DirectMethodHandler

type DirectMethodHandler func(p map[string]interface{}) (map[string]interface{}, error)

DirectMethodHandler handles direct method invocations.

type EventSub

type EventSub struct {
	// contains filtered or unexported fields
}

func (*EventSub) C

func (s *EventSub) C() <-chan *common.Message

func (*EventSub) Err

func (s *EventSub) Err() error

type SendOption

type SendOption func(msg *common.Message) error

SendOption is a send event options.

func WithSendCorrelationID

func WithSendCorrelationID(cid string) SendOption

WithSendCorrelationID sets message correlation id.

func WithSendMessageID

func WithSendMessageID(mid string) SendOption

WithSendMessageID sets message id.

func WithSendProperties

func WithSendProperties(m map[string]string) SendOption

WithSendProperties same as `WithSendProperty` but accepts map of keys and values.

func WithSendProperty

func WithSendProperty(k, v string) SendOption

WithSendProperty sets a message option.

func WithSendQoS

func WithSendQoS(qos int) SendOption

WithSendQoS sets the quality of service (MQTT only). Only 0 and 1 values are supported, defaults to 1.

type SharedAccessKeyCredentials

type SharedAccessKeyCredentials struct {
	DeviceID string
	common.SharedAccessKey
}

func ParseConnectionString

func ParseConnectionString(cs string) (*SharedAccessKeyCredentials, error)

func (*SharedAccessKeyCredentials) GetCertificate

func (c *SharedAccessKeyCredentials) GetCertificate() *tls.Certificate

func (*SharedAccessKeyCredentials) GetDeviceID

func (c *SharedAccessKeyCredentials) GetDeviceID() string

func (*SharedAccessKeyCredentials) GetHostName

func (c *SharedAccessKeyCredentials) GetHostName() string

type TwinState

type TwinState map[string]interface{}

TwinState is both desired and reported twin device's state.

func (TwinState) Version

func (s TwinState) Version() int

Version is state version.

type TwinStateSub

type TwinStateSub struct {
	// contains filtered or unexported fields
}

func (*TwinStateSub) C

func (s *TwinStateSub) C() <-chan TwinState

func (*TwinStateSub) Err

func (s *TwinStateSub) Err() error

type X509Credentials

type X509Credentials struct {
	HostName    string
	DeviceID    string
	Certificate *tls.Certificate
}

func (*X509Credentials) GetCertificate

func (c *X509Credentials) GetCertificate() *tls.Certificate

func (*X509Credentials) GetDeviceID

func (c *X509Credentials) GetDeviceID() string

func (*X509Credentials) GetHostName

func (c *X509Credentials) GetHostName() string

func (*X509Credentials) Token

func (c *X509Credentials) Token(
	resource string, lifetime time.Duration,
) (*common.SharedAccessSignature, error)