Skip to content

Commit

Permalink
type name fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Razz4780 committed Oct 3, 2024
1 parent 4612c3c commit 72476e7
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions mirrord/config/src/feature/split_queues.rs
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ impl FromMirrordConfig for SplitQueuesConfig {
type Generator = Self;
}

pub type MessageFilter = BTreeMap<String, String>;
pub type QueueMessageFilter = BTreeMap<String, String>;

/// More queue types might be added in the future.
#[derive(Serialize, Deserialize, Clone, Debug, Eq, PartialEq, JsonSchema)]
Expand All @@ -126,7 +126,7 @@ pub enum QueueFilter {
/// This means, only messages that have **all** of the attributes in the filter,
/// with values of those attributes matching the respective patterns.
#[serde(rename = "SQS")]
Sqs(MessageFilter),
Sqs(QueueMessageFilter),

/// Kafka.
///
Expand All @@ -135,7 +135,7 @@ pub enum QueueFilter {
/// This means, only messages that have **all** of the headers in the filter,
/// with values of those headers matching the respective patterns.
#[serde(rename = "Kafka")]
Kafka(MessageFilter),
Kafka(QueueMessageFilter),

/// When a newer client sends a new filter kind to an older operator, that does not yet know
/// about that filter type, this is what that filter will be deserialized to.
Expand Down

0 comments on commit 72476e7

Please sign in to comment.