Prepare eventhubs for beta (Azure#2085)

* Added 'send' verb to eventhubs; publish types from eventhubs crate

* Added example for writing events

* Added a couple more samples; moved models into a separate module

* Refactored receiving messages
* Added timeout receiving events

* Refactored examples in readme documentation

* Renamed message_receiver to event_receiver

* Simplify use of timeout function

* Limit receive_lots_of_events to 10 seconds of runtime, clarified a couple of properties

* Defer calculating eventdata properties in ReceiveEventData until they are consumed.

* Distinguish AMQP message from EH event

* Renamed batch create events to batch produce events to be consistent with naming

* PR feedback

* Analysis fixes

---------

Co-authored-by: Copilot <[email protected]>

Author: LarryOsterman

.vscode/cspell.json

@@ -77,11 +77,21 @@
       "path": "../eng/dict/rust-custom.txt",
       "noSuggest": true
     },
+    {
+      "name": "azure_core_amqp",
+      "path": "../sdk/core/azure_core_amqp/.dict.txt",
+      "noSuggest": true
+    },
     {
       "name": "cosmos",
       "path": "../sdk/cosmos/.dict.txt",
       "noSuggest": true
     },
+    {
+      "name": "eventhubs",
+      "path": "../sdk/eventhubs/.dict.txt",
+      "noSuggest": true
+    },
     {
       "name": "identity",
       "path": "../sdk/identity/.dict.txt",
@@ -123,6 +133,22 @@
         "rust-custom"
       ]
     },
+    {
+      "filename": "sdk/core/azure_core_amqp/**",
+      "dictionaries": [
+        "crates",
+        "rust-custom",
+        "azure_core_amqp"
+      ]
+    },
+    {
+      "filename": "sdk/eventhubs/**",
+      "dictionaries": [
+        "crates",
+        "rust-custom",
+        "eventhubs"
+      ]
+    },
     {
       "filename": "sdk/identity/**",
       "dictionaries": [
@@ -163,4 +189,4 @@
       ]
     }
   ]
-}
+}

sdk/core/azure_core_amqp/.dict.txt

@@ -0,0 +1,5 @@
+mgmt
+sasl
+sastoken
+smallulong
+smalluint

sdk/core/azure_core_amqp/src/cbs.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp sasl sastoken
 
 use azure_core::error::Result;
 

sdk/core/azure_core_amqp/src/connection.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp sasl
 
 use super::value::{AmqpOrderedMap, AmqpSymbol, AmqpValue};
 use azure_core::{error::Result, Url};

sdk/core/azure_core_amqp/src/error.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp
 
 pub enum ErrorKind {
     AmqpReceiverAlreadyAttached,

sdk/core/azure_core_amqp/src/fe2o3/connection.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp sasl
 
 use crate::connection::{AmqpConnectionApis, AmqpConnectionOptions};
 use crate::value::{AmqpOrderedMap, AmqpSymbol, AmqpValue};

sdk/core/azure_core_amqp/src/fe2o3/error.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words thiserror amqp
 
 macro_rules! impl_from_external_error {
     ($(($amqp_error:ident, $foreign_error:ty)),*) => {

sdk/core/azure_core_amqp/src/fe2o3/management.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp servicebus eventhub mgmt
 
 use std::borrow::BorrowMut;
 

sdk/core/azure_core_amqp/src/fe2o3/messaging/message_fields.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp servicebus eventhub mgmt
 
 use crate::{
     messaging::{

sdk/core/azure_core_amqp/src/fe2o3/messaging/message_source.rs

@@ -1,6 +1,5 @@
 // Copyright (c) Microsoft Corporation. All Rights reserved
 // Licensed under the MIT license.
-// cspell: words amqp servicebus eventhub mgmt
 
 use fe2o3_amqp_types::definitions::Fields;