Merge remote-tracking branch 'origin/master' into stream-timestamp-offsetstream-timestamp-offset

1 files changed, 70 insertions, 0 deletions

diff --git a/deps/rabbitmq_stream/include/rabbit_stream.hrl b/deps/rabbitmq_stream/include/rabbit_stream.hrl
new file mode 100644
index 0000000000..0593893d93
--- /dev/null
+++ b/deps/rabbitmq_stream/include/rabbit_stream.hrl
@@ -0,0 +1,70 @@
+-define(COMMAND_PUBLISH, 0).
+-define(COMMAND_PUBLISH_CONFIRM, 1).
+-define(COMMAND_SUBSCRIBE, 2).
+-define(COMMAND_DELIVER, 3).
+-define(COMMAND_CREDIT, 4).
+-define(COMMAND_UNSUBSCRIBE, 5).
+-define(COMMAND_PUBLISH_ERROR, 6).
+-define(COMMAND_METADATA_UPDATE, 7).
+-define(COMMAND_METADATA, 8).
+-define(COMMAND_SASL_HANDSHAKE, 9).
+-define(COMMAND_SASL_AUTHENTICATE, 10).
+-define(COMMAND_TUNE, 11).
+-define(COMMAND_OPEN, 12).
+-define(COMMAND_CLOSE, 13).
+-define(COMMAND_HEARTBEAT, 14).
+-define(COMMAND_PEER_PROPERTIES, 15).
+-define(COMMAND_COMMIT_OFFSET, 16).
+-define(COMMAND_QUERY_OFFSET, 17).
+-define(COMMAND_CREATE_STREAM, 998).
+-define(COMMAND_DELETE_STREAM, 999).
+
+-define(VERSION_0, 0).
+
+-define(RESPONSE_CODE_OK, 0).
+-define(RESPONSE_CODE_STREAM_DOES_NOT_EXIST, 1).
+-define(RESPONSE_CODE_SUBSCRIPTION_ID_ALREADY_EXISTS, 2).
+-define(RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST, 3).
+-define(RESPONSE_CODE_STREAM_ALREADY_EXISTS, 4).
+-define(RESPONSE_CODE_STREAM_NOT_AVAILABLE, 5).
+-define(RESPONSE_SASL_MECHANISM_NOT_SUPPORTED, 6).
+-define(RESPONSE_AUTHENTICATION_FAILURE, 7).
+-define(RESPONSE_SASL_ERROR, 8).
+-define(RESPONSE_SASL_CHALLENGE, 9).
+-define(RESPONSE_SASL_AUTHENTICATION_FAILURE_LOOPBACK, 10).
+-define(RESPONSE_VHOST_ACCESS_FAILURE, 11).
+-define(RESPONSE_CODE_UNKNOWN_FRAME, 12).
+-define(RESPONSE_CODE_FRAME_TOO_LARGE, 13).
+-define(RESPONSE_CODE_INTERNAL_ERROR, 14).
+-define(RESPONSE_CODE_ACCESS_REFUSED, 15).
+-define(RESPONSE_CODE_PRECONDITION_FAILED, 16).
+
+-define(OFFSET_TYPE_FIRST, 0).
+-define(OFFSET_TYPE_LAST, 1).
+-define(OFFSET_TYPE_NEXT, 2).
+-define(OFFSET_TYPE_OFFSET, 3).
+-define(OFFSET_TYPE_TIMESTAMP, 4).
+
+-define(DEFAULT_INITIAL_CREDITS, 50000).
+-define(DEFAULT_CREDITS_REQUIRED_FOR_UNBLOCKING, 12500).
+-define(DEFAULT_FRAME_MAX, 1048576). %% 1 MiB
+-define(DEFAULT_HEARTBEAT, 60). %% 60 seconds
+
+-define(INFO_ITEMS,
+  [conn_name,
+    port,
+    peer_port,
+    host,
+    peer_host,
+    user,
+    vhost,
+    subscriptions,
+    connection_state,
+    auth_mechanism,
+    heartbeat,
+    frame_max,
+    client_properties,
+    connected_at
+    ]).
+
+-define(STREAM_GUIDE_URL, <<"https://rabbitmq.com/stream.html">>).
\ No newline at end of file