Add TelemetryPolicy

sdk/core/src/policies/mod.rs

@@ -1,3 +1,5 @@
 mod retry_policy;
+mod telemetry_policy;
 
 pub use retry_policy::{RetryOptions, RetryPolicy};
+pub use telemetry_policy::{TelemetryOptions, TelemetryPolicy};

sdk/core/src/policies/retry_policy.rs

@@ -33,13 +33,14 @@ impl Policy for RetryPolicy {
         request: &mut Request,
         next: &[Arc<dyn Policy>],
     ) -> PolicyResult<Response> {
-        let retries = self.options.num_retries;
+        let mut retries = self.options.num_retries;
         let mut last_result = next[0].send(ctx.clone(), request, &next[1..]).await;
         loop {
             if last_result.is_ok() || retries == 0 {
                 return last_result;
             }
 
+            retries -= 1usize;
             last_result = next[0].send(ctx.clone(), request, &next[1..]).await;
         }
     }

sdk/core/src/policies/telemetry_policy.rs

@@ -0,0 +1,39 @@
+use crate::{Context, Policy, PolicyResult, Request, Response};
+
+use async_trait::async_trait;
+use std::sync::Arc;
+
+#[derive(Clone, Debug)]
+pub struct TelemetryOptions {
+    application_id: Option<String>,
+}
+
+impl TelemetryOptions {
+    pub fn new(application_id: Option<String>) -> Self {
+        Self { application_id }
+    }
+}
+
+#[derive(Clone, Debug)]
+pub struct TelemetryPolicy {
+    options: TelemetryOptions,
+}
+
+impl TelemetryPolicy {
+    pub fn new(options: TelemetryOptions) -> Self {
+        Self { options }
+    }
+}
+
+#[async_trait]
+impl Policy for TelemetryPolicy {
+    async fn send(
+        &self,
+        ctx: Context,
+        request: &mut Request,
+        next: &[Arc<dyn Policy>],
+    ) -> PolicyResult<Response> {
+        // TODO
+        next[0].send(ctx.clone(), request, &next[1..]).await
+    }
+}