Skip to content

Commit

Permalink
display Q consumer
Browse files Browse the repository at this point in the history
  • Loading branch information
t4lz committed Jul 15, 2024
1 parent 03caf46 commit 20ff89d
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion mirrord/operator/src/crd.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,12 @@ use std::{
};

use kube::CustomResource;
use kube_target::{KubeTarget, UnknownTargetType};
pub use mirrord_config::feature::split_queues::QueueId;
use mirrord_config::{
feature::split_queues::SqsMessageFilter,
target::{Target, TargetConfig},
};
use kube_target::{KubeTarget, UnknownTargetType};
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};

Expand Down Expand Up @@ -395,6 +395,13 @@ impl QueueConsumer {
}
}

impl Display for QueueConsumer {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
let (type_, name) = self.get_type_and_name();
write!(f, "{}/{}", type_, name)
}
}

#[derive(Clone, Debug, Default, Deserialize, Serialize, JsonSchema)]
pub struct QueueNameUpdate {
pub original_name: String,
Expand Down

0 comments on commit 20ff89d

Please sign in to comment.