diff --git a/sdks/rust/src/coders/register_coders/mod.rs b/sdks/rust/src/coders/register_coders/mod.rs index 8082e4accbac9..b8eecaa0b62bd 100644 --- a/sdks/rust/src/coders/register_coders/mod.rs +++ b/sdks/rust/src/coders/register_coders/mod.rs @@ -16,16 +16,16 @@ /// // ... /// } /// ``` -/// +/// /// # Related doc -/// +/// /// [Design doc: Custom Coders for the Beam Rust SDK](https://docs.google.com/document/d/1tUb8EoajRkxLW3mrJZzx6xxGhoiUSRKwVuT2uxjAeIU/edit#heading=h.mgr8mrx81tnc) #[macro_export] macro_rules! register_coders { ($($coder:ident),*) => { $( impl $crate::coders::CoderUrn for $coder { - const URN: &'static str = concat!("beam:coder:rustsdk:1.0:", stringify!($coder)); + const URN: &'static str = concat!(stringify!($crate::coders::urns::RUST_CODER_PREFIX), stringify!($coder)); } )* diff --git a/sdks/rust/src/coders/urns.rs b/sdks/rust/src/coders/urns.rs index d7fac0b862a76..af99140c8aa5c 100644 --- a/sdks/rust/src/coders/urns.rs +++ b/sdks/rust/src/coders/urns.rs @@ -26,4 +26,6 @@ pub const STR_UTF8_CODER_URN: &str = "beam:coder:string_utf8:v1"; pub const VARINT_CODER_URN: &str = "beam:coder:varint:v1"; // ******* Rust coders ******* -pub const GENERAL_OBJECT_CODER_URN: &str = "beam:coder:genericobjectjs:v1"; +pub const RUST_CODER_PREFIX: &str = "beam:coder:rustsdk:1.0:"; +pub const GENERAL_OBJECT_CODER_URN: &str = + concat!(stringify!(RUST_CODER_PREFIX), "genericobject:v1");