kvasir_pub_sub v0.0.1

View Source Kvasir.PubSub.Protocols.MQTT (kvasir_pub_sub v0.0.1)

Link to this section Summary

Types

control_type()
packet()

Functions

pong(transport, socket)
publish(transport, socket, data)
read(transport, socket, timeout \\ 15000)
write(transport, socket, package)

Link to this section Types

Link to this type

control_type()

View Source 
@type control_type() ::
  :connect
  | :connack
  | :publish
  | :puback
  | :pubrec
  | :pubrel
  | :pubcomp
  | :subscribe
  | :suback
  | :unsubscribe
  | :unsuback
  | :pingreq
  | :pingresp
  | :disconnect
Link to this type

packet()

View Source 
@type packet() ::
  {:mqtt, type :: control_type()}
  | {:mqtt, type :: control_type(), payload :: Keyword.t()}

Link to this section Functions

Link to this function

pong(transport, socket)

View Source
Link to this function

publish(transport, socket, data)

View Source
Link to this function

read(transport, socket, timeout \\ 15000)

View Source 
@spec read(atom(), port(), timeout :: pos_integer()) ::
  {:ok, MQTT.packet()} | {:error, atom()}
Link to this function

write(transport, socket, package)

View Source