unitycatalog_common/models/_gen/

unitycatalog.recipients.v1.rs

// @generated by buffa-codegen. DO NOT EDIT.

#[derive(Clone, Copy, PartialEq, Eq, Hash, Debug)]
#[repr(i32)]
pub enum AuthenticationType {
    /// No authentication is required.
    AUTHENTICATION_TYPE_UNSPECIFIED = 0i32,
    /// Basic authentication is required.
    TOKEN = 1i32,
    /// OAuth2 authentication is required.
    OAUTH_CLIENT_CREDENTIALS = 2i32,
}
impl AuthenticationType {
    ///Idiomatic alias for [`Self::AUTHENTICATION_TYPE_UNSPECIFIED`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const AuthenticationTypeUnspecified: Self = Self::AUTHENTICATION_TYPE_UNSPECIFIED;
    ///Idiomatic alias for [`Self::TOKEN`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const Token: Self = Self::TOKEN;
    ///Idiomatic alias for [`Self::OAUTH_CLIENT_CREDENTIALS`]; `Debug` prints the variant name.
    #[allow(non_upper_case_globals)]
    pub const OauthClientCredentials: Self = Self::OAUTH_CLIENT_CREDENTIALS;
}
impl ::core::default::Default for AuthenticationType {
    fn default() -> Self {
        Self::AUTHENTICATION_TYPE_UNSPECIFIED
    }
}
impl ::serde::Serialize for AuthenticationType {
    fn serialize<S: ::serde::Serializer>(
        &self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        s.serialize_str(::buffa::Enumeration::proto_name(self))
    }
}
impl<'de> ::serde::Deserialize<'de> for AuthenticationType {
    fn deserialize<D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        struct _V;
        impl ::serde::de::Visitor<'_> for _V {
            type Value = AuthenticationType;
            fn expecting(
                &self,
                f: &mut ::core::fmt::Formatter<'_>,
            ) -> ::core::fmt::Result {
                f.write_str(
                    concat!(
                        "a string, integer, or null for ", stringify!(AuthenticationType)
                    ),
                )
            }
            fn visit_str<E: ::serde::de::Error>(
                self,
                v: &str,
            ) -> ::core::result::Result<AuthenticationType, E> {
                <AuthenticationType as ::buffa::Enumeration>::from_proto_name(v)
                    .ok_or_else(|| { ::serde::de::Error::unknown_variant(v, &[]) })
            }
            fn visit_i64<E: ::serde::de::Error>(
                self,
                v: i64,
            ) -> ::core::result::Result<AuthenticationType, E> {
                let v32 = i32::try_from(v)
                    .map_err(|_| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("enum value {v} out of i32 range"),
                        )
                    })?;
                <AuthenticationType as ::buffa::Enumeration>::from_i32(v32)
                    .ok_or_else(|| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("unknown enum value {v32}"),
                        )
                    })
            }
            fn visit_u64<E: ::serde::de::Error>(
                self,
                v: u64,
            ) -> ::core::result::Result<AuthenticationType, E> {
                let v32 = i32::try_from(v)
                    .map_err(|_| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("enum value {v} out of i32 range"),
                        )
                    })?;
                <AuthenticationType as ::buffa::Enumeration>::from_i32(v32)
                    .ok_or_else(|| {
                        ::serde::de::Error::custom(
                            ::buffa::alloc::format!("unknown enum value {v32}"),
                        )
                    })
            }
            fn visit_unit<E: ::serde::de::Error>(
                self,
            ) -> ::core::result::Result<AuthenticationType, E> {
                ::core::result::Result::Ok(::core::default::Default::default())
            }
        }
        d.deserialize_any(_V)
    }
}
impl ::buffa::json_helpers::ProtoElemJson for AuthenticationType {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
impl ::buffa::Enumeration for AuthenticationType {
    fn from_i32(value: i32) -> ::core::option::Option<Self> {
        match value {
            0i32 => ::core::option::Option::Some(Self::AUTHENTICATION_TYPE_UNSPECIFIED),
            1i32 => ::core::option::Option::Some(Self::TOKEN),
            2i32 => ::core::option::Option::Some(Self::OAUTH_CLIENT_CREDENTIALS),
            _ => ::core::option::Option::None,
        }
    }
    fn to_i32(&self) -> i32 {
        *self as i32
    }
    fn proto_name(&self) -> &'static str {
        match self {
            Self::AUTHENTICATION_TYPE_UNSPECIFIED => "AUTHENTICATION_TYPE_UNSPECIFIED",
            Self::TOKEN => "TOKEN",
            Self::OAUTH_CLIENT_CREDENTIALS => "OAUTH_CLIENT_CREDENTIALS",
        }
    }
    fn from_proto_name(name: &str) -> ::core::option::Option<Self> {
        match name {
            "AUTHENTICATION_TYPE_UNSPECIFIED" => {
                ::core::option::Option::Some(Self::AUTHENTICATION_TYPE_UNSPECIFIED)
            }
            "TOKEN" => ::core::option::Option::Some(Self::TOKEN),
            "OAUTH_CLIENT_CREDENTIALS" => {
                ::core::option::Option::Some(Self::OAUTH_CLIENT_CREDENTIALS)
            }
            _ => ::core::option::Option::None,
        }
    }
    fn values() -> &'static [Self] {
        &[
            Self::AUTHENTICATION_TYPE_UNSPECIFIED,
            Self::TOKEN,
            Self::OAUTH_CLIENT_CREDENTIALS,
        ]
    }
}
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct RecipientToken {
    /// Unique ID of the recipient token.
    ///
    /// Field 1: `id`
    #[serde(
        rename = "id",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub id: ::buffa::alloc::string::String,
    /// Time at which this recipient token was created, in epoch milliseconds.
    ///
    /// Field 2: `created_at`
    #[serde(
        rename = "created_at",
        alias = "createdAt",
        with = "::buffa::json_helpers::int64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i64"
    )]
    pub created_at: i64,
    /// Username of recipient token creator.
    ///
    /// Field 3: `created_by`
    #[serde(
        rename = "created_by",
        alias = "createdBy",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub created_by: ::buffa::alloc::string::String,
    /// Full activation URL to retrieve the access token. It will be empty if the token is already retrieved.
    ///
    /// Field 4: `activation_url`
    #[serde(
        rename = "activation_url",
        alias = "activationUrl",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub activation_url: ::buffa::alloc::string::String,
    /// Expiration timestamp of the token in epoch milliseconds.
    ///
    /// Field 5: `expiration_time`
    #[serde(
        rename = "expiration_time",
        alias = "expirationTime",
        with = "::buffa::json_helpers::int64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i64"
    )]
    pub expiration_time: i64,
    /// Time at which this recipient token was updated, in epoch milliseconds.
    ///
    /// Field 6: `updated_at`
    #[serde(
        rename = "updated_at",
        alias = "updatedAt",
        with = "::buffa::json_helpers::int64",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_zero_i64"
    )]
    pub updated_at: i64,
    /// Username of recipient token updater.
    ///
    /// Field 7: `updated_by`
    #[serde(
        rename = "updated_by",
        alias = "updatedBy",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub updated_by: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for RecipientToken {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("RecipientToken")
            .field("id", &self.id)
            .field("created_at", &self.created_at)
            .field("created_by", &self.created_by)
            .field("activation_url", &self.activation_url)
            .field("expiration_time", &self.expiration_time)
            .field("updated_at", &self.updated_at)
            .field("updated_by", &self.updated_by)
            .finish()
    }
}
impl RecipientToken {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.RecipientToken";
}
impl ::buffa::DefaultInstance for RecipientToken {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<RecipientToken> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for RecipientToken {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "RecipientToken";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.RecipientToken";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.RecipientToken";
}
impl ::buffa::Message for RecipientToken {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.id.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.id) as u32;
        }
        if self.created_at != 0i64 {
            size += 1u32 + ::buffa::types::int64_encoded_len(self.created_at) as u32;
        }
        if !self.created_by.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.created_by) as u32;
        }
        if !self.activation_url.is_empty() {
            size
                += 1u32
                    + ::buffa::types::string_encoded_len(&self.activation_url) as u32;
        }
        if self.expiration_time != 0i64 {
            size
                += 1u32 + ::buffa::types::int64_encoded_len(self.expiration_time) as u32;
        }
        if self.updated_at != 0i64 {
            size += 1u32 + ::buffa::types::int64_encoded_len(self.updated_at) as u32;
        }
        if !self.updated_by.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.updated_by) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.id.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.id, buf);
        }
        if self.created_at != 0i64 {
            ::buffa::encoding::Tag::new(2u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(self.created_at, buf);
        }
        if !self.created_by.is_empty() {
            ::buffa::encoding::Tag::new(
                    3u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.created_by, buf);
        }
        if !self.activation_url.is_empty() {
            ::buffa::encoding::Tag::new(
                    4u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.activation_url, buf);
        }
        if self.expiration_time != 0i64 {
            ::buffa::encoding::Tag::new(5u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(self.expiration_time, buf);
        }
        if self.updated_at != 0i64 {
            ::buffa::encoding::Tag::new(6u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(self.updated_at, buf);
        }
        if !self.updated_by.is_empty() {
            ::buffa::encoding::Tag::new(
                    7u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.updated_by, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.id, buf)?;
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.created_at = ::buffa::types::decode_int64(buf)?;
            }
            3u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 3u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.created_by, buf)?;
            }
            4u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 4u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.activation_url, buf)?;
            }
            5u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 5u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.expiration_time = ::buffa::types::decode_int64(buf)?;
            }
            6u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 6u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.updated_at = ::buffa::types::decode_int64(buf)?;
            }
            7u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 7u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.updated_by, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.id.clear();
        self.created_at = 0i64;
        self.created_by.clear();
        self.activation_url.clear();
        self.expiration_time = 0i64;
        self.updated_at = 0i64;
        self.updated_by.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for RecipientToken {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.RecipientToken";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for RecipientToken {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __RECIPIENT_TOKEN_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.RecipientToken",
    to_json: ::buffa::type_registry::any_to_json::<RecipientToken>,
    from_json: ::buffa::type_registry::any_from_json::<RecipientToken>,
    is_wkt: false,
};
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct Recipient {
    /// Unique ID of the recipient.
    ///
    /// Field 100: `id`
    #[serde(rename = "id", skip_serializing_if = "::core::option::Option::is_none")]
    pub id: ::core::option::Option<::buffa::alloc::string::String>,
    /// The name of the recipient.
    ///
    /// Field 1: `name`
    #[serde(
        rename = "name",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub name: ::buffa::alloc::string::String,
    /// The delta sharing authentication type.
    ///
    /// Field 2: `authentication_type`
    #[serde(
        rename = "authentication_type",
        alias = "authenticationType",
        with = "::buffa::json_helpers::proto_enum",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_default_enum_value"
    )]
    pub authentication_type: ::buffa::EnumValue<AuthenticationType>,
    /// Username of the recipient owner.
    ///
    /// Field 3: `owner`
    #[serde(rename = "owner", skip_serializing_if = "::core::option::Option::is_none")]
    pub owner: ::core::option::Option<::buffa::alloc::string::String>,
    /// Description about the recipient.
    ///
    /// Field 4: `comment`
    #[serde(rename = "comment", skip_serializing_if = "::core::option::Option::is_none")]
    pub comment: ::core::option::Option<::buffa::alloc::string::String>,
    /// A map of key-value properties attached to the securable.
    ///
    /// Field 6: `properties`
    #[serde(
        rename = "properties",
        skip_serializing_if = "::buffa::__private::HashMap::is_empty",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub properties: ::buffa::__private::HashMap<
        ::buffa::alloc::string::String,
        ::buffa::alloc::string::String,
    >,
    /// Time at which this share was created, in epoch milliseconds.
    ///
    /// Field 7: `created_at`
    #[serde(
        rename = "created_at",
        alias = "createdAt",
        with = "::buffa::json_helpers::opt_int64",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub created_at: ::core::option::Option<i64>,
    /// Username of the creator of the share.
    ///
    /// Field 8: `created_by`
    #[serde(
        rename = "created_by",
        alias = "createdBy",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub created_by: ::core::option::Option<::buffa::alloc::string::String>,
    /// This field is only present when the authentication_type is TOKEN.
    ///
    /// Field 9: `tokens`
    #[serde(
        rename = "tokens",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub tokens: ::buffa::alloc::vec::Vec<RecipientToken>,
    /// Time at which this share was updated, in epoch milliseconds.
    ///
    /// Field 10: `updated_at`
    #[serde(
        rename = "updated_at",
        alias = "updatedAt",
        with = "::buffa::json_helpers::opt_int64",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub updated_at: ::core::option::Option<i64>,
    /// Username of share updater.
    ///
    /// Field 11: `updated_by`
    #[serde(
        rename = "updated_by",
        alias = "updatedBy",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub updated_by: ::core::option::Option<::buffa::alloc::string::String>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for Recipient {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("Recipient")
            .field("id", &self.id)
            .field("name", &self.name)
            .field("authentication_type", &self.authentication_type)
            .field("owner", &self.owner)
            .field("comment", &self.comment)
            .field("properties", &self.properties)
            .field("created_at", &self.created_at)
            .field("created_by", &self.created_by)
            .field("tokens", &self.tokens)
            .field("updated_at", &self.updated_at)
            .field("updated_by", &self.updated_by)
            .finish()
    }
}
impl Recipient {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.Recipient";
}
impl Recipient {
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::id`] to `Some(value)`, consuming and returning `self`.
    pub fn with_id(mut self, value: impl Into<::buffa::alloc::string::String>) -> Self {
        self.id = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::owner`] to `Some(value)`, consuming and returning `self`.
    pub fn with_owner(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.owner = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::comment`] to `Some(value)`, consuming and returning `self`.
    pub fn with_comment(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.comment = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::created_at`] to `Some(value)`, consuming and returning `self`.
    pub fn with_created_at(mut self, value: i64) -> Self {
        self.created_at = Some(value);
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::created_by`] to `Some(value)`, consuming and returning `self`.
    pub fn with_created_by(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.created_by = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::updated_at`] to `Some(value)`, consuming and returning `self`.
    pub fn with_updated_at(mut self, value: i64) -> Self {
        self.updated_at = Some(value);
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::updated_by`] to `Some(value)`, consuming and returning `self`.
    pub fn with_updated_by(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.updated_by = Some(value.into());
        self
    }
}
impl ::buffa::DefaultInstance for Recipient {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<Recipient> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for Recipient {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "Recipient";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.Recipient";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.Recipient";
}
impl ::buffa::Message for Recipient {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.name.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
        }
        {
            let val = self.authentication_type.to_i32();
            if val != 0 {
                size += 1u32 + ::buffa::types::int32_encoded_len(val) as u32;
            }
        }
        if let Some(ref v) = self.owner {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.comment {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        #[allow(clippy::for_kv_map)]
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            size
                += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                    + entry_size;
        }
        if let Some(v) = self.created_at {
            size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.created_by {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        for v in &self.tokens {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        if let Some(v) = self.updated_at {
            size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.updated_by {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.id {
            size += 2u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        __cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.name.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.name, buf);
        }
        {
            let val = self.authentication_type.to_i32();
            if val != 0 {
                ::buffa::encoding::Tag::new(2u32, ::buffa::encoding::WireType::Varint)
                    .encode(buf);
                ::buffa::types::encode_int32(val, buf);
            }
        }
        if let Some(ref v) = self.owner {
            ::buffa::encoding::Tag::new(
                    3u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(ref v) = self.comment {
            ::buffa::encoding::Tag::new(
                    4u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            ::buffa::encoding::Tag::new(
                    6u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::encoding::encode_varint(entry_size as u64, buf);
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(k, buf);
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(v) = self.created_at {
            ::buffa::encoding::Tag::new(7u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(v, buf);
        }
        if let Some(ref v) = self.created_by {
            ::buffa::encoding::Tag::new(
                    8u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        for v in &self.tokens {
            ::buffa::encoding::Tag::new(
                    9u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
            v.write_to(__cache, buf);
        }
        if let Some(v) = self.updated_at {
            ::buffa::encoding::Tag::new(10u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(v, buf);
        }
        if let Some(ref v) = self.updated_by {
            ::buffa::encoding::Tag::new(
                    11u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(ref v) = self.id {
            ::buffa::encoding::Tag::new(
                    100u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.name, buf)?;
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.authentication_type = ::buffa::EnumValue::from(
                    ::buffa::types::decode_int32(buf)?,
                );
            }
            3u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 3u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.owner.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            4u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 4u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.comment.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            6u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 6u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                let entry_len = ::buffa::encoding::decode_varint(buf)?;
                let entry_len = usize::try_from(entry_len)
                    .map_err(|_| ::buffa::DecodeError::MessageTooLarge)?;
                if buf.remaining() < entry_len {
                    return ::core::result::Result::Err(
                        ::buffa::DecodeError::UnexpectedEof,
                    );
                }
                let entry_limit = buf.remaining() - entry_len;
                let mut key = ::core::default::Default::default();
                let mut val = ::core::default::Default::default();
                while buf.remaining() > entry_limit {
                    let entry_tag = ::buffa::encoding::Tag::decode(buf)?;
                    match entry_tag.field_number() {
                        1 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            key = ::buffa::types::decode_string(buf)?;
                        }
                        2 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            val = ::buffa::types::decode_string(buf)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(entry_tag, buf, depth)?;
                        }
                    }
                }
                if buf.remaining() != entry_limit {
                    let remaining = buf.remaining();
                    if remaining > entry_limit {
                        buf.advance(remaining - entry_limit);
                    } else {
                        return ::core::result::Result::Err(
                            ::buffa::DecodeError::UnexpectedEof,
                        );
                    }
                }
                self.properties.insert(key, val);
            }
            7u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 7u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.created_at = ::core::option::Option::Some(
                    ::buffa::types::decode_int64(buf)?,
                );
            }
            8u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 8u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self
                        .created_by
                        .get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            9u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 9u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, depth)?;
                self.tokens.push(elem);
            }
            10u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 10u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.updated_at = ::core::option::Option::Some(
                    ::buffa::types::decode_int64(buf)?,
                );
            }
            11u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 11u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self
                        .updated_by
                        .get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            100u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 100u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.id.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.name.clear();
        self.authentication_type = ::buffa::EnumValue::from(0);
        self.owner = ::core::option::Option::None;
        self.comment = ::core::option::Option::None;
        self.properties.clear();
        self.created_at = ::core::option::Option::None;
        self.created_by = ::core::option::Option::None;
        self.tokens.clear();
        self.updated_at = ::core::option::Option::None;
        self.updated_by = ::core::option::Option::None;
        self.id = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for Recipient {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.Recipient";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for Recipient {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __RECIPIENT_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.Recipient",
    to_json: ::buffa::type_registry::any_to_json::<Recipient>,
    from_json: ::buffa::type_registry::any_from_json::<Recipient>,
    is_wkt: false,
};
/// Request to list recipients.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ListRecipientsRequest {
    /// The maximum number of results per page that should be returned.
    ///
    /// Field 1: `max_results`
    #[serde(
        rename = "max_results",
        alias = "maxResults",
        with = "::buffa::json_helpers::opt_int32",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub max_results: ::core::option::Option<i32>,
    /// Opaque pagination token to go to next page based on previous query.
    ///
    /// Field 2: `page_token`
    #[serde(
        rename = "page_token",
        alias = "pageToken",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub page_token: ::core::option::Option<::buffa::alloc::string::String>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ListRecipientsRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("ListRecipientsRequest")
            .field("max_results", &self.max_results)
            .field("page_token", &self.page_token)
            .finish()
    }
}
impl ListRecipientsRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsRequest";
}
impl ListRecipientsRequest {
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::max_results`] to `Some(value)`, consuming and returning `self`.
    pub fn with_max_results(mut self, value: i32) -> Self {
        self.max_results = Some(value);
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::page_token`] to `Some(value)`, consuming and returning `self`.
    pub fn with_page_token(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.page_token = Some(value.into());
        self
    }
}
impl ::buffa::DefaultInstance for ListRecipientsRequest {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<ListRecipientsRequest> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for ListRecipientsRequest {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "ListRecipientsRequest";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.ListRecipientsRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsRequest";
}
impl ::buffa::Message for ListRecipientsRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if let Some(v) = self.max_results {
            size += 1u32 + ::buffa::types::int32_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.page_token {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if let Some(v) = self.max_results {
            ::buffa::encoding::Tag::new(1u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int32(v, buf);
        }
        if let Some(ref v) = self.page_token {
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.max_results = ::core::option::Option::Some(
                    ::buffa::types::decode_int32(buf)?,
                );
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self
                        .page_token
                        .get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.max_results = ::core::option::Option::None;
        self.page_token = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for ListRecipientsRequest {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.ListRecipientsRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for ListRecipientsRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __LIST_RECIPIENTS_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsRequest",
    to_json: ::buffa::type_registry::any_to_json::<ListRecipientsRequest>,
    from_json: ::buffa::type_registry::any_from_json::<ListRecipientsRequest>,
    is_wkt: false,
};
/// Response to list recipients.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct ListRecipientsResponse {
    /// List of recipients.
    ///
    /// Field 1: `recipients`
    #[serde(
        rename = "recipients",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_vec",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub recipients: ::buffa::alloc::vec::Vec<Recipient>,
    /// Opaque pagination token to go to next page based on previous query.
    ///
    /// Field 2: `next_page_token`
    #[serde(
        rename = "next_page_token",
        alias = "nextPageToken",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub next_page_token: ::core::option::Option<::buffa::alloc::string::String>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for ListRecipientsResponse {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("ListRecipientsResponse")
            .field("recipients", &self.recipients)
            .field("next_page_token", &self.next_page_token)
            .finish()
    }
}
impl ListRecipientsResponse {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsResponse";
}
impl ListRecipientsResponse {
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::next_page_token`] to `Some(value)`, consuming and returning `self`.
    pub fn with_next_page_token(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.next_page_token = Some(value.into());
        self
    }
}
impl ::buffa::DefaultInstance for ListRecipientsResponse {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<ListRecipientsResponse> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for ListRecipientsResponse {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "ListRecipientsResponse";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.ListRecipientsResponse";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsResponse";
}
impl ::buffa::Message for ListRecipientsResponse {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        for v in &self.recipients {
            let __slot = __cache.reserve();
            let inner_size = v.compute_size(__cache);
            __cache.set(__slot, inner_size);
            size
                += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                    + inner_size;
        }
        if let Some(ref v) = self.next_page_token {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        __cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        for v in &self.recipients {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
            v.write_to(__cache, buf);
        }
        if let Some(ref v) = self.next_page_token {
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                let mut elem = ::core::default::Default::default();
                ::buffa::Message::merge_length_delimited(&mut elem, buf, depth)?;
                self.recipients.push(elem);
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self
                        .next_page_token
                        .get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.recipients.clear();
        self.next_page_token = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for ListRecipientsResponse {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.ListRecipientsResponse";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for ListRecipientsResponse {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __LIST_RECIPIENTS_RESPONSE_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsResponse",
    to_json: ::buffa::type_registry::any_to_json::<ListRecipientsResponse>,
    from_json: ::buffa::type_registry::any_from_json::<ListRecipientsResponse>,
    is_wkt: false,
};
/// Creates a new recipient
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct CreateRecipientRequest {
    /// Name of the recipient.
    ///
    /// Field 1: `name`
    #[serde(
        rename = "name",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub name: ::buffa::alloc::string::String,
    /// The delta sharing authentication type.
    ///
    /// Field 2: `authentication_type`
    #[serde(
        rename = "authentication_type",
        alias = "authenticationType",
        with = "::buffa::json_helpers::proto_enum",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_default_enum_value"
    )]
    pub authentication_type: ::buffa::EnumValue<AuthenticationType>,
    /// Username of the recipient owner.
    ///
    /// Field 3: `owner`
    #[serde(
        rename = "owner",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub owner: ::buffa::alloc::string::String,
    /// Description about the recipient.
    ///
    /// Field 4: `comment`
    #[serde(rename = "comment", skip_serializing_if = "::core::option::Option::is_none")]
    pub comment: ::core::option::Option<::buffa::alloc::string::String>,
    /// Recipient properties as map of string key-value pairs.
    ///
    /// When provided in update request, the specified properties will override the existing properties.
    /// To add and remove properties, one would need to perform a read-modify-write.
    ///
    /// Field 5: `properties`
    #[serde(
        rename = "properties",
        skip_serializing_if = "::buffa::__private::HashMap::is_empty",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub properties: ::buffa::__private::HashMap<
        ::buffa::alloc::string::String,
        ::buffa::alloc::string::String,
    >,
    /// Expiration timestamp of the token, in epoch milliseconds.
    ///
    /// Field 6: `expiration_time`
    #[serde(
        rename = "expiration_time",
        alias = "expirationTime",
        with = "::buffa::json_helpers::opt_int64",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub expiration_time: ::core::option::Option<i64>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for CreateRecipientRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("CreateRecipientRequest")
            .field("name", &self.name)
            .field("authentication_type", &self.authentication_type)
            .field("owner", &self.owner)
            .field("comment", &self.comment)
            .field("properties", &self.properties)
            .field("expiration_time", &self.expiration_time)
            .finish()
    }
}
impl CreateRecipientRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.CreateRecipientRequest";
}
impl CreateRecipientRequest {
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::comment`] to `Some(value)`, consuming and returning `self`.
    pub fn with_comment(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.comment = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::expiration_time`] to `Some(value)`, consuming and returning `self`.
    pub fn with_expiration_time(mut self, value: i64) -> Self {
        self.expiration_time = Some(value);
        self
    }
}
impl ::buffa::DefaultInstance for CreateRecipientRequest {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<CreateRecipientRequest> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for CreateRecipientRequest {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "CreateRecipientRequest";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.CreateRecipientRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.CreateRecipientRequest";
}
impl ::buffa::Message for CreateRecipientRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.name.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
        }
        {
            let val = self.authentication_type.to_i32();
            if val != 0 {
                size += 1u32 + ::buffa::types::int32_encoded_len(val) as u32;
            }
        }
        if !self.owner.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.owner) as u32;
        }
        if let Some(ref v) = self.comment {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        #[allow(clippy::for_kv_map)]
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            size
                += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                    + entry_size;
        }
        if let Some(v) = self.expiration_time {
            size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.name.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.name, buf);
        }
        {
            let val = self.authentication_type.to_i32();
            if val != 0 {
                ::buffa::encoding::Tag::new(2u32, ::buffa::encoding::WireType::Varint)
                    .encode(buf);
                ::buffa::types::encode_int32(val, buf);
            }
        }
        if !self.owner.is_empty() {
            ::buffa::encoding::Tag::new(
                    3u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.owner, buf);
        }
        if let Some(ref v) = self.comment {
            ::buffa::encoding::Tag::new(
                    4u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            ::buffa::encoding::Tag::new(
                    5u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::encoding::encode_varint(entry_size as u64, buf);
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(k, buf);
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(v) = self.expiration_time {
            ::buffa::encoding::Tag::new(6u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(v, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.name, buf)?;
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.authentication_type = ::buffa::EnumValue::from(
                    ::buffa::types::decode_int32(buf)?,
                );
            }
            3u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 3u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.owner, buf)?;
            }
            4u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 4u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.comment.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            5u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 5u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                let entry_len = ::buffa::encoding::decode_varint(buf)?;
                let entry_len = usize::try_from(entry_len)
                    .map_err(|_| ::buffa::DecodeError::MessageTooLarge)?;
                if buf.remaining() < entry_len {
                    return ::core::result::Result::Err(
                        ::buffa::DecodeError::UnexpectedEof,
                    );
                }
                let entry_limit = buf.remaining() - entry_len;
                let mut key = ::core::default::Default::default();
                let mut val = ::core::default::Default::default();
                while buf.remaining() > entry_limit {
                    let entry_tag = ::buffa::encoding::Tag::decode(buf)?;
                    match entry_tag.field_number() {
                        1 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            key = ::buffa::types::decode_string(buf)?;
                        }
                        2 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            val = ::buffa::types::decode_string(buf)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(entry_tag, buf, depth)?;
                        }
                    }
                }
                if buf.remaining() != entry_limit {
                    let remaining = buf.remaining();
                    if remaining > entry_limit {
                        buf.advance(remaining - entry_limit);
                    } else {
                        return ::core::result::Result::Err(
                            ::buffa::DecodeError::UnexpectedEof,
                        );
                    }
                }
                self.properties.insert(key, val);
            }
            6u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 6u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.expiration_time = ::core::option::Option::Some(
                    ::buffa::types::decode_int64(buf)?,
                );
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.name.clear();
        self.authentication_type = ::buffa::EnumValue::from(0);
        self.owner.clear();
        self.comment = ::core::option::Option::None;
        self.properties.clear();
        self.expiration_time = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for CreateRecipientRequest {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.CreateRecipientRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for CreateRecipientRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __CREATE_RECIPIENT_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.CreateRecipientRequest",
    to_json: ::buffa::type_registry::any_to_json::<CreateRecipientRequest>,
    from_json: ::buffa::type_registry::any_from_json::<CreateRecipientRequest>,
    is_wkt: false,
};
/// Get a recipient by name.
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct GetRecipientRequest {
    /// Name of the recipient.
    ///
    /// Field 1: `name`
    #[serde(
        rename = "name",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub name: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for GetRecipientRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("GetRecipientRequest").field("name", &self.name).finish()
    }
}
impl GetRecipientRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.GetRecipientRequest";
}
impl ::buffa::DefaultInstance for GetRecipientRequest {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<GetRecipientRequest> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for GetRecipientRequest {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "GetRecipientRequest";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.GetRecipientRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.GetRecipientRequest";
}
impl ::buffa::Message for GetRecipientRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.name.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.name.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.name, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.name, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.name.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for GetRecipientRequest {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.GetRecipientRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for GetRecipientRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __GET_RECIPIENT_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.GetRecipientRequest",
    to_json: ::buffa::type_registry::any_to_json::<GetRecipientRequest>,
    from_json: ::buffa::type_registry::any_from_json::<GetRecipientRequest>,
    is_wkt: false,
};
/// Update a recipient
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct UpdateRecipientRequest {
    /// Name of the recipient.
    ///
    /// Field 1: `name`
    #[serde(
        rename = "name",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub name: ::buffa::alloc::string::String,
    /// New name for the recipient
    ///
    /// Field 2: `new_name`
    #[serde(
        rename = "new_name",
        alias = "newName",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub new_name: ::core::option::Option<::buffa::alloc::string::String>,
    /// Username of the recipient owner.
    ///
    /// Field 3: `owner`
    #[serde(rename = "owner", skip_serializing_if = "::core::option::Option::is_none")]
    pub owner: ::core::option::Option<::buffa::alloc::string::String>,
    /// Description about the recipient.
    ///
    /// Field 4: `comment`
    #[serde(rename = "comment", skip_serializing_if = "::core::option::Option::is_none")]
    pub comment: ::core::option::Option<::buffa::alloc::string::String>,
    /// Recipient properties as map of string key-value pairs.
    ///
    /// When provided in update request, the specified properties will override the existing properties.
    /// To add and remove properties, one would need to perform a read-modify-write.
    ///
    /// Field 5: `properties`
    #[serde(
        rename = "properties",
        skip_serializing_if = "::buffa::__private::HashMap::is_empty",
        deserialize_with = "::buffa::json_helpers::null_as_default"
    )]
    pub properties: ::buffa::__private::HashMap<
        ::buffa::alloc::string::String,
        ::buffa::alloc::string::String,
    >,
    /// Expiration timestamp of the token, in epoch milliseconds.
    ///
    /// Field 6: `expiration_time`
    #[serde(
        rename = "expiration_time",
        alias = "expirationTime",
        with = "::buffa::json_helpers::opt_int64",
        skip_serializing_if = "::core::option::Option::is_none"
    )]
    pub expiration_time: ::core::option::Option<i64>,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for UpdateRecipientRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("UpdateRecipientRequest")
            .field("name", &self.name)
            .field("new_name", &self.new_name)
            .field("owner", &self.owner)
            .field("comment", &self.comment)
            .field("properties", &self.properties)
            .field("expiration_time", &self.expiration_time)
            .finish()
    }
}
impl UpdateRecipientRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.UpdateRecipientRequest";
}
impl UpdateRecipientRequest {
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::new_name`] to `Some(value)`, consuming and returning `self`.
    pub fn with_new_name(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.new_name = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::owner`] to `Some(value)`, consuming and returning `self`.
    pub fn with_owner(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.owner = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::comment`] to `Some(value)`, consuming and returning `self`.
    pub fn with_comment(
        mut self,
        value: impl Into<::buffa::alloc::string::String>,
    ) -> Self {
        self.comment = Some(value.into());
        self
    }
    #[must_use = "with_* setters return `self` by value; assign or chain the result"]
    #[inline]
    ///Sets [`Self::expiration_time`] to `Some(value)`, consuming and returning `self`.
    pub fn with_expiration_time(mut self, value: i64) -> Self {
        self.expiration_time = Some(value);
        self
    }
}
impl ::buffa::DefaultInstance for UpdateRecipientRequest {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<UpdateRecipientRequest> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for UpdateRecipientRequest {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "UpdateRecipientRequest";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.UpdateRecipientRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.UpdateRecipientRequest";
}
impl ::buffa::Message for UpdateRecipientRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.name.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
        }
        if let Some(ref v) = self.new_name {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.owner {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        if let Some(ref v) = self.comment {
            size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
        }
        #[allow(clippy::for_kv_map)]
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            size
                += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                    + entry_size;
        }
        if let Some(v) = self.expiration_time {
            size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.name.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.name, buf);
        }
        if let Some(ref v) = self.new_name {
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(ref v) = self.owner {
            ::buffa::encoding::Tag::new(
                    3u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(ref v) = self.comment {
            ::buffa::encoding::Tag::new(
                    4u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        for (k, v) in &self.properties {
            let entry_size: u32 = 1u32 + ::buffa::types::string_encoded_len(k) as u32
                + 1u32 + ::buffa::types::string_encoded_len(v) as u32;
            ::buffa::encoding::Tag::new(
                    5u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::encoding::encode_varint(entry_size as u64, buf);
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(k, buf);
            ::buffa::encoding::Tag::new(
                    2u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(v, buf);
        }
        if let Some(v) = self.expiration_time {
            ::buffa::encoding::Tag::new(6u32, ::buffa::encoding::WireType::Varint)
                .encode(buf);
            ::buffa::types::encode_int64(v, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.name, buf)?;
            }
            2u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 2u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self
                        .new_name
                        .get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            3u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 3u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.owner.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            4u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 4u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(
                    self.comment.get_or_insert_with(::buffa::alloc::string::String::new),
                    buf,
                )?;
            }
            5u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 5u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                let entry_len = ::buffa::encoding::decode_varint(buf)?;
                let entry_len = usize::try_from(entry_len)
                    .map_err(|_| ::buffa::DecodeError::MessageTooLarge)?;
                if buf.remaining() < entry_len {
                    return ::core::result::Result::Err(
                        ::buffa::DecodeError::UnexpectedEof,
                    );
                }
                let entry_limit = buf.remaining() - entry_len;
                let mut key = ::core::default::Default::default();
                let mut val = ::core::default::Default::default();
                while buf.remaining() > entry_limit {
                    let entry_tag = ::buffa::encoding::Tag::decode(buf)?;
                    match entry_tag.field_number() {
                        1 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            key = ::buffa::types::decode_string(buf)?;
                        }
                        2 => {
                            if entry_tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: entry_tag.field_number(),
                                    expected: 2u8,
                                    actual: entry_tag.wire_type() as u8,
                                });
                            }
                            val = ::buffa::types::decode_string(buf)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(entry_tag, buf, depth)?;
                        }
                    }
                }
                if buf.remaining() != entry_limit {
                    let remaining = buf.remaining();
                    if remaining > entry_limit {
                        buf.advance(remaining - entry_limit);
                    } else {
                        return ::core::result::Result::Err(
                            ::buffa::DecodeError::UnexpectedEof,
                        );
                    }
                }
                self.properties.insert(key, val);
            }
            6u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 6u32,
                        expected: 0u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                self.expiration_time = ::core::option::Option::Some(
                    ::buffa::types::decode_int64(buf)?,
                );
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.name.clear();
        self.new_name = ::core::option::Option::None;
        self.owner = ::core::option::Option::None;
        self.comment = ::core::option::Option::None;
        self.properties.clear();
        self.expiration_time = ::core::option::Option::None;
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for UpdateRecipientRequest {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.UpdateRecipientRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for UpdateRecipientRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __UPDATE_RECIPIENT_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.UpdateRecipientRequest",
    to_json: ::buffa::type_registry::any_to_json::<UpdateRecipientRequest>,
    from_json: ::buffa::type_registry::any_from_json::<UpdateRecipientRequest>,
    is_wkt: false,
};
/// Delete a recipient
#[derive(Clone, PartialEq, Default)]
#[derive(::serde::Serialize, ::serde::Deserialize)]
#[serde(default)]
pub struct DeleteRecipientRequest {
    /// Name of the recipient.
    ///
    /// Field 1: `name`
    #[serde(
        rename = "name",
        with = "::buffa::json_helpers::proto_string",
        skip_serializing_if = "::buffa::json_helpers::skip_if::is_empty_str"
    )]
    pub name: ::buffa::alloc::string::String,
    #[serde(skip)]
    #[doc(hidden)]
    pub __buffa_unknown_fields: ::buffa::UnknownFields,
}
impl ::core::fmt::Debug for DeleteRecipientRequest {
    fn fmt(&self, f: &mut ::core::fmt::Formatter<'_>) -> ::core::fmt::Result {
        f.debug_struct("DeleteRecipientRequest").field("name", &self.name).finish()
    }
}
impl DeleteRecipientRequest {
    /// Protobuf type URL for this message, for use with `Any::pack` and
    /// `Any::unpack_if`.
    ///
    /// Format: `type.googleapis.com/<fully.qualified.TypeName>`
    pub const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.DeleteRecipientRequest";
}
impl ::buffa::DefaultInstance for DeleteRecipientRequest {
    fn default_instance() -> &'static Self {
        static VALUE: ::buffa::__private::OnceBox<DeleteRecipientRequest> = ::buffa::__private::OnceBox::new();
        VALUE.get_or_init(|| ::buffa::alloc::boxed::Box::new(Self::default()))
    }
}
impl ::buffa::MessageName for DeleteRecipientRequest {
    const PACKAGE: &'static str = "unitycatalog.recipients.v1";
    const NAME: &'static str = "DeleteRecipientRequest";
    const FULL_NAME: &'static str = "unitycatalog.recipients.v1.DeleteRecipientRequest";
    const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.DeleteRecipientRequest";
}
impl ::buffa::Message for DeleteRecipientRequest {
    /// Returns the total encoded size in bytes.
    ///
    /// The result is a `u32`; the protobuf specification requires all
    /// messages to fit within 2 GiB (2,147,483,647 bytes), so a
    /// compliant message will never overflow this type.
    #[allow(clippy::let_and_return)]
    fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        let mut size = 0u32;
        if !self.name.is_empty() {
            size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
        }
        size += self.__buffa_unknown_fields.encoded_len() as u32;
        size
    }
    fn write_to(
        &self,
        _cache: &mut ::buffa::SizeCache,
        buf: &mut impl ::buffa::bytes::BufMut,
    ) {
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        if !self.name.is_empty() {
            ::buffa::encoding::Tag::new(
                    1u32,
                    ::buffa::encoding::WireType::LengthDelimited,
                )
                .encode(buf);
            ::buffa::types::encode_string(&self.name, buf);
        }
        self.__buffa_unknown_fields.write_to(buf);
    }
    fn merge_field(
        &mut self,
        tag: ::buffa::encoding::Tag,
        buf: &mut impl ::buffa::bytes::Buf,
        depth: u32,
    ) -> ::core::result::Result<(), ::buffa::DecodeError> {
        #[allow(unused_imports)]
        use ::buffa::bytes::Buf as _;
        #[allow(unused_imports)]
        use ::buffa::Enumeration as _;
        match tag.field_number() {
            1u32 => {
                if tag.wire_type() != ::buffa::encoding::WireType::LengthDelimited {
                    return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                        field_number: 1u32,
                        expected: 2u8,
                        actual: tag.wire_type() as u8,
                    });
                }
                ::buffa::types::merge_string(&mut self.name, buf)?;
            }
            _ => {
                self.__buffa_unknown_fields
                    .push(::buffa::encoding::decode_unknown_field(tag, buf, depth)?);
            }
        }
        ::core::result::Result::Ok(())
    }
    fn clear(&mut self) {
        self.name.clear();
        self.__buffa_unknown_fields.clear();
    }
}
impl ::buffa::ExtensionSet for DeleteRecipientRequest {
    const PROTO_FQN: &'static str = "unitycatalog.recipients.v1.DeleteRecipientRequest";
    fn unknown_fields(&self) -> &::buffa::UnknownFields {
        &self.__buffa_unknown_fields
    }
    fn unknown_fields_mut(&mut self) -> &mut ::buffa::UnknownFields {
        &mut self.__buffa_unknown_fields
    }
}
impl ::buffa::json_helpers::ProtoElemJson for DeleteRecipientRequest {
    fn serialize_proto_json<S: ::serde::Serializer>(
        v: &Self,
        s: S,
    ) -> ::core::result::Result<S::Ok, S::Error> {
        ::serde::Serialize::serialize(v, s)
    }
    fn deserialize_proto_json<'de, D: ::serde::Deserializer<'de>>(
        d: D,
    ) -> ::core::result::Result<Self, D::Error> {
        <Self as ::serde::Deserialize>::deserialize(d)
    }
}
#[doc(hidden)]
pub const __DELETE_RECIPIENT_REQUEST_JSON_ANY: ::buffa::type_registry::JsonAnyEntry = ::buffa::type_registry::JsonAnyEntry {
    type_url: "type.googleapis.com/unitycatalog.recipients.v1.DeleteRecipientRequest",
    to_json: ::buffa::type_registry::any_to_json::<DeleteRecipientRequest>,
    from_json: ::buffa::type_registry::any_from_json::<DeleteRecipientRequest>,
    is_wkt: false,
};
#[allow(
    non_camel_case_types,
    dead_code,
    unused_imports,
    unused_qualifications,
    clippy::derivable_impls,
    clippy::match_single_binding,
    clippy::uninlined_format_args,
    clippy::doc_lazy_continuation,
    clippy::module_inception
)]
pub mod __buffa {
    #[allow(unused_imports)]
    use super::*;
    pub mod view {
        #[allow(unused_imports)]
        use super::*;
        #[derive(Clone, Debug, Default)]
        pub struct RecipientTokenView<'a> {
            /// Unique ID of the recipient token.
            ///
            /// Field 1: `id`
            pub id: &'a str,
            /// Time at which this recipient token was created, in epoch milliseconds.
            ///
            /// Field 2: `created_at`
            pub created_at: i64,
            /// Username of recipient token creator.
            ///
            /// Field 3: `created_by`
            pub created_by: &'a str,
            /// Full activation URL to retrieve the access token. It will be empty if the token is already retrieved.
            ///
            /// Field 4: `activation_url`
            pub activation_url: &'a str,
            /// Expiration timestamp of the token in epoch milliseconds.
            ///
            /// Field 5: `expiration_time`
            pub expiration_time: i64,
            /// Time at which this recipient token was updated, in epoch milliseconds.
            ///
            /// Field 6: `updated_at`
            pub updated_at: i64,
            /// Username of recipient token updater.
            ///
            /// Field 7: `updated_by`
            pub updated_by: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> RecipientTokenView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.id = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        2u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.created_at = ::buffa::types::decode_int64(&mut cur)?;
                        }
                        3u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 3u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.created_by = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        4u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 4u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.activation_url = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        5u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 5u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.expiration_time = ::buffa::types::decode_int64(
                                &mut cur,
                            )?;
                        }
                        6u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 6u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.updated_at = ::buffa::types::decode_int64(&mut cur)?;
                        }
                        7u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 7u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.updated_by = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for RecipientTokenView<'a> {
            type Owned = super::super::RecipientToken;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::RecipientToken {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::RecipientToken {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::RecipientToken {
                    id: self.id.to_string(),
                    created_at: self.created_at,
                    created_by: self.created_by.to_string(),
                    activation_url: self.activation_url.to_string(),
                    expiration_time: self.expiration_time,
                    updated_at: self.updated_at,
                    updated_by: self.updated_by.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for RecipientTokenView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.id.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.id) as u32;
                }
                if self.created_at != 0i64 {
                    size
                        += 1u32
                            + ::buffa::types::int64_encoded_len(self.created_at) as u32;
                }
                if !self.created_by.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.created_by)
                                as u32;
                }
                if !self.activation_url.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.activation_url)
                                as u32;
                }
                if self.expiration_time != 0i64 {
                    size
                        += 1u32
                            + ::buffa::types::int64_encoded_len(self.expiration_time)
                                as u32;
                }
                if self.updated_at != 0i64 {
                    size
                        += 1u32
                            + ::buffa::types::int64_encoded_len(self.updated_at) as u32;
                }
                if !self.updated_by.is_empty() {
                    size
                        += 1u32
                            + ::buffa::types::string_encoded_len(&self.updated_by)
                                as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.id.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.id, buf);
                }
                if self.created_at != 0i64 {
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(self.created_at, buf);
                }
                if !self.created_by.is_empty() {
                    ::buffa::encoding::Tag::new(
                            3u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.created_by, buf);
                }
                if !self.activation_url.is_empty() {
                    ::buffa::encoding::Tag::new(
                            4u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.activation_url, buf);
                }
                if self.expiration_time != 0i64 {
                    ::buffa::encoding::Tag::new(
                            5u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(self.expiration_time, buf);
                }
                if self.updated_at != 0i64 {
                    ::buffa::encoding::Tag::new(
                            6u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(self.updated_at, buf);
                }
                if !self.updated_by.is_empty() {
                    ::buffa::encoding::Tag::new(
                            7u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.updated_by, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for RecipientTokenView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.id) {
                    __map.serialize_entry("id", self.id)?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_i64(&self.created_at) {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("created_at", &_W(self.created_at))?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.created_by) {
                    __map.serialize_entry("created_by", self.created_by)?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.activation_url) {
                    __map.serialize_entry("activation_url", self.activation_url)?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_i64(&self.expiration_time) {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("expiration_time", &_W(self.expiration_time))?;
                }
                if !::buffa::json_helpers::skip_if::is_zero_i64(&self.updated_at) {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("updated_at", &_W(self.updated_at))?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.updated_by) {
                    __map.serialize_entry("updated_by", self.updated_by)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for RecipientTokenView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "RecipientToken";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.RecipientToken";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.RecipientToken";
        }
        impl<'v> ::buffa::DefaultViewInstance for RecipientTokenView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<RecipientTokenView<'static>> = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <RecipientTokenView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for RecipientTokenView<'static> {
            type Reborrowed<'b> = RecipientTokenView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `RecipientToken` message.

 Wraps [`::buffa::OwnedView`]`<`[`RecipientTokenView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`RecipientTokenView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct RecipientTokenOwnedView(
            ::buffa::OwnedView<RecipientTokenView<'static>>,
        );
        impl RecipientTokenOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientTokenOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientTokenOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::RecipientToken,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientTokenOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`RecipientTokenView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &RecipientTokenView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::RecipientToken {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Unique ID of the recipient token.
            ///
            /// Field 1: `id`
            #[must_use]
            pub fn id(&self) -> &'_ str {
                self.0.reborrow().id
            }
            /// Time at which this recipient token was created, in epoch milliseconds.
            ///
            /// Field 2: `created_at`
            #[must_use]
            pub fn created_at(&self) -> i64 {
                self.0.reborrow().created_at
            }
            /// Username of recipient token creator.
            ///
            /// Field 3: `created_by`
            #[must_use]
            pub fn created_by(&self) -> &'_ str {
                self.0.reborrow().created_by
            }
            /// Full activation URL to retrieve the access token. It will be empty if the token is already retrieved.
            ///
            /// Field 4: `activation_url`
            #[must_use]
            pub fn activation_url(&self) -> &'_ str {
                self.0.reborrow().activation_url
            }
            /// Expiration timestamp of the token in epoch milliseconds.
            ///
            /// Field 5: `expiration_time`
            #[must_use]
            pub fn expiration_time(&self) -> i64 {
                self.0.reborrow().expiration_time
            }
            /// Time at which this recipient token was updated, in epoch milliseconds.
            ///
            /// Field 6: `updated_at`
            #[must_use]
            pub fn updated_at(&self) -> i64 {
                self.0.reborrow().updated_at
            }
            /// Username of recipient token updater.
            ///
            /// Field 7: `updated_by`
            #[must_use]
            pub fn updated_by(&self) -> &'_ str {
                self.0.reborrow().updated_by
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<RecipientTokenView<'static>>>
        for RecipientTokenOwnedView {
            fn from(inner: ::buffa::OwnedView<RecipientTokenView<'static>>) -> Self {
                RecipientTokenOwnedView(inner)
            }
        }
        impl ::core::convert::From<RecipientTokenOwnedView>
        for ::buffa::OwnedView<RecipientTokenView<'static>> {
            fn from(wrapper: RecipientTokenOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<RecipientTokenView<'static>>>
        for RecipientTokenOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<RecipientTokenView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::RecipientToken {
            type View<'a> = RecipientTokenView<'a>;
            type ViewHandle = RecipientTokenOwnedView;
        }
        impl ::serde::Serialize for RecipientTokenOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        #[derive(Clone, Debug, Default)]
        pub struct RecipientView<'a> {
            /// Unique ID of the recipient.
            ///
            /// Field 100: `id`
            pub id: ::core::option::Option<&'a str>,
            /// The name of the recipient.
            ///
            /// Field 1: `name`
            pub name: &'a str,
            /// The delta sharing authentication type.
            ///
            /// Field 2: `authentication_type`
            pub authentication_type: ::buffa::EnumValue<
                super::super::AuthenticationType,
            >,
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            pub owner: ::core::option::Option<&'a str>,
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            pub comment: ::core::option::Option<&'a str>,
            /// A map of key-value properties attached to the securable.
            ///
            /// Field 6: `properties` (map)
            pub properties: ::buffa::MapView<'a, &'a str, &'a str>,
            /// Time at which this share was created, in epoch milliseconds.
            ///
            /// Field 7: `created_at`
            pub created_at: ::core::option::Option<i64>,
            /// Username of the creator of the share.
            ///
            /// Field 8: `created_by`
            pub created_by: ::core::option::Option<&'a str>,
            /// This field is only present when the authentication_type is TOKEN.
            ///
            /// Field 9: `tokens`
            pub tokens: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::RecipientTokenView<'a>,
            >,
            /// Time at which this share was updated, in epoch milliseconds.
            ///
            /// Field 10: `updated_at`
            pub updated_at: ::core::option::Option<i64>,
            /// Username of share updater.
            ///
            /// Field 11: `updated_by`
            pub updated_by: ::core::option::Option<&'a str>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> RecipientView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        100u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 100u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.id = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.name = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        2u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.authentication_type = ::buffa::EnumValue::from(
                                ::buffa::types::decode_int32(&mut cur)?,
                            );
                        }
                        3u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 3u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.owner = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        4u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 4u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.comment = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        7u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 7u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.created_at = Some(
                                ::buffa::types::decode_int64(&mut cur)?,
                            );
                        }
                        8u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 8u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.created_by = Some(
                                ::buffa::types::borrow_str(&mut cur)?,
                            );
                        }
                        10u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 10u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.updated_at = Some(
                                ::buffa::types::decode_int64(&mut cur)?,
                            );
                        }
                        11u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 11u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.updated_by = Some(
                                ::buffa::types::borrow_str(&mut cur)?,
                            );
                        }
                        9u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 9u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            if depth == 0 {
                                return Err(::buffa::DecodeError::RecursionLimitExceeded);
                            }
                            let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                            view.tokens
                                .push(
                                    super::super::__buffa::view::RecipientTokenView::_decode_depth(
                                        sub,
                                        depth - 1,
                                    )?,
                                );
                        }
                        6u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 6u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            let entry_bytes = ::buffa::types::borrow_bytes(&mut cur)?;
                            let mut entry_cur: &'a [u8] = entry_bytes;
                            let mut key = "";
                            let mut val = "";
                            while !entry_cur.is_empty() {
                                let entry_tag = ::buffa::encoding::Tag::decode(
                                    &mut entry_cur,
                                )?;
                                match entry_tag.field_number() {
                                    1 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        key = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    2 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        val = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    _ => {
                                        ::buffa::encoding::skip_field_depth(
                                            entry_tag,
                                            &mut entry_cur,
                                            depth,
                                        )?;
                                    }
                                }
                            }
                            view.properties.push(key, val);
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for RecipientView<'a> {
            type Owned = super::super::Recipient;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::Recipient {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::Recipient {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::Recipient {
                    id: self.id.map(|s| s.to_string()),
                    name: self.name.to_string(),
                    authentication_type: self.authentication_type,
                    owner: self.owner.map(|s| s.to_string()),
                    comment: self.comment.map(|s| s.to_string()),
                    properties: self
                        .properties
                        .iter()
                        .map(|(k, v)| (k.to_string(), v.to_string()))
                        .collect(),
                    created_at: self.created_at,
                    created_by: self.created_by.map(|s| s.to_string()),
                    tokens: self
                        .tokens
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect(),
                    updated_at: self.updated_at,
                    updated_by: self.updated_by.map(|s| s.to_string()),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for RecipientView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.name.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
                }
                {
                    let val = self.authentication_type.to_i32();
                    if val != 0 {
                        size += 1u32 + ::buffa::types::int32_encoded_len(val) as u32;
                    }
                }
                if let Some(ref v) = self.owner {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.comment {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                #[allow(clippy::for_kv_map)]
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    size
                        += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                            + entry_size;
                }
                if let Some(v) = self.created_at {
                    size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.created_by {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                for v in &self.tokens {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                if let Some(v) = self.updated_at {
                    size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.updated_by {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.id {
                    size += 2u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                __cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.name.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.name, buf);
                }
                {
                    let val = self.authentication_type.to_i32();
                    if val != 0 {
                        ::buffa::encoding::Tag::new(
                                2u32,
                                ::buffa::encoding::WireType::Varint,
                            )
                            .encode(buf);
                        ::buffa::types::encode_int32(val, buf);
                    }
                }
                if let Some(ref v) = self.owner {
                    ::buffa::encoding::Tag::new(
                            3u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(ref v) = self.comment {
                    ::buffa::encoding::Tag::new(
                            4u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    ::buffa::encoding::Tag::new(
                            6u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::encoding::encode_varint(entry_size as u64, buf);
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(k, buf);
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(v) = self.created_at {
                    ::buffa::encoding::Tag::new(
                            7u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(v, buf);
                }
                if let Some(ref v) = self.created_by {
                    ::buffa::encoding::Tag::new(
                            8u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                for v in &self.tokens {
                    ::buffa::encoding::Tag::new(
                            9u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
                    v.write_to(__cache, buf);
                }
                if let Some(v) = self.updated_at {
                    ::buffa::encoding::Tag::new(
                            10u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(v, buf);
                }
                if let Some(ref v) = self.updated_by {
                    ::buffa::encoding::Tag::new(
                            11u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(ref v) = self.id {
                    ::buffa::encoding::Tag::new(
                            100u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for RecipientView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if let ::core::option::Option::Some(__v) = self.id {
                    __map.serialize_entry("id", __v)?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.name) {
                    __map.serialize_entry("name", self.name)?;
                }
                if !::buffa::json_helpers::skip_if::is_default_enum_value(
                    &self.authentication_type,
                ) {
                    __map
                        .serialize_entry(
                            "authenticationType",
                            &self.authentication_type,
                        )?;
                }
                if let ::core::option::Option::Some(__v) = self.owner {
                    __map.serialize_entry("owner", __v)?;
                }
                if let ::core::option::Option::Some(__v) = self.comment {
                    __map.serialize_entry("comment", __v)?;
                }
                if !self.properties.is_empty() {
                    struct _WM<'__a, '__x>(
                        &'__x ::buffa::MapView<'__x, &'__a str, &'__a str>,
                    );
                    impl<'__a> ::serde::Serialize for _WM<'__a, '_> {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            use ::serde::ser::SerializeMap as _;
                            let mut __m = __s
                                .serialize_map(::core::option::Option::Some(self.0.len()))?;
                            for (k, v) in self.0.iter_unique() {
                                __m.serialize_entry(k, v)?;
                            }
                            __m.end()
                        }
                    }
                    __map.serialize_entry("properties", &_WM(&self.properties))?;
                }
                if let ::core::option::Option::Some(__v) = self.created_at {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("created_at", &_W(__v))?;
                }
                if let ::core::option::Option::Some(__v) = self.created_by {
                    __map.serialize_entry("created_by", __v)?;
                }
                if !self.tokens.is_empty() {
                    __map.serialize_entry("tokens", &*self.tokens)?;
                }
                if let ::core::option::Option::Some(__v) = self.updated_at {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("updated_at", &_W(__v))?;
                }
                if let ::core::option::Option::Some(__v) = self.updated_by {
                    __map.serialize_entry("updated_by", __v)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for RecipientView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "Recipient";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.Recipient";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.Recipient";
        }
        impl<'v> ::buffa::DefaultViewInstance for RecipientView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<RecipientView<'static>> = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <RecipientView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for RecipientView<'static> {
            type Reborrowed<'b> = RecipientView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `Recipient` message.

 Wraps [`::buffa::OwnedView`]`<`[`RecipientView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`RecipientView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct RecipientOwnedView(::buffa::OwnedView<RecipientView<'static>>);
        impl RecipientOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::Recipient,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    RecipientOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`RecipientView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &RecipientView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::Recipient {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Unique ID of the recipient.
            ///
            /// Field 100: `id`
            #[must_use]
            pub fn id(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().id
            }
            /// The name of the recipient.
            ///
            /// Field 1: `name`
            #[must_use]
            pub fn name(&self) -> &'_ str {
                self.0.reborrow().name
            }
            /// The delta sharing authentication type.
            ///
            /// Field 2: `authentication_type`
            #[must_use]
            pub fn authentication_type(
                &self,
            ) -> ::buffa::EnumValue<super::super::AuthenticationType> {
                self.0.reborrow().authentication_type
            }
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            #[must_use]
            pub fn owner(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().owner
            }
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            #[must_use]
            pub fn comment(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().comment
            }
            /// A map of key-value properties attached to the securable.
            ///
            /// Field 6: `properties` (map)
            #[must_use]
            pub fn properties(&self) -> &::buffa::MapView<'_, &'_ str, &'_ str> {
                &self.0.reborrow().properties
            }
            /// Time at which this share was created, in epoch milliseconds.
            ///
            /// Field 7: `created_at`
            #[must_use]
            pub fn created_at(&self) -> ::core::option::Option<i64> {
                self.0.reborrow().created_at
            }
            /// Username of the creator of the share.
            ///
            /// Field 8: `created_by`
            #[must_use]
            pub fn created_by(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().created_by
            }
            /// This field is only present when the authentication_type is TOKEN.
            ///
            /// Field 9: `tokens`
            #[must_use]
            pub fn tokens(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::RecipientTokenView<'_>,
            > {
                &self.0.reborrow().tokens
            }
            /// Time at which this share was updated, in epoch milliseconds.
            ///
            /// Field 10: `updated_at`
            #[must_use]
            pub fn updated_at(&self) -> ::core::option::Option<i64> {
                self.0.reborrow().updated_at
            }
            /// Username of share updater.
            ///
            /// Field 11: `updated_by`
            #[must_use]
            pub fn updated_by(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().updated_by
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<RecipientView<'static>>>
        for RecipientOwnedView {
            fn from(inner: ::buffa::OwnedView<RecipientView<'static>>) -> Self {
                RecipientOwnedView(inner)
            }
        }
        impl ::core::convert::From<RecipientOwnedView>
        for ::buffa::OwnedView<RecipientView<'static>> {
            fn from(wrapper: RecipientOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<RecipientView<'static>>>
        for RecipientOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<RecipientView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::Recipient {
            type View<'a> = RecipientView<'a>;
            type ViewHandle = RecipientOwnedView;
        }
        impl ::serde::Serialize for RecipientOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Request to list recipients.
        #[derive(Clone, Debug, Default)]
        pub struct ListRecipientsRequestView<'a> {
            /// The maximum number of results per page that should be returned.
            ///
            /// Field 1: `max_results`
            pub max_results: ::core::option::Option<i32>,
            /// Opaque pagination token to go to next page based on previous query.
            ///
            /// Field 2: `page_token`
            pub page_token: ::core::option::Option<&'a str>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ListRecipientsRequestView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.max_results = Some(
                                ::buffa::types::decode_int32(&mut cur)?,
                            );
                        }
                        2u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.page_token = Some(
                                ::buffa::types::borrow_str(&mut cur)?,
                            );
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for ListRecipientsRequestView<'a> {
            type Owned = super::super::ListRecipientsRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::ListRecipientsRequest {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::ListRecipientsRequest {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::ListRecipientsRequest {
                    max_results: self.max_results,
                    page_token: self.page_token.map(|s| s.to_string()),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for ListRecipientsRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if let Some(v) = self.max_results {
                    size += 1u32 + ::buffa::types::int32_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.page_token {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if let Some(v) = self.max_results {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int32(v, buf);
                }
                if let Some(ref v) = self.page_token {
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for ListRecipientsRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if let ::core::option::Option::Some(__v) = self.max_results {
                    struct _W(i32);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int32::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("max_results", &_W(__v))?;
                }
                if let ::core::option::Option::Some(__v) = self.page_token {
                    __map.serialize_entry("page_token", __v)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for ListRecipientsRequestView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "ListRecipientsRequest";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.ListRecipientsRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsRequest";
        }
        impl<'v> ::buffa::DefaultViewInstance for ListRecipientsRequestView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    ListRecipientsRequestView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <ListRecipientsRequestView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for ListRecipientsRequestView<'static> {
            type Reborrowed<'b> = ListRecipientsRequestView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `ListRecipientsRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`ListRecipientsRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`ListRecipientsRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct ListRecipientsRequestOwnedView(
            ::buffa::OwnedView<ListRecipientsRequestView<'static>>,
        );
        impl ListRecipientsRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::ListRecipientsRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`ListRecipientsRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &ListRecipientsRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::ListRecipientsRequest {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// The maximum number of results per page that should be returned.
            ///
            /// Field 1: `max_results`
            #[must_use]
            pub fn max_results(&self) -> ::core::option::Option<i32> {
                self.0.reborrow().max_results
            }
            /// Opaque pagination token to go to next page based on previous query.
            ///
            /// Field 2: `page_token`
            #[must_use]
            pub fn page_token(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().page_token
            }
        }
        impl ::core::convert::From<
            ::buffa::OwnedView<ListRecipientsRequestView<'static>>,
        > for ListRecipientsRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<ListRecipientsRequestView<'static>>,
            ) -> Self {
                ListRecipientsRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<ListRecipientsRequestOwnedView>
        for ::buffa::OwnedView<ListRecipientsRequestView<'static>> {
            fn from(wrapper: ListRecipientsRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<ListRecipientsRequestView<'static>>,
        > for ListRecipientsRequestOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<ListRecipientsRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::ListRecipientsRequest {
            type View<'a> = ListRecipientsRequestView<'a>;
            type ViewHandle = ListRecipientsRequestOwnedView;
        }
        impl ::serde::Serialize for ListRecipientsRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Response to list recipients.
        #[derive(Clone, Debug, Default)]
        pub struct ListRecipientsResponseView<'a> {
            /// List of recipients.
            ///
            /// Field 1: `recipients`
            pub recipients: ::buffa::RepeatedView<
                'a,
                super::super::__buffa::view::RecipientView<'a>,
            >,
            /// Opaque pagination token to go to next page based on previous query.
            ///
            /// Field 2: `next_page_token`
            pub next_page_token: ::core::option::Option<&'a str>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> ListRecipientsResponseView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        2u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.next_page_token = Some(
                                ::buffa::types::borrow_str(&mut cur)?,
                            );
                        }
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            if depth == 0 {
                                return Err(::buffa::DecodeError::RecursionLimitExceeded);
                            }
                            let sub = ::buffa::types::borrow_bytes(&mut cur)?;
                            view.recipients
                                .push(
                                    super::super::__buffa::view::RecipientView::_decode_depth(
                                        sub,
                                        depth - 1,
                                    )?,
                                );
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for ListRecipientsResponseView<'a> {
            type Owned = super::super::ListRecipientsResponse;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::ListRecipientsResponse {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::ListRecipientsResponse {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::ListRecipientsResponse {
                    recipients: self
                        .recipients
                        .iter()
                        .map(|v| v.to_owned_from_source(__buffa_src))
                        .collect(),
                    next_page_token: self.next_page_token.map(|s| s.to_string()),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for ListRecipientsResponseView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, __cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                for v in &self.recipients {
                    let __slot = __cache.reserve();
                    let inner_size = v.compute_size(__cache);
                    __cache.set(__slot, inner_size);
                    size
                        += 1u32 + ::buffa::encoding::varint_len(inner_size as u64) as u32
                            + inner_size;
                }
                if let Some(ref v) = self.next_page_token {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                __cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                for v in &self.recipients {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::encoding::encode_varint(__cache.consume_next() as u64, buf);
                    v.write_to(__cache, buf);
                }
                if let Some(ref v) = self.next_page_token {
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for ListRecipientsResponseView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !self.recipients.is_empty() {
                    __map.serialize_entry("recipients", &*self.recipients)?;
                }
                if let ::core::option::Option::Some(__v) = self.next_page_token {
                    __map.serialize_entry("next_page_token", __v)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for ListRecipientsResponseView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "ListRecipientsResponse";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.ListRecipientsResponse";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.ListRecipientsResponse";
        }
        impl<'v> ::buffa::DefaultViewInstance for ListRecipientsResponseView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    ListRecipientsResponseView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <ListRecipientsResponseView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for ListRecipientsResponseView<'static> {
            type Reborrowed<'b> = ListRecipientsResponseView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `ListRecipientsResponse` message.

 Wraps [`::buffa::OwnedView`]`<`[`ListRecipientsResponseView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`ListRecipientsResponseView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct ListRecipientsResponseOwnedView(
            ::buffa::OwnedView<ListRecipientsResponseView<'static>>,
        );
        impl ListRecipientsResponseOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsResponseOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsResponseOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::ListRecipientsResponse,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    ListRecipientsResponseOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`ListRecipientsResponseView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &ListRecipientsResponseView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::ListRecipientsResponse {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// List of recipients.
            ///
            /// Field 1: `recipients`
            #[must_use]
            pub fn recipients(
                &self,
            ) -> &::buffa::RepeatedView<
                '_,
                super::super::__buffa::view::RecipientView<'_>,
            > {
                &self.0.reborrow().recipients
            }
            /// Opaque pagination token to go to next page based on previous query.
            ///
            /// Field 2: `next_page_token`
            #[must_use]
            pub fn next_page_token(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().next_page_token
            }
        }
        impl ::core::convert::From<
            ::buffa::OwnedView<ListRecipientsResponseView<'static>>,
        > for ListRecipientsResponseOwnedView {
            fn from(
                inner: ::buffa::OwnedView<ListRecipientsResponseView<'static>>,
            ) -> Self {
                ListRecipientsResponseOwnedView(inner)
            }
        }
        impl ::core::convert::From<ListRecipientsResponseOwnedView>
        for ::buffa::OwnedView<ListRecipientsResponseView<'static>> {
            fn from(wrapper: ListRecipientsResponseOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<ListRecipientsResponseView<'static>>,
        > for ListRecipientsResponseOwnedView {
            fn as_ref(
                &self,
            ) -> &::buffa::OwnedView<ListRecipientsResponseView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::ListRecipientsResponse {
            type View<'a> = ListRecipientsResponseView<'a>;
            type ViewHandle = ListRecipientsResponseOwnedView;
        }
        impl ::serde::Serialize for ListRecipientsResponseOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Creates a new recipient
        #[derive(Clone, Debug, Default)]
        pub struct CreateRecipientRequestView<'a> {
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            pub name: &'a str,
            /// The delta sharing authentication type.
            ///
            /// Field 2: `authentication_type`
            pub authentication_type: ::buffa::EnumValue<
                super::super::AuthenticationType,
            >,
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            pub owner: &'a str,
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            pub comment: ::core::option::Option<&'a str>,
            /// Recipient properties as map of string key-value pairs.
            ///
            /// When provided in update request, the specified properties will override the existing properties.
            /// To add and remove properties, one would need to perform a read-modify-write.
            ///
            /// Field 5: `properties` (map)
            pub properties: ::buffa::MapView<'a, &'a str, &'a str>,
            /// Expiration timestamp of the token, in epoch milliseconds.
            ///
            /// Field 6: `expiration_time`
            pub expiration_time: ::core::option::Option<i64>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> CreateRecipientRequestView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.name = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        2u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.authentication_type = ::buffa::EnumValue::from(
                                ::buffa::types::decode_int32(&mut cur)?,
                            );
                        }
                        3u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 3u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.owner = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        4u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 4u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.comment = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        6u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 6u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.expiration_time = Some(
                                ::buffa::types::decode_int64(&mut cur)?,
                            );
                        }
                        5u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 5u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            let entry_bytes = ::buffa::types::borrow_bytes(&mut cur)?;
                            let mut entry_cur: &'a [u8] = entry_bytes;
                            let mut key = "";
                            let mut val = "";
                            while !entry_cur.is_empty() {
                                let entry_tag = ::buffa::encoding::Tag::decode(
                                    &mut entry_cur,
                                )?;
                                match entry_tag.field_number() {
                                    1 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        key = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    2 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        val = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    _ => {
                                        ::buffa::encoding::skip_field_depth(
                                            entry_tag,
                                            &mut entry_cur,
                                            depth,
                                        )?;
                                    }
                                }
                            }
                            view.properties.push(key, val);
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for CreateRecipientRequestView<'a> {
            type Owned = super::super::CreateRecipientRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::CreateRecipientRequest {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::CreateRecipientRequest {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::CreateRecipientRequest {
                    name: self.name.to_string(),
                    authentication_type: self.authentication_type,
                    owner: self.owner.to_string(),
                    comment: self.comment.map(|s| s.to_string()),
                    properties: self
                        .properties
                        .iter()
                        .map(|(k, v)| (k.to_string(), v.to_string()))
                        .collect(),
                    expiration_time: self.expiration_time,
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for CreateRecipientRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.name.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
                }
                {
                    let val = self.authentication_type.to_i32();
                    if val != 0 {
                        size += 1u32 + ::buffa::types::int32_encoded_len(val) as u32;
                    }
                }
                if !self.owner.is_empty() {
                    size
                        += 1u32 + ::buffa::types::string_encoded_len(&self.owner) as u32;
                }
                if let Some(ref v) = self.comment {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                #[allow(clippy::for_kv_map)]
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    size
                        += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                            + entry_size;
                }
                if let Some(v) = self.expiration_time {
                    size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.name.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.name, buf);
                }
                {
                    let val = self.authentication_type.to_i32();
                    if val != 0 {
                        ::buffa::encoding::Tag::new(
                                2u32,
                                ::buffa::encoding::WireType::Varint,
                            )
                            .encode(buf);
                        ::buffa::types::encode_int32(val, buf);
                    }
                }
                if !self.owner.is_empty() {
                    ::buffa::encoding::Tag::new(
                            3u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.owner, buf);
                }
                if let Some(ref v) = self.comment {
                    ::buffa::encoding::Tag::new(
                            4u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    ::buffa::encoding::Tag::new(
                            5u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::encoding::encode_varint(entry_size as u64, buf);
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(k, buf);
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(v) = self.expiration_time {
                    ::buffa::encoding::Tag::new(
                            6u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(v, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for CreateRecipientRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.name) {
                    __map.serialize_entry("name", self.name)?;
                }
                if !::buffa::json_helpers::skip_if::is_default_enum_value(
                    &self.authentication_type,
                ) {
                    __map
                        .serialize_entry(
                            "authenticationType",
                            &self.authentication_type,
                        )?;
                }
                if !::buffa::json_helpers::skip_if::is_empty_str(self.owner) {
                    __map.serialize_entry("owner", self.owner)?;
                }
                if let ::core::option::Option::Some(__v) = self.comment {
                    __map.serialize_entry("comment", __v)?;
                }
                if !self.properties.is_empty() {
                    struct _WM<'__a, '__x>(
                        &'__x ::buffa::MapView<'__x, &'__a str, &'__a str>,
                    );
                    impl<'__a> ::serde::Serialize for _WM<'__a, '_> {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            use ::serde::ser::SerializeMap as _;
                            let mut __m = __s
                                .serialize_map(::core::option::Option::Some(self.0.len()))?;
                            for (k, v) in self.0.iter_unique() {
                                __m.serialize_entry(k, v)?;
                            }
                            __m.end()
                        }
                    }
                    __map.serialize_entry("properties", &_WM(&self.properties))?;
                }
                if let ::core::option::Option::Some(__v) = self.expiration_time {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("expiration_time", &_W(__v))?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for CreateRecipientRequestView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "CreateRecipientRequest";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.CreateRecipientRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.CreateRecipientRequest";
        }
        impl<'v> ::buffa::DefaultViewInstance for CreateRecipientRequestView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    CreateRecipientRequestView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <CreateRecipientRequestView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for CreateRecipientRequestView<'static> {
            type Reborrowed<'b> = CreateRecipientRequestView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `CreateRecipientRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`CreateRecipientRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`CreateRecipientRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct CreateRecipientRequestOwnedView(
            ::buffa::OwnedView<CreateRecipientRequestView<'static>>,
        );
        impl CreateRecipientRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CreateRecipientRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CreateRecipientRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::CreateRecipientRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    CreateRecipientRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`CreateRecipientRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &CreateRecipientRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::CreateRecipientRequest {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            #[must_use]
            pub fn name(&self) -> &'_ str {
                self.0.reborrow().name
            }
            /// The delta sharing authentication type.
            ///
            /// Field 2: `authentication_type`
            #[must_use]
            pub fn authentication_type(
                &self,
            ) -> ::buffa::EnumValue<super::super::AuthenticationType> {
                self.0.reborrow().authentication_type
            }
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            #[must_use]
            pub fn owner(&self) -> &'_ str {
                self.0.reborrow().owner
            }
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            #[must_use]
            pub fn comment(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().comment
            }
            /// Recipient properties as map of string key-value pairs.
            ///
            /// When provided in update request, the specified properties will override the existing properties.
            /// To add and remove properties, one would need to perform a read-modify-write.
            ///
            /// Field 5: `properties` (map)
            #[must_use]
            pub fn properties(&self) -> &::buffa::MapView<'_, &'_ str, &'_ str> {
                &self.0.reborrow().properties
            }
            /// Expiration timestamp of the token, in epoch milliseconds.
            ///
            /// Field 6: `expiration_time`
            #[must_use]
            pub fn expiration_time(&self) -> ::core::option::Option<i64> {
                self.0.reborrow().expiration_time
            }
        }
        impl ::core::convert::From<
            ::buffa::OwnedView<CreateRecipientRequestView<'static>>,
        > for CreateRecipientRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<CreateRecipientRequestView<'static>>,
            ) -> Self {
                CreateRecipientRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<CreateRecipientRequestOwnedView>
        for ::buffa::OwnedView<CreateRecipientRequestView<'static>> {
            fn from(wrapper: CreateRecipientRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<CreateRecipientRequestView<'static>>,
        > for CreateRecipientRequestOwnedView {
            fn as_ref(
                &self,
            ) -> &::buffa::OwnedView<CreateRecipientRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::CreateRecipientRequest {
            type View<'a> = CreateRecipientRequestView<'a>;
            type ViewHandle = CreateRecipientRequestOwnedView;
        }
        impl ::serde::Serialize for CreateRecipientRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Get a recipient by name.
        #[derive(Clone, Debug, Default)]
        pub struct GetRecipientRequestView<'a> {
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            pub name: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> GetRecipientRequestView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.name = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for GetRecipientRequestView<'a> {
            type Owned = super::super::GetRecipientRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::GetRecipientRequest {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::GetRecipientRequest {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::GetRecipientRequest {
                    name: self.name.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for GetRecipientRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.name.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.name.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.name, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for GetRecipientRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.name) {
                    __map.serialize_entry("name", self.name)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for GetRecipientRequestView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "GetRecipientRequest";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.GetRecipientRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.GetRecipientRequest";
        }
        impl<'v> ::buffa::DefaultViewInstance for GetRecipientRequestView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    GetRecipientRequestView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <GetRecipientRequestView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for GetRecipientRequestView<'static> {
            type Reborrowed<'b> = GetRecipientRequestView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `GetRecipientRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`GetRecipientRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`GetRecipientRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct GetRecipientRequestOwnedView(
            ::buffa::OwnedView<GetRecipientRequestView<'static>>,
        );
        impl GetRecipientRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    GetRecipientRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    GetRecipientRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::GetRecipientRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    GetRecipientRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`GetRecipientRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &GetRecipientRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::GetRecipientRequest {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            #[must_use]
            pub fn name(&self) -> &'_ str {
                self.0.reborrow().name
            }
        }
        impl ::core::convert::From<::buffa::OwnedView<GetRecipientRequestView<'static>>>
        for GetRecipientRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<GetRecipientRequestView<'static>>,
            ) -> Self {
                GetRecipientRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<GetRecipientRequestOwnedView>
        for ::buffa::OwnedView<GetRecipientRequestView<'static>> {
            fn from(wrapper: GetRecipientRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<::buffa::OwnedView<GetRecipientRequestView<'static>>>
        for GetRecipientRequestOwnedView {
            fn as_ref(&self) -> &::buffa::OwnedView<GetRecipientRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::GetRecipientRequest {
            type View<'a> = GetRecipientRequestView<'a>;
            type ViewHandle = GetRecipientRequestOwnedView;
        }
        impl ::serde::Serialize for GetRecipientRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Update a recipient
        #[derive(Clone, Debug, Default)]
        pub struct UpdateRecipientRequestView<'a> {
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            pub name: &'a str,
            /// New name for the recipient
            ///
            /// Field 2: `new_name`
            pub new_name: ::core::option::Option<&'a str>,
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            pub owner: ::core::option::Option<&'a str>,
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            pub comment: ::core::option::Option<&'a str>,
            /// Recipient properties as map of string key-value pairs.
            ///
            /// When provided in update request, the specified properties will override the existing properties.
            /// To add and remove properties, one would need to perform a read-modify-write.
            ///
            /// Field 5: `properties` (map)
            pub properties: ::buffa::MapView<'a, &'a str, &'a str>,
            /// Expiration timestamp of the token, in epoch milliseconds.
            ///
            /// Field 6: `expiration_time`
            pub expiration_time: ::core::option::Option<i64>,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> UpdateRecipientRequestView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.name = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        2u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 2u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.new_name = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        3u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 3u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.owner = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        4u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 4u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.comment = Some(::buffa::types::borrow_str(&mut cur)?);
                        }
                        6u32 => {
                            if tag.wire_type() != ::buffa::encoding::WireType::Varint {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 6u32,
                                    expected: 0u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.expiration_time = Some(
                                ::buffa::types::decode_int64(&mut cur)?,
                            );
                        }
                        5u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 5u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            let entry_bytes = ::buffa::types::borrow_bytes(&mut cur)?;
                            let mut entry_cur: &'a [u8] = entry_bytes;
                            let mut key = "";
                            let mut val = "";
                            while !entry_cur.is_empty() {
                                let entry_tag = ::buffa::encoding::Tag::decode(
                                    &mut entry_cur,
                                )?;
                                match entry_tag.field_number() {
                                    1 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        key = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    2 => {
                                        if entry_tag.wire_type()
                                            != ::buffa::encoding::WireType::LengthDelimited
                                        {
                                            return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                                field_number: entry_tag.field_number(),
                                                expected: 2u8,
                                                actual: entry_tag.wire_type() as u8,
                                            });
                                        }
                                        val = ::buffa::types::borrow_str(&mut entry_cur)?;
                                    }
                                    _ => {
                                        ::buffa::encoding::skip_field_depth(
                                            entry_tag,
                                            &mut entry_cur,
                                            depth,
                                        )?;
                                    }
                                }
                            }
                            view.properties.push(key, val);
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for UpdateRecipientRequestView<'a> {
            type Owned = super::super::UpdateRecipientRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::UpdateRecipientRequest {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::UpdateRecipientRequest {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::UpdateRecipientRequest {
                    name: self.name.to_string(),
                    new_name: self.new_name.map(|s| s.to_string()),
                    owner: self.owner.map(|s| s.to_string()),
                    comment: self.comment.map(|s| s.to_string()),
                    properties: self
                        .properties
                        .iter()
                        .map(|(k, v)| (k.to_string(), v.to_string()))
                        .collect(),
                    expiration_time: self.expiration_time,
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for UpdateRecipientRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.name.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
                }
                if let Some(ref v) = self.new_name {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.owner {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                if let Some(ref v) = self.comment {
                    size += 1u32 + ::buffa::types::string_encoded_len(v) as u32;
                }
                #[allow(clippy::for_kv_map)]
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    size
                        += 1u32 + ::buffa::encoding::varint_len(entry_size as u64) as u32
                            + entry_size;
                }
                if let Some(v) = self.expiration_time {
                    size += 1u32 + ::buffa::types::int64_encoded_len(v) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.name.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.name, buf);
                }
                if let Some(ref v) = self.new_name {
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(ref v) = self.owner {
                    ::buffa::encoding::Tag::new(
                            3u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(ref v) = self.comment {
                    ::buffa::encoding::Tag::new(
                            4u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                for (k, v) in &self.properties {
                    let entry_size: u32 = 1u32
                        + ::buffa::types::string_encoded_len(k) as u32 + 1u32
                        + ::buffa::types::string_encoded_len(v) as u32;
                    ::buffa::encoding::Tag::new(
                            5u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::encoding::encode_varint(entry_size as u64, buf);
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(k, buf);
                    ::buffa::encoding::Tag::new(
                            2u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(v, buf);
                }
                if let Some(v) = self.expiration_time {
                    ::buffa::encoding::Tag::new(
                            6u32,
                            ::buffa::encoding::WireType::Varint,
                        )
                        .encode(buf);
                    ::buffa::types::encode_int64(v, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for UpdateRecipientRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.name) {
                    __map.serialize_entry("name", self.name)?;
                }
                if let ::core::option::Option::Some(__v) = self.new_name {
                    __map.serialize_entry("new_name", __v)?;
                }
                if let ::core::option::Option::Some(__v) = self.owner {
                    __map.serialize_entry("owner", __v)?;
                }
                if let ::core::option::Option::Some(__v) = self.comment {
                    __map.serialize_entry("comment", __v)?;
                }
                if !self.properties.is_empty() {
                    struct _WM<'__a, '__x>(
                        &'__x ::buffa::MapView<'__x, &'__a str, &'__a str>,
                    );
                    impl<'__a> ::serde::Serialize for _WM<'__a, '_> {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            use ::serde::ser::SerializeMap as _;
                            let mut __m = __s
                                .serialize_map(::core::option::Option::Some(self.0.len()))?;
                            for (k, v) in self.0.iter_unique() {
                                __m.serialize_entry(k, v)?;
                            }
                            __m.end()
                        }
                    }
                    __map.serialize_entry("properties", &_WM(&self.properties))?;
                }
                if let ::core::option::Option::Some(__v) = self.expiration_time {
                    struct _W(i64);
                    impl ::serde::Serialize for _W {
                        fn serialize<__S: ::serde::Serializer>(
                            &self,
                            __s: __S,
                        ) -> ::core::result::Result<__S::Ok, __S::Error> {
                            ::buffa::json_helpers::int64::serialize(&self.0, __s)
                        }
                    }
                    __map.serialize_entry("expiration_time", &_W(__v))?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for UpdateRecipientRequestView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "UpdateRecipientRequest";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.UpdateRecipientRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.UpdateRecipientRequest";
        }
        impl<'v> ::buffa::DefaultViewInstance for UpdateRecipientRequestView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    UpdateRecipientRequestView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <UpdateRecipientRequestView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for UpdateRecipientRequestView<'static> {
            type Reborrowed<'b> = UpdateRecipientRequestView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `UpdateRecipientRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`UpdateRecipientRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`UpdateRecipientRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct UpdateRecipientRequestOwnedView(
            ::buffa::OwnedView<UpdateRecipientRequestView<'static>>,
        );
        impl UpdateRecipientRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    UpdateRecipientRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    UpdateRecipientRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::UpdateRecipientRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    UpdateRecipientRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`UpdateRecipientRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &UpdateRecipientRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::UpdateRecipientRequest {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            #[must_use]
            pub fn name(&self) -> &'_ str {
                self.0.reborrow().name
            }
            /// New name for the recipient
            ///
            /// Field 2: `new_name`
            #[must_use]
            pub fn new_name(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().new_name
            }
            /// Username of the recipient owner.
            ///
            /// Field 3: `owner`
            #[must_use]
            pub fn owner(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().owner
            }
            /// Description about the recipient.
            ///
            /// Field 4: `comment`
            #[must_use]
            pub fn comment(&self) -> ::core::option::Option<&'_ str> {
                self.0.reborrow().comment
            }
            /// Recipient properties as map of string key-value pairs.
            ///
            /// When provided in update request, the specified properties will override the existing properties.
            /// To add and remove properties, one would need to perform a read-modify-write.
            ///
            /// Field 5: `properties` (map)
            #[must_use]
            pub fn properties(&self) -> &::buffa::MapView<'_, &'_ str, &'_ str> {
                &self.0.reborrow().properties
            }
            /// Expiration timestamp of the token, in epoch milliseconds.
            ///
            /// Field 6: `expiration_time`
            #[must_use]
            pub fn expiration_time(&self) -> ::core::option::Option<i64> {
                self.0.reborrow().expiration_time
            }
        }
        impl ::core::convert::From<
            ::buffa::OwnedView<UpdateRecipientRequestView<'static>>,
        > for UpdateRecipientRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<UpdateRecipientRequestView<'static>>,
            ) -> Self {
                UpdateRecipientRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<UpdateRecipientRequestOwnedView>
        for ::buffa::OwnedView<UpdateRecipientRequestView<'static>> {
            fn from(wrapper: UpdateRecipientRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<UpdateRecipientRequestView<'static>>,
        > for UpdateRecipientRequestOwnedView {
            fn as_ref(
                &self,
            ) -> &::buffa::OwnedView<UpdateRecipientRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::UpdateRecipientRequest {
            type View<'a> = UpdateRecipientRequestView<'a>;
            type ViewHandle = UpdateRecipientRequestOwnedView;
        }
        impl ::serde::Serialize for UpdateRecipientRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
        /// Delete a recipient
        #[derive(Clone, Debug, Default)]
        pub struct DeleteRecipientRequestView<'a> {
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            pub name: &'a str,
            pub __buffa_unknown_fields: ::buffa::UnknownFieldsView<'a>,
        }
        impl<'a> DeleteRecipientRequestView<'a> {
            /// Decode from `buf`, enforcing a recursion depth limit for nested messages.
            ///
            /// Called by [`::buffa::MessageView::decode_view`] with [`::buffa::RECURSION_LIMIT`]
            /// and by generated sub-message decode arms with `depth - 1`.
            ///
            /// **Not part of the public API.** Named with a leading underscore to
            /// signal that it is for generated-code use only.
            #[doc(hidden)]
            pub fn _decode_depth(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                let mut view = Self::default();
                view._merge_into_view(buf, depth)?;
                ::core::result::Result::Ok(view)
            }
            /// Merge fields from `buf` into this view (proto merge semantics).
            ///
            /// Repeated fields append; singular fields last-wins; singular
            /// MESSAGE fields merge recursively. Used by sub-message decode
            /// arms when the same field appears multiple times on the wire.
            ///
            /// **Not part of the public API.**
            #[doc(hidden)]
            pub fn _merge_into_view(
                &mut self,
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<(), ::buffa::DecodeError> {
                let _ = depth;
                #[allow(unused_variables)]
                let view = self;
                let mut cur: &'a [u8] = buf;
                while !cur.is_empty() {
                    let before_tag = cur;
                    let tag = ::buffa::encoding::Tag::decode(&mut cur)?;
                    match tag.field_number() {
                        1u32 => {
                            if tag.wire_type()
                                != ::buffa::encoding::WireType::LengthDelimited
                            {
                                return ::core::result::Result::Err(::buffa::DecodeError::WireTypeMismatch {
                                    field_number: 1u32,
                                    expected: 2u8,
                                    actual: tag.wire_type() as u8,
                                });
                            }
                            view.name = ::buffa::types::borrow_str(&mut cur)?;
                        }
                        _ => {
                            ::buffa::encoding::skip_field_depth(tag, &mut cur, depth)?;
                            let span_len = before_tag.len() - cur.len();
                            view.__buffa_unknown_fields
                                .push_raw(&before_tag[..span_len]);
                        }
                    }
                }
                ::core::result::Result::Ok(())
            }
        }
        impl<'a> ::buffa::MessageView<'a> for DeleteRecipientRequestView<'a> {
            type Owned = super::super::DeleteRecipientRequest;
            fn decode_view(
                buf: &'a [u8],
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, ::buffa::RECURSION_LIMIT)
            }
            fn decode_view_with_limit(
                buf: &'a [u8],
                depth: u32,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                Self::_decode_depth(buf, depth)
            }
            fn to_owned_message(&self) -> super::super::DeleteRecipientRequest {
                self.to_owned_from_source(None)
            }
            #[allow(clippy::useless_conversion, clippy::needless_update)]
            fn to_owned_from_source(
                &self,
                __buffa_src: ::core::option::Option<&::buffa::bytes::Bytes>,
            ) -> super::super::DeleteRecipientRequest {
                #[allow(unused_imports)]
                use ::buffa::alloc::string::ToString as _;
                let _ = __buffa_src;
                super::super::DeleteRecipientRequest {
                    name: self.name.to_string(),
                    __buffa_unknown_fields: self
                        .__buffa_unknown_fields
                        .to_owned()
                        .unwrap_or_default()
                        .into(),
                    ..::core::default::Default::default()
                }
            }
        }
        impl<'a> ::buffa::ViewEncode<'a> for DeleteRecipientRequestView<'a> {
            #[allow(clippy::needless_borrow, clippy::let_and_return)]
            fn compute_size(&self, _cache: &mut ::buffa::SizeCache) -> u32 {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                let mut size = 0u32;
                if !self.name.is_empty() {
                    size += 1u32 + ::buffa::types::string_encoded_len(&self.name) as u32;
                }
                size += self.__buffa_unknown_fields.encoded_len() as u32;
                size
            }
            #[allow(clippy::needless_borrow)]
            fn write_to(
                &self,
                _cache: &mut ::buffa::SizeCache,
                buf: &mut impl ::buffa::bytes::BufMut,
            ) {
                #[allow(unused_imports)]
                use ::buffa::Enumeration as _;
                if !self.name.is_empty() {
                    ::buffa::encoding::Tag::new(
                            1u32,
                            ::buffa::encoding::WireType::LengthDelimited,
                        )
                        .encode(buf);
                    ::buffa::types::encode_string(&self.name, buf);
                }
                self.__buffa_unknown_fields.write_to(buf);
            }
        }
        /// Serializes this view as protobuf JSON.
        ///
        /// Implicit-presence fields with default values are omitted, `required`
        /// fields are always emitted, explicit-presence (`optional`) fields are
        /// emitted only when set, bytes fields are base64-encoded, and enum
        /// values are their proto name strings.
        ///
        /// This impl uses `serialize_map(None)` because the number of emitted
        /// fields depends on default-omission rules; serializers that require
        /// known map lengths (e.g. `bincode`) will return a runtime error.
        /// Use the owned message type for those formats.
        impl<'__a> ::serde::Serialize for DeleteRecipientRequestView<'__a> {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                use ::serde::ser::SerializeMap as _;
                let mut __map = __s.serialize_map(::core::option::Option::None)?;
                if !::buffa::json_helpers::skip_if::is_empty_str(self.name) {
                    __map.serialize_entry("name", self.name)?;
                }
                __map.end()
            }
        }
        impl<'a> ::buffa::MessageName for DeleteRecipientRequestView<'a> {
            const PACKAGE: &'static str = "unitycatalog.recipients.v1";
            const NAME: &'static str = "DeleteRecipientRequest";
            const FULL_NAME: &'static str = "unitycatalog.recipients.v1.DeleteRecipientRequest";
            const TYPE_URL: &'static str = "type.googleapis.com/unitycatalog.recipients.v1.DeleteRecipientRequest";
        }
        impl<'v> ::buffa::DefaultViewInstance for DeleteRecipientRequestView<'v> {
            fn default_view_instance<'a>() -> &'a Self
            where
                Self: 'a,
            {
                static VALUE: ::buffa::__private::OnceBox<
                    DeleteRecipientRequestView<'static>,
                > = ::buffa::__private::OnceBox::new();
                VALUE
                    .get_or_init(|| ::buffa::alloc::boxed::Box::new(
                        <DeleteRecipientRequestView<'static>>::default(),
                    ))
            }
        }
        impl ::buffa::ViewReborrow for DeleteRecipientRequestView<'static> {
            type Reborrowed<'b> = DeleteRecipientRequestView<'b>;
            fn reborrow<'b>(this: &'b Self) -> &'b Self::Reborrowed<'b> {
                this
            }
        }
        /** Self-contained, `'static` owned view of a `DeleteRecipientRequest` message.

 Wraps [`::buffa::OwnedView`]`<`[`DeleteRecipientRequestView`]`<'static>>`: the decoded view and the [`::buffa::bytes::Bytes`] buffer it borrows from travel together, so the handle is `'static` and `Send + Sync` — suitable for async handlers, spawned tasks, and anywhere a `'static` bound is required.

 Field accessors return borrows tied to `&self`. Use [`Self::view`] to get the full [`DeleteRecipientRequestView`] when you need struct patterns, iteration helpers, or to pass the view to lifetime-parameterised code.*/
        #[derive(Clone, Debug)]
        pub struct DeleteRecipientRequestOwnedView(
            ::buffa::OwnedView<DeleteRecipientRequestView<'static>>,
        );
        impl DeleteRecipientRequestOwnedView {
            /// Decode an owned view from a [`::buffa::bytes::Bytes`] buffer.
            ///
            /// The view borrows directly from the buffer's data; the buffer is
            /// retained inside the returned handle.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer contains invalid
            /// protobuf data.
            pub fn decode(
                bytes: ::buffa::bytes::Bytes,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    DeleteRecipientRequestOwnedView(::buffa::OwnedView::decode(bytes)?),
                )
            }
            /// Decode with custom [`::buffa::DecodeOptions`] (recursion limit,
            /// max message size).
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the buffer is invalid or
            /// exceeds the configured limits.
            pub fn decode_with_options(
                bytes: ::buffa::bytes::Bytes,
                opts: &::buffa::DecodeOptions,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    DeleteRecipientRequestOwnedView(
                        ::buffa::OwnedView::decode_with_options(bytes, opts)?,
                    ),
                )
            }
            /// Build from an owned message via an encode → decode round-trip.
            ///
            /// # Errors
            ///
            /// Returns [`::buffa::DecodeError`] if the re-encoded bytes are
            /// somehow invalid (should not happen for well-formed messages).
            pub fn from_owned(
                msg: &super::super::DeleteRecipientRequest,
            ) -> ::core::result::Result<Self, ::buffa::DecodeError> {
                ::core::result::Result::Ok(
                    DeleteRecipientRequestOwnedView(::buffa::OwnedView::from_owned(msg)?),
                )
            }
            /// Borrow the full [`DeleteRecipientRequestView`] with its lifetime tied to `&self`.
            #[must_use]
            pub fn view(&self) -> &DeleteRecipientRequestView<'_> {
                self.0.reborrow()
            }
            /// Convert to the owned message type.
            #[must_use]
            pub fn to_owned_message(&self) -> super::super::DeleteRecipientRequest {
                self.0.to_owned_message()
            }
            /// The underlying bytes buffer.
            #[must_use]
            pub fn bytes(&self) -> &::buffa::bytes::Bytes {
                self.0.bytes()
            }
            /// Consume the handle, returning the underlying bytes buffer.
            #[must_use]
            pub fn into_bytes(self) -> ::buffa::bytes::Bytes {
                self.0.into_bytes()
            }
            /// Name of the recipient.
            ///
            /// Field 1: `name`
            #[must_use]
            pub fn name(&self) -> &'_ str {
                self.0.reborrow().name
            }
        }
        impl ::core::convert::From<
            ::buffa::OwnedView<DeleteRecipientRequestView<'static>>,
        > for DeleteRecipientRequestOwnedView {
            fn from(
                inner: ::buffa::OwnedView<DeleteRecipientRequestView<'static>>,
            ) -> Self {
                DeleteRecipientRequestOwnedView(inner)
            }
        }
        impl ::core::convert::From<DeleteRecipientRequestOwnedView>
        for ::buffa::OwnedView<DeleteRecipientRequestView<'static>> {
            fn from(wrapper: DeleteRecipientRequestOwnedView) -> Self {
                wrapper.0
            }
        }
        impl ::core::convert::AsRef<
            ::buffa::OwnedView<DeleteRecipientRequestView<'static>>,
        > for DeleteRecipientRequestOwnedView {
            fn as_ref(
                &self,
            ) -> &::buffa::OwnedView<DeleteRecipientRequestView<'static>> {
                &self.0
            }
        }
        impl ::buffa::HasMessageView for super::super::DeleteRecipientRequest {
            type View<'a> = DeleteRecipientRequestView<'a>;
            type ViewHandle = DeleteRecipientRequestOwnedView;
        }
        impl ::serde::Serialize for DeleteRecipientRequestOwnedView {
            fn serialize<__S: ::serde::Serializer>(
                &self,
                __s: __S,
            ) -> ::core::result::Result<__S::Ok, __S::Error> {
                ::serde::Serialize::serialize(&self.0, __s)
            }
        }
    }
    /// Register this package's `Any` type entries and extension entries.
    pub fn register_types(reg: &mut ::buffa::type_registry::TypeRegistry) {
        reg.register_json_any(super::__RECIPIENT_TOKEN_JSON_ANY);
        reg.register_json_any(super::__RECIPIENT_JSON_ANY);
        reg.register_json_any(super::__LIST_RECIPIENTS_REQUEST_JSON_ANY);
        reg.register_json_any(super::__LIST_RECIPIENTS_RESPONSE_JSON_ANY);
        reg.register_json_any(super::__CREATE_RECIPIENT_REQUEST_JSON_ANY);
        reg.register_json_any(super::__GET_RECIPIENT_REQUEST_JSON_ANY);
        reg.register_json_any(super::__UPDATE_RECIPIENT_REQUEST_JSON_ANY);
        reg.register_json_any(super::__DELETE_RECIPIENT_REQUEST_JSON_ANY);
    }
}
#[doc(inline)]
pub use self::__buffa::view::RecipientTokenView;
#[doc(inline)]
pub use self::__buffa::view::RecipientTokenOwnedView;
#[doc(inline)]
pub use self::__buffa::view::RecipientView;
#[doc(inline)]
pub use self::__buffa::view::RecipientOwnedView;
#[doc(inline)]
pub use self::__buffa::view::ListRecipientsRequestView;
#[doc(inline)]
pub use self::__buffa::view::ListRecipientsRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::ListRecipientsResponseView;
#[doc(inline)]
pub use self::__buffa::view::ListRecipientsResponseOwnedView;
#[doc(inline)]
pub use self::__buffa::view::CreateRecipientRequestView;
#[doc(inline)]
pub use self::__buffa::view::CreateRecipientRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::GetRecipientRequestView;
#[doc(inline)]
pub use self::__buffa::view::GetRecipientRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::UpdateRecipientRequestView;
#[doc(inline)]
pub use self::__buffa::view::UpdateRecipientRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::view::DeleteRecipientRequestView;
#[doc(inline)]
pub use self::__buffa::view::DeleteRecipientRequestOwnedView;
#[doc(inline)]
pub use self::__buffa::register_types;