Sfoglia il codice sorgente

improve(type): refine the message header types

JianBo He 5 anni fa
parent
commit
89377aeaa2
1 ha cambiato i file con 8 aggiunte e 2 eliminazioni
  1. 8 2
      src/emqx_types.erl

+ 8 - 2
src/emqx_types.erl

@@ -181,9 +181,15 @@
 -type(subscriber() :: {pid(), subid()}).
 -type(payload() :: binary() | iodata()).
 -type(message() :: #message{}).
--type(flag() :: atom()).
+-type(flag() :: sys | dup | retain | atom()).
 -type(flags() :: #{flag() := boolean()}).
--type(headers() :: map()).
+-type(headers() :: #{proto_ver => ver(),
+                     protocol => protocol(),
+                     username => username(),
+                     peerhost => peerhost(),
+                     properties => properties(),
+                     atom() => term()}).
+
 -type(banned() :: #banned{}).
 -type(deliver() :: {deliver, topic(), message()}).
 -type(delivery() :: #delivery{}).