Struct relay_filter::ErrorMessagesFilterConfig
source · pub struct ErrorMessagesFilterConfig {
- pub patterns: GlobPatterns,
+ pub patterns: GlobPatterns,
}Expand description
Configuration for the error messages filter.
-Fields§
§patterns: GlobPatternsList of error message patterns that will be filtered.
+Fields§
§patterns: GlobPatternsList of error message patterns that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ErrorMessagesFilterConfig
impl Clone for ErrorMessagesFilterConfig
source§fn clone(&self) -> ErrorMessagesFilterConfig
fn clone(&self) -> ErrorMessagesFilterConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Debug for ErrorMessagesFilterConfig
impl Debug for ErrorMessagesFilterConfig
source§impl Default for ErrorMessagesFilterConfig
impl Default for ErrorMessagesFilterConfig
source§fn default() -> ErrorMessagesFilterConfig
fn default() -> ErrorMessagesFilterConfig
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for ErrorMessagesFilterConfig
impl<'de> Deserialize<'de> for ErrorMessagesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Serialize for ErrorMessagesFilterConfig
impl Serialize for ErrorMessagesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_filter/struct.IgnoreTransactionsFilterConfig.html b/relay_filter/struct.IgnoreTransactionsFilterConfig.html
index fc51631acb..6bc1fdd171 100644
--- a/relay_filter/struct.IgnoreTransactionsFilterConfig.html
+++ b/relay_filter/struct.IgnoreTransactionsFilterConfig.html
@@ -1,8 +1,8 @@
IgnoreTransactionsFilterConfig in relay_filter - Rust pub struct IgnoreTransactionsFilterConfig {
- pub patterns: GlobPatterns,
+ pub patterns: GlobPatterns,
pub is_enabled: bool,
}
Expand description
Configuration for transaction name filter.
-Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
+Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
§is_enabled: boolTrue if the filter is enabled
Implementations§
Trait Implementations§
source§impl Clone for IgnoreTransactionsFilterConfig
source§fn clone(&self) -> IgnoreTransactionsFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Default for IgnoreTransactionsFilterConfig
source§fn default() -> IgnoreTransactionsFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for IgnoreTransactionsFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
diff --git a/relay_filter/struct.ReleasesFilterConfig.html b/relay_filter/struct.ReleasesFilterConfig.html
index 3fac1e1771..7377fd4377 100644
--- a/relay_filter/struct.ReleasesFilterConfig.html
+++ b/relay_filter/struct.ReleasesFilterConfig.html
@@ -1,7 +1,7 @@
ReleasesFilterConfig in relay_filter - Rust Struct relay_filter::ReleasesFilterConfig
source · pub struct ReleasesFilterConfig {
- pub releases: GlobPatterns,
+ pub releases: GlobPatterns,
}
Expand description
Configuration for the releases filter.
-Fields§
§releases: GlobPatternsList of release names that will be filtered.
+Fields§
§releases: GlobPatternsList of release names that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ReleasesFilterConfig
source§fn clone(&self) -> ReleasesFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Debug for ReleasesFilterConfig
source§impl Default for ReleasesFilterConfig
source§fn default() -> ReleasesFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for ReleasesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read moresource§impl Serialize for ReleasesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
\ No newline at end of file
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_filter/struct.IgnoreTransactionsFilterConfig.html b/relay_filter/struct.IgnoreTransactionsFilterConfig.html
index fc51631acb..6bc1fdd171 100644
--- a/relay_filter/struct.IgnoreTransactionsFilterConfig.html
+++ b/relay_filter/struct.IgnoreTransactionsFilterConfig.html
@@ -1,8 +1,8 @@
IgnoreTransactionsFilterConfig in relay_filter - Rust pub struct IgnoreTransactionsFilterConfig {
- pub patterns: GlobPatterns,
+ pub patterns: GlobPatterns,
pub is_enabled: bool,
}
Expand description
Configuration for transaction name filter.
-Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
+Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
§is_enabled: boolTrue if the filter is enabled
Implementations§
Trait Implementations§
source§impl Clone for IgnoreTransactionsFilterConfig
source§fn clone(&self) -> IgnoreTransactionsFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Default for IgnoreTransactionsFilterConfig
source§fn default() -> IgnoreTransactionsFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for IgnoreTransactionsFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
diff --git a/relay_filter/struct.ReleasesFilterConfig.html b/relay_filter/struct.ReleasesFilterConfig.html
index 3fac1e1771..7377fd4377 100644
--- a/relay_filter/struct.ReleasesFilterConfig.html
+++ b/relay_filter/struct.ReleasesFilterConfig.html
@@ -1,7 +1,7 @@
ReleasesFilterConfig in relay_filter - Rust Struct relay_filter::ReleasesFilterConfig
source · pub struct ReleasesFilterConfig {
- pub releases: GlobPatterns,
+ pub releases: GlobPatterns,
}
Expand description
Configuration for the releases filter.
-Fields§
§releases: GlobPatternsList of release names that will be filtered.
+Fields§
§releases: GlobPatternsList of release names that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ReleasesFilterConfig
source§fn clone(&self) -> ReleasesFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Debug for ReleasesFilterConfig
source§impl Default for ReleasesFilterConfig
source§fn default() -> ReleasesFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for ReleasesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read moresource§impl Serialize for ReleasesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
\ No newline at end of file
pub struct IgnoreTransactionsFilterConfig {
- pub patterns: GlobPatterns,
+ pub patterns: GlobPatterns,
pub is_enabled: bool,
}Expand description
Configuration for transaction name filter.
-Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
+Fields§
§patterns: GlobPatternsList of patterns for ignored transactions that should be filtered.
is_enabled: boolTrue if the filter is enabled
Implementations§
Trait Implementations§
source§impl Clone for IgnoreTransactionsFilterConfig
impl Clone for IgnoreTransactionsFilterConfig
source§fn clone(&self) -> IgnoreTransactionsFilterConfig
fn clone(&self) -> IgnoreTransactionsFilterConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Default for IgnoreTransactionsFilterConfig
impl Default for IgnoreTransactionsFilterConfig
source§fn default() -> IgnoreTransactionsFilterConfig
fn default() -> IgnoreTransactionsFilterConfig
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for IgnoreTransactionsFilterConfig
impl<'de> Deserialize<'de> for IgnoreTransactionsFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
diff --git a/relay_filter/struct.ReleasesFilterConfig.html b/relay_filter/struct.ReleasesFilterConfig.html
index 3fac1e1771..7377fd4377 100644
--- a/relay_filter/struct.ReleasesFilterConfig.html
+++ b/relay_filter/struct.ReleasesFilterConfig.html
@@ -1,7 +1,7 @@
ReleasesFilterConfig in relay_filter - Rust Struct relay_filter::ReleasesFilterConfig
source · pub struct ReleasesFilterConfig {
- pub releases: GlobPatterns,
+ pub releases: GlobPatterns,
}
Expand description
Configuration for the releases filter.
-Fields§
§releases: GlobPatternsList of release names that will be filtered.
+Fields§
§releases: GlobPatternsList of release names that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ReleasesFilterConfig
source§fn clone(&self) -> ReleasesFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Debug for ReleasesFilterConfig
source§impl Default for ReleasesFilterConfig
source§fn default() -> ReleasesFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for ReleasesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read moresource§impl Serialize for ReleasesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
\ No newline at end of file
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
diff --git a/relay_filter/struct.ReleasesFilterConfig.html b/relay_filter/struct.ReleasesFilterConfig.html
index 3fac1e1771..7377fd4377 100644
--- a/relay_filter/struct.ReleasesFilterConfig.html
+++ b/relay_filter/struct.ReleasesFilterConfig.html
@@ -1,7 +1,7 @@
ReleasesFilterConfig in relay_filter - Rust Struct relay_filter::ReleasesFilterConfig
source · pub struct ReleasesFilterConfig {
- pub releases: GlobPatterns,
+ pub releases: GlobPatterns,
}
Expand description
Configuration for the releases filter.
-Fields§
§releases: GlobPatternsList of release names that will be filtered.
+Fields§
§releases: GlobPatternsList of release names that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ReleasesFilterConfig
source§fn clone(&self) -> ReleasesFilterConfig
Returns a copy of the value. Read more1.0.0 · source§fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read moresource§impl Debug for ReleasesFilterConfig
source§impl Default for ReleasesFilterConfig
source§fn default() -> ReleasesFilterConfig
Returns the “default value” for a type. Read moresource§impl<'de> Deserialize<'de> for ReleasesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read moresource§impl Serialize for ReleasesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
\ No newline at end of file
Struct relay_filter::ReleasesFilterConfig
source · pub struct ReleasesFilterConfig {
- pub releases: GlobPatterns,
+ pub releases: GlobPatterns,
}Expand description
Configuration for the releases filter.
-Fields§
§releases: GlobPatternsList of release names that will be filtered.
+Fields§
§releases: GlobPatternsList of release names that will be filtered.
Implementations§
Trait Implementations§
source§impl Clone for ReleasesFilterConfig
impl Clone for ReleasesFilterConfig
source§fn clone(&self) -> ReleasesFilterConfig
fn clone(&self) -> ReleasesFilterConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Debug for ReleasesFilterConfig
impl Debug for ReleasesFilterConfig
source§impl Default for ReleasesFilterConfig
impl Default for ReleasesFilterConfig
source§fn default() -> ReleasesFilterConfig
fn default() -> ReleasesFilterConfig
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for ReleasesFilterConfig
impl<'de> Deserialize<'de> for ReleasesFilterConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Serialize for ReleasesFilterConfig
impl Serialize for ReleasesFilterConfig
source§fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
diff --git a/relay_monitors/fn.process_check_in.html b/relay_monitors/fn.process_check_in.html
index ffe584a8bc..e23779685c 100644
--- a/relay_monitors/fn.process_check_in.html
+++ b/relay_monitors/fn.process_check_in.html
@@ -1,5 +1,5 @@
process_check_in in relay_monitors - Rust Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>
Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}
Function relay_monitors::process_check_in
source · pub fn process_check_in(
payload: &[u8],
- project_id: ProjectId,
+ project_id: ProjectId,
) -> Result<ProcessedCheckInResult, ProcessCheckInError>Expand description
Normalizes a monitor check-in payload.
use std::collections::{BTreeMap, HashMap};
use std::error::Error;
use std::io::Write;
@@ -3527,7 +3539,7 @@
disk_batch_size: spool_envelopes_stack_disk_batch_size(),
max_batches: spool_envelopes_stack_max_batches(),
max_envelope_delay_secs: spool_envelopes_max_envelope_delay_secs(),
- version: EnvelopeSpoolVersion::V2,
+ version: EnvelopeSpoolVersion::default(),
}
}
}
@@ -5191,5 +5203,17 @@
fn test_emit_outcomes_invalid() {
assert!(serde_json::from_str::<EmitOutcomes>("asdf").is_err());
}
+
+ #[test]
+ fn test_spool_defaults_to_v1() {
+ let config: ConfigValues = serde_json::from_str("{}").unwrap();
+ assert!(matches!(
+ config.spool.envelopes.version,
+ EnvelopeSpoolVersion::V1
+ ));
+
+ let config = Config::from_json_value(serde_json::json!({})).unwrap();
+ assert!(!config.spool_v2());
+ }
}