feat(server): Implement an HTTP outcomes producer (#592)

Add support for generating and forwarding Outcomes for non processing relays.

Author: RaduW

CHANGELOG.md

@@ -19,6 +19,7 @@ We have switched to [CalVer](https://calver.org/)! Relay's version is always in
 
 **Internal**:
 
+- Add support for Outcomes generation in non processing relays.([#592](https://github.com/getsentry/relay/pull/592))
 - Ignore non-Rust folders for faster rebuilding and testing. ([#578](https://github.com/getsentry/relay/pull/578))
 - Invalid session payloads are now logged for SDK debugging. ([#584](https://github.com/getsentry/relay/pull/584), [#591](https://github.com/getsentry/relay/pull/591))
 - Remove unused `rev` from project state. ([#586](https://github.com/getsentry/relay/pull/586))

relay-config/src/config.rs

@@ -351,9 +351,6 @@ pub struct Relay {
     pub tls_identity_path: Option<PathBuf>,
     /// Password for the PKCS12 archive.
     pub tls_identity_password: Option<String>,
-    /// Controls whether outcomes will be emitted when processing is disabled.
-    /// Processing relays always emit outcomes (for backwards compatibility).
-    pub emit_outcomes: bool,
 }
 
 impl Default for Relay {
@@ -366,7 +363,6 @@ impl Default for Relay {
             tls_port: None,
             tls_identity_path: None,
             tls_identity_password: None,
-            emit_outcomes: false,
         }
     }
 }
@@ -710,6 +706,31 @@ impl Default for Processing {
     }
 }
 
+/// Outcome generation specific configuration values.
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(default)]
+pub struct Outcomes {
+    /// Controls whether outcomes will be emitted when processing is disabled.
+    /// Processing relays always emit outcomes (for backwards compatibility).
+    pub emit_outcomes: bool,
+    /// The maximum number of outcomes that are batched before being sent
+    /// via http to the upstream (only applies to non processing relays)
+    pub batch_size: usize,
+    /// The maximum time interval (in milliseconds) that an outcome may be batched
+    /// via http to the upstream (only applies to non processing relays)
+    pub batch_interval: u64,
+}
+
+impl Default for Outcomes {
+    fn default() -> Self {
+        Outcomes {
+            emit_outcomes: false,
+            batch_size: 1000,
+            batch_interval: 500,
+        }
+    }
+}
+
 /// Minimal version of a config for dumping out.
 #[derive(Serialize, Deserialize, Debug, Default)]
 pub struct MinimalConfig {
@@ -757,6 +778,8 @@ struct ConfigValues {
     sentry: Sentry,
     #[serde(default)]
     processing: Processing,
+    #[serde(default)]
+    outcomes: Outcomes,
 }
 
 impl ConfigObject for ConfigValues {
@@ -838,7 +861,7 @@ impl Config {
                 "true" | "1" => processing.enabled = true,
                 "false" | "0" | "" => processing.enabled = false,
                 _ => {
-                    return Err(ConfigError::new(ConfigErrorKind::InvalidValue).field("processing"))
+                    return Err(ConfigError::new(ConfigErrorKind::InvalidValue).field("processing"));
                 }
             }
         }
@@ -1044,7 +1067,17 @@ impl Config {
 
     /// Returns the emit_outcomes flag
     pub fn emit_outcomes(&self) -> bool {
-        self.values.relay.emit_outcomes
+        self.values.outcomes.emit_outcomes
+    }
+
+    /// Returns the maximum number of outcomes that are batched before being sent
+    pub fn outcome_batch_size(&self) -> usize {
+        self.values.outcomes.batch_size
+    }
+
+    /// Returns the maximum interval that an outcome may be batched
+    pub fn outcome_batch_interval(&self) -> Duration {
+        Duration::from_millis(self.values.outcomes.batch_interval)
     }
 
     /// Returns the log level.