Skip to content

Commit

Permalink
feat(processor): Add initial types into processing pipeline (#3078)
Browse files Browse the repository at this point in the history
This PR puts types restrictions on some functions, which makes it harder
to get wrong. There is no functional changes over here. The code that
was moved around wasn't changed, it's just to make it easier to create
the current state in more control manner.

This is just initial setup, which should evolve once we move to
`TypedEnvelope` (will be described in
getsentry/team-ingest#281)
  • Loading branch information
olksdr committed Feb 12, 2024
1 parent 9508403 commit d63d3ed
Show file tree
Hide file tree
Showing 15 changed files with 297 additions and 140 deletions.
4 changes: 2 additions & 2 deletions relay-server/src/endpoints/common.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ use serde::Deserialize;
use crate::envelope::{AttachmentType, Envelope, EnvelopeError, Item, ItemType, Items};
use crate::service::ServiceState;
use crate::services::outcome::{DiscardReason, Outcome};
use crate::services::processor::{ProcessMetricMeta, ProcessMetrics, ProcessingGroup};
use crate::services::processor::{ProcessMetricMeta, ProcessMetrics, ProcessingGroup, Ungrouped};
use crate::services::project_cache::{CheckEnvelope, ValidateEnvelope};
use crate::statsd::RelayCounters;
use crate::utils::{
Expand Down Expand Up @@ -334,7 +334,7 @@ pub async fn handle_envelope(
state.test_store().clone(),
// It's not clear at this point which group this envelope belongs to.
// The decission will be made while queueing in `queue_envelope` function.
ProcessingGroup::Ungrouped,
ProcessingGroup::Ungrouped(Ungrouped),
)
.map_err(BadStoreRequest::QueueFailed)?;

Expand Down
Loading

0 comments on commit d63d3ed

Please sign in to comment.