shorten operation names

sdk/eventgrid/azure-eventgrid/README.md

@@ -12,7 +12,7 @@ Azure Event Grid is a fully-managed intelligent event routing service that allow
 
 ## _Disclaimer_
 
-This is a beta release of Azure EventGrid's `EventGridClient`. `EventGridClient` supports `send`, `receive_cloud_events`, `acknowledge_cloud_events` , `release_cloud_events`, `reject_cloud_events`, and `renew_cloud_event_locks` operations. Please refer to the [samples](https://github.com/Azure/azure-sdk-for-python/tree/feature/eventgrid/sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples) for further information.
+This is a beta release of Azure EventGrid's `EventGridClient`. `EventGridClient` supports `send`, `receive`, `acknowledge` , `release`, `reject`, and `renew_locks` operations. Please refer to the [samples](https://github.com/Azure/azure-sdk-for-python/tree/feature/eventgrid/sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples) for further information.
 
 ## Getting started
 
@@ -316,32 +316,32 @@ sub_name = os.environ["EVENTGRID_EVENT_SUBSCRIPTION_NAME"]
 credential = AzureKeyCredential(key)
 client = EventGridClient(endpoint, credential, level=ClientLevel.STANDARD)
 
-events = client.receive_cloud_events(topic_name, sub_name, max_events=4)
+events = client.receive(topic_name, sub_name, max_events=4)
 
 for e in events:
     renew_tokens = e.broker_properties.lock_token
-    renew_result = client.renew_cloud_events_lock(
+    renew_result = client.renew_locks(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         lock_tokens=renew_tokens,
     )
 
 release_tokens = events[0].broker_properties.lock_token
-release_result = client.release_cloud_events(
+release_result = client.release(
     topic_name=TOPIC_NAME,
     subscription_name=EVENT_SUBSCRIPTION_NAME,
     lock_tokens=release_tokens,
 )
 
 ack_tokens = events[1].broker_properties.lock_token
-ack_result = client.acknowledge_cloud_events(
+ack_result = client.acknowledge(
     topic_name=TOPIC_NAME,
     subscription_name=EVENT_SUBSCRIPTION_NAME,
     lock_tokens=ack_tokens,
 )
 
 reject_tokens = events[2].broker_properties.lock_token
-reject_result = client.reject_cloud_events(
+reject_result = client.reject(
     topic_name=TOPIC_NAME,
     subscription_name=EVENT_SUBSCRIPTION_NAME,
     lock_tokens=reject_tokens,

sdk/eventgrid/azure-eventgrid/azure/eventgrid/_operations/_patch.py

@@ -417,7 +417,7 @@ def _publish(
 
     @use_standard_only
     @distributed_trace
-    def receive_cloud_events(
+    def receive(
         self,
         topic_name: str,
         subscription_name: str,
@@ -468,7 +468,7 @@ def receive_cloud_events(
 
     @use_standard_only
     @distributed_trace
-    def acknowledge_cloud_events(
+    def acknowledge(
         self,
         topic_name: str,
         subscription_name: str,
@@ -504,7 +504,7 @@ def acknowledge_cloud_events(
     @api_version_validation(
         params_added_on={"2023-10-01-preview": ["release_delay_in_seconds"]},
     )
-    def release_cloud_events(
+    def release(
         self,
         topic_name: str,
         subscription_name: str,
@@ -541,7 +541,7 @@ def release_cloud_events(
 
     @use_standard_only
     @distributed_trace
-    def reject_cloud_events(
+    def reject(
         self,
         topic_name: str,
         subscription_name: str,
@@ -576,7 +576,7 @@ def reject_cloud_events(
     @api_version_validation(
         method_added_on="2023-10-01-preview",
     )
-    def renew_cloud_event_locks(
+    def renew_locks(
         self,
         topic_name: str,
         subscription_name: str,

sdk/eventgrid/azure-eventgrid/azure/eventgrid/aio/_operations/_patch.py

@@ -248,7 +248,7 @@ def _http_response_error_handler(self, exception, level):
 
     @use_standard_only
     @distributed_trace_async
-    async def receive_cloud_events(
+    async def receive(
         self,
         topic_name: str,
         subscription_name: str,
@@ -299,7 +299,7 @@ async def receive_cloud_events(
 
     @use_standard_only
     @distributed_trace_async
-    async def acknowledge_cloud_events(
+    async def acknowledge(
         self,
         topic_name: str,
         subscription_name: str,
@@ -332,7 +332,7 @@ async def acknowledge_cloud_events(
     @api_version_validation(
         params_added_on={"2023-10-01-preview": ["release_delay_in_seconds"]},
     )
-    async def release_cloud_events(
+    async def release(
         self,
         topic_name: str,
         subscription_name: str,
@@ -369,7 +369,7 @@ async def release_cloud_events(
 
     @use_standard_only
     @distributed_trace_async
-    async def reject_cloud_events(
+    async def reject(
         self,
         topic_name: str,
         subscription_name: str,
@@ -401,7 +401,7 @@ async def reject_cloud_events(
     @api_version_validation(
         method_added_on="2023-10-01-preview",
     )
-    async def renew_cloud_event_locks(
+    async def renew_locks(
         self,
         topic_name: str,
         subscription_name: str,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_acknowledge_operation_async.py

@@ -37,7 +37,7 @@ async def run():
     try:
         async with client:
             lock_tokens = ["token"]
-            ack_events = await client.acknowledge_cloud_events(
+            ack_events = await client.acknowledge(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 lock_tokens=lock_tokens,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_all_operations_async.py

@@ -66,7 +66,7 @@ async def run():
 
         # Receive Published Cloud Events
         try:
-            receive_results = await client.receive_cloud_events(
+            receive_results = await client.receive(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 max_events=10,
@@ -95,7 +95,7 @@ async def run():
 
         if len(release_events) > 0:
             try:
-                release_result = await client.release_cloud_events(
+                release_result = await client.release(
                     topic_name=TOPIC_NAME,
                     subscription_name=EVENT_SUBSCRIPTION_NAME,
                     lock_tokens=release_events,
@@ -108,7 +108,7 @@ async def run():
 
         if len(acknowledge_events) > 0:
             try:
-                ack_result = await client.acknowledge_cloud_events(
+                ack_result = await client.acknowledge(
                     topic_name=TOPIC_NAME,
                     subscription_name=EVENT_SUBSCRIPTION_NAME,
                     lock_tokens=acknowledge_events,
@@ -121,7 +121,7 @@ async def run():
 
         if len(reject_events) > 0:
             try:
-                reject_result = await client.reject_cloud_events(
+                reject_result = await client.reject(
                     topic_name=TOPIC_NAME,
                     subscription_name=EVENT_SUBSCRIPTION_NAME,
                     lock_tokens=reject_events,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_binary_mode_async.py

@@ -47,7 +47,7 @@ async def run():
             cloud_event = CloudEvent(data=json.dumps({"hello":"data"}).encode("utf-8"), source="https://example.com", type="example", datacontenttype="application/json")
             await client.send(topic_name=TOPIC_NAME, events=cloud_event, binary_mode=True)
 
-            receive_result = await client.receive_cloud_events(
+            receive_result = await client.receive(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 max_events=10,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_publish_receive_renew_async.py

@@ -42,13 +42,13 @@ async def run():
             await client.send(topic_name=TOPIC_NAME, events=cloud_event)
 
             # Receive CloudEvents and parse out lock tokens
-            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=10, max_wait_time=10)
+            receive_result = await client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=10, max_wait_time=10)
             lock_tokens_to_release = []
             for item in receive_result.value:
                 lock_tokens_to_release.append(item.broker_properties.lock_token)
 
             # Renew lock tokens
-            renew_events = await client.renew_cloud_event_locks(
+            renew_events = await client.renew_locks(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 lock_tokens=lock_tokens_to_release,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_publish_release_receive_async.py

@@ -42,15 +42,15 @@ async def run():
             await client.send(topic_name=TOPIC_NAME, events=cloud_event)
 
             # Receive CloudEvents and parse out lock tokens
-            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+            receive_result = await client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
             lock_tokens_to_release = []
             for item in receive_result.value:
                 lock_tokens_to_release.append(item.broker_properties.lock_token)
 
             print("Received events:", receive_result.value)
 
             # Release a LockToken
-            release_events = await client.release_cloud_events(
+            release_events = await client.release(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 release_delay_in_seconds=60,
@@ -59,11 +59,11 @@ async def run():
             print("Released Event:", release_events)
 
             # Receive CloudEvents again
-            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+            receive_result = await client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
             print("Received events after release:", receive_result.value)
 
             # Acknowledge a LockToken that was released
-            acknowledge_events = await client.acknowledge_cloud_events(
+            acknowledge_events = await client.acknowledge(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 lock_tokens=lock_tokens_to_release,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_receive_operation_async.py

@@ -36,7 +36,7 @@ async def run():
     # Receive CloudEvents
     try:
         async with client:
-            receive_result = await client.receive_cloud_events(
+            receive_result = await client.receive(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 max_events=10,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_reject_operation_async.py

@@ -37,7 +37,7 @@ async def run():
     try:
         async with client:
             tokens = ["token"]
-            reject_events = await client.reject_cloud_events(
+            reject_events = await client.reject(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 lock_tokens=tokens,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_release_operation_async.py

@@ -37,7 +37,7 @@ async def run():
     try:
         async with client:
             tokens = ["token"]
-            release_events = await client.release_cloud_events(
+            release_events = await client.release(
                 topic_name=TOPIC_NAME,
                 subscription_name=EVENT_SUBSCRIPTION_NAME,
                 release_delay_in_seconds=10,

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_renew_locks_operation_async.py

@@ -35,7 +35,7 @@ async def run():
     # Renew a lockToken
     try:
         lock_tokens = ["token"]
-        release_events = await client.renew_cloud_event_locks(
+        release_events = await client.renew_locks(
             topic_name=TOPIC_NAME,
             subscription_name=EVENT_SUBSCRIPTION_NAME,
             lock_tokens=lock_tokens,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_acknowledge_operation.py

@@ -34,7 +34,7 @@
 # Acknowledge a CloudEvent
 try:
     lock_tokens = ["token"]
-    ack_events = client.acknowledge_cloud_events(
+    ack_events = client.acknowledge(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         lock_tokens=lock_tokens,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_all_operations.py

@@ -59,7 +59,7 @@
 
 # Receive Published Cloud Events
 try:
-    receive_results = client.receive_cloud_events(
+    receive_results = client.receive(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         max_events=10,
@@ -88,7 +88,7 @@
 
 if len(release_events) > 0:
     try:
-        release_result = client.release_cloud_events(
+        release_result = client.release(
             topic_name=TOPIC_NAME,
             subscription_name=EVENT_SUBSCRIPTION_NAME,
             lock_tokens=release_events,
@@ -101,7 +101,7 @@
 
 if len(acknowledge_events) > 0:
     try:
-        ack_result = client.acknowledge_cloud_events(
+        ack_result = client.acknowledge(
             topic_name=TOPIC_NAME,
             subscription_name=EVENT_SUBSCRIPTION_NAME,
             lock_tokens=acknowledge_events,
@@ -114,7 +114,7 @@
 
 if len(reject_events) > 0:
     try:
-        reject_result = client.reject_cloud_events(
+        reject_result = client.reject(
             topic_name=TOPIC_NAME,
             subscription_name=EVENT_SUBSCRIPTION_NAME,
             lock_tokens=reject_events,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_binary_mode.py

@@ -45,7 +45,7 @@
     client.send(topic_name=TOPIC_NAME, events=cloud_event, binary_mode=True)
 
     # Receive a CloudEvent
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=100)
+    receive_result = client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=100)
     for receive_details in receive_result.value:
         cloud_event_received = receive_details.event
         print("CloudEvent: ", cloud_event_received)

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_publish_receive_renew.py

@@ -39,13 +39,13 @@
     client.send(topic_name=TOPIC_NAME, events=cloud_event)
 
     # Receive CloudEvents and parse out lock tokens
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=10, max_wait_time=10)
+    receive_result = client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=10, max_wait_time=10)
     lock_tokens_to_renew = []
     for item in receive_result.value:
         lock_tokens_to_renew.append(item.broker_properties.lock_token)
 
     # Renew a lock token
-    renew_events = client.renew_cloud_event_locks(
+    renew_events = client.renew_locks(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         lock_tokens=lock_tokens_to_renew,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_publish_release_receive.py

@@ -39,15 +39,15 @@
     client.send(topic_name=TOPIC_NAME, events=cloud_event)
 
     # Receive CloudEvents and parse out lock tokens
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+    receive_result = client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
     lock_tokens_to_release = []
     for item in receive_result.value:
         lock_tokens_to_release.append(item.broker_properties.lock_token)
 
     print("Received events:", receive_result.value)
 
     # Release a LockToken
-    release_events = client.release_cloud_events(
+    release_events = client.release(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         release_delay_in_seconds=60,
@@ -56,11 +56,11 @@
     print("Released Event:", release_events)
 
     # Receive CloudEvents again
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+    receive_result = client.receive(topic_name=TOPIC_NAME, subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
     print("Received events after release:", receive_result.value)
 
     # Acknowledge a LockToken that was released
-    acknowledge_events = client.acknowledge_cloud_events(
+    acknowledge_events = client.acknowledge(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         lock_tokens=lock_tokens_to_release,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_receive_operation.py

@@ -33,7 +33,7 @@
 
 # Receive CloudEvents
 try:
-    receive_result = client.receive_cloud_events(
+    receive_result = client.receive(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         max_events=10,

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_reject_operation.py

@@ -33,7 +33,7 @@
 # Release a LockToken
 try:
     lock_tokens = ["token"]
-    reject_events = client.reject_cloud_events(
+    reject_events = client.reject(
         topic_name=TOPIC_NAME,
         subscription_name=EVENT_SUBSCRIPTION_NAME,
         lock_tokens=lock_tokens,