impl serde::Serialize for DeltaLogMessage {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.entry.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.DeltaLogMessage", len)?;
if let Some(v) = self.entry.as_ref() {
match v {
delta_log_message::Entry::Protocol(v) => {
struct_ser.serialize_field("protocol", v)?;
}
delta_log_message::Entry::Metadata(v) => {
struct_ser.serialize_field("metadata", v)?;
}
}
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for DeltaLogMessage {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"protocol",
"metadata",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Protocol,
Metadata,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"protocol" => Ok(GeneratedField::Protocol),
"metadata" => Ok(GeneratedField::Metadata),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = DeltaLogMessage;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.DeltaLogMessage")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<DeltaLogMessage, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut entry__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Protocol => {
if entry__.is_some() {
return Err(serde::de::Error::duplicate_field("protocol"));
}
entry__ = map_.next_value::<::std::option::Option<_>>()?.map(delta_log_message::Entry::Protocol)
;
}
GeneratedField::Metadata => {
if entry__.is_some() {
return Err(serde::de::Error::duplicate_field("metadata"));
}
entry__ = map_.next_value::<::std::option::Option<_>>()?.map(delta_log_message::Entry::Metadata)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(DeltaLogMessage {
entry: entry__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.DeltaLogMessage", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for DeltaResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.entries.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.DeltaResponse", len)?;
if !self.entries.is_empty() {
struct_ser.serialize_field("entries", &self.entries)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for DeltaResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"entries",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Entries,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"entries" => Ok(GeneratedField::Entries),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = DeltaResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.DeltaResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<DeltaResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut entries__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Entries => {
if entries__.is_some() {
return Err(serde::de::Error::duplicate_field("entries"));
}
entries__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(DeltaResponse {
entries: entries__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.DeltaResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for Format {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.provider.is_empty() {
len += 1;
}
if !self.options.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.Format", len)?;
if !self.provider.is_empty() {
struct_ser.serialize_field("provider", &self.provider)?;
}
if !self.options.is_empty() {
struct_ser.serialize_field("options", &self.options)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for Format {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"provider",
"options",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Provider,
Options,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"provider" => Ok(GeneratedField::Provider),
"options" => Ok(GeneratedField::Options),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = Format;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.Format")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<Format, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut provider__ = None;
let mut options__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Provider => {
if provider__.is_some() {
return Err(serde::de::Error::duplicate_field("provider"));
}
provider__ = Some(map_.next_value()?);
}
GeneratedField::Options => {
if options__.is_some() {
return Err(serde::de::Error::duplicate_field("options"));
}
options__ = Some(
map_.next_value::<std::collections::HashMap<_, _>>()?
);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(Format {
provider: provider__.unwrap_or_default(),
options: options__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.Format", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GenerateTemporarySkillCredentialsRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.name.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GenerateTemporarySkillCredentialsRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GenerateTemporarySkillCredentialsRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"name",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
Name,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"name" => Ok(GeneratedField::Name),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GenerateTemporarySkillCredentialsRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GenerateTemporarySkillCredentialsRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GenerateTemporarySkillCredentialsRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut name__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GenerateTemporarySkillCredentialsRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
name: name__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GenerateTemporarySkillCredentialsRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GenerateTemporaryVolumeCredentialsRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.name.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GenerateTemporaryVolumeCredentialsRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GenerateTemporaryVolumeCredentialsRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"name",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
Name,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"name" => Ok(GeneratedField::Name),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GenerateTemporaryVolumeCredentialsRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GenerateTemporaryVolumeCredentialsRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GenerateTemporaryVolumeCredentialsRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut name__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GenerateTemporaryVolumeCredentialsRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
name: name__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GenerateTemporaryVolumeCredentialsRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetShareRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetShareRequest", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetShareRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetShareRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetShareRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetShareRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetShareRequest {
name: name__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetShareRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetSkillRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.name.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetSkillRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetSkillRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"name",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
Name,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"name" => Ok(GeneratedField::Name),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetSkillRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetSkillRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetSkillRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut name__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetSkillRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
name: name__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetSkillRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetTableMetadataRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetTableMetadataRequest", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetTableMetadataRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"share",
"schema",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Share,
Schema,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetTableMetadataRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetTableMetadataRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetTableMetadataRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut share__ = None;
let mut schema__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetTableMetadataRequest {
name: name__.unwrap_or_default(),
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetTableMetadataRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetTableVersionRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.starting_timestamp.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetTableVersionRequest", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.starting_timestamp.as_ref() {
struct_ser.serialize_field("starting_timestamp", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetTableVersionRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"schema",
"share",
"starting_timestamp",
"startingTimestamp",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Schema,
Share,
StartingTimestamp,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"schema" => Ok(GeneratedField::Schema),
"share" => Ok(GeneratedField::Share),
"startingTimestamp" | "starting_timestamp" => Ok(GeneratedField::StartingTimestamp),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetTableVersionRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetTableVersionRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetTableVersionRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut schema__ = None;
let mut share__ = None;
let mut starting_timestamp__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::StartingTimestamp => {
if starting_timestamp__.is_some() {
return Err(serde::de::Error::duplicate_field("startingTimestamp"));
}
starting_timestamp__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetTableVersionRequest {
name: name__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
share: share__.unwrap_or_default(),
starting_timestamp: starting_timestamp__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetTableVersionRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetTableVersionResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.version != 0 {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetTableVersionResponse", len)?;
if self.version != 0 {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("version", ToString::to_string(&self.version).as_str())?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetTableVersionResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"version",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Version,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"version" => Ok(GeneratedField::Version),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetTableVersionResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetTableVersionResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetTableVersionResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut version__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Version => {
if version__.is_some() {
return Err(serde::de::Error::duplicate_field("version"));
}
version__ =
Some(map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetTableVersionResponse {
version: version__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetTableVersionResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for GetVolumeRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.name.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.GetVolumeRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for GetVolumeRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"name",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
Name,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"name" => Ok(GeneratedField::Name),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GetVolumeRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.GetVolumeRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<GetVolumeRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut name__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(GetVolumeRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
name: name__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.GetVolumeRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for JsonPredicate {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.op.is_empty() {
len += 1;
}
if !self.children.is_empty() {
len += 1;
}
if self.name.is_some() {
len += 1;
}
if self.value.is_some() {
len += 1;
}
if self.value_type.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.JsonPredicate", len)?;
if !self.op.is_empty() {
struct_ser.serialize_field("op", &self.op)?;
}
if !self.children.is_empty() {
struct_ser.serialize_field("children", &self.children)?;
}
if let Some(v) = self.name.as_ref() {
struct_ser.serialize_field("name", v)?;
}
if let Some(v) = self.value.as_ref() {
struct_ser.serialize_field("value", v)?;
}
if let Some(v) = self.value_type.as_ref() {
struct_ser.serialize_field("value_type", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for JsonPredicate {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"op",
"children",
"name",
"value",
"value_type",
"valueType",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Op,
Children,
Name,
Value,
ValueType,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"op" => Ok(GeneratedField::Op),
"children" => Ok(GeneratedField::Children),
"name" => Ok(GeneratedField::Name),
"value" => Ok(GeneratedField::Value),
"valueType" | "value_type" => Ok(GeneratedField::ValueType),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = JsonPredicate;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.JsonPredicate")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<JsonPredicate, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut op__ = None;
let mut children__ = None;
let mut name__ = None;
let mut value__ = None;
let mut value_type__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Op => {
if op__.is_some() {
return Err(serde::de::Error::duplicate_field("op"));
}
op__ = Some(map_.next_value()?);
}
GeneratedField::Children => {
if children__.is_some() {
return Err(serde::de::Error::duplicate_field("children"));
}
children__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = map_.next_value()?;
}
GeneratedField::Value => {
if value__.is_some() {
return Err(serde::de::Error::duplicate_field("value"));
}
value__ = map_.next_value()?;
}
GeneratedField::ValueType => {
if value_type__.is_some() {
return Err(serde::de::Error::duplicate_field("valueType"));
}
value_type__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(JsonPredicate {
op: op__.unwrap_or_default(),
children: children__.unwrap_or_default(),
name: name__,
value: value__,
value_type: value_type__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.JsonPredicate", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllSkillsRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllSkillsRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllSkillsRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllSkillsRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllSkillsRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllSkillsRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllSkillsRequest {
share: share__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllSkillsRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllSkillsResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllSkillsResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllSkillsResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllSkillsResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllSkillsResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllSkillsResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllSkillsResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllSkillsResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllTablesRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllTablesRequest", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllTablesRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllTablesRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllTablesRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllTablesRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllTablesRequest {
name: name__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllTablesRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllTablesResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllTablesResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllTablesResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllTablesResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllTablesResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllTablesResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllTablesResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllTablesResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllVolumesRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllVolumesRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllVolumesRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllVolumesRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllVolumesRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllVolumesRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllVolumesRequest {
share: share__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllVolumesRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListAllVolumesResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListAllVolumesResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListAllVolumesResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListAllVolumesResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListAllVolumesResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListAllVolumesResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListAllVolumesResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListAllVolumesResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSchemasRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSchemasRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSchemasRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSchemasRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSchemasRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSchemasRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSchemasRequest {
share: share__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSchemasRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSchemasResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSchemasResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSchemasResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSchemasResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSchemasResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSchemasResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSchemasResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSchemasResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSharesRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSharesRequest", len)?;
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSharesRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSharesRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSharesRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSharesRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSharesRequest {
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSharesRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSharesResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSharesResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSharesResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSharesResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSharesResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSharesResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSharesResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSharesResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSkillsRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSkillsRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSkillsRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSkillsRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSkillsRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSkillsRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSkillsRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSkillsRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListSkillsResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListSkillsResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListSkillsResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListSkillsResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListSkillsResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListSkillsResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListSkillsResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListSkillsResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListTablesRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListTablesRequest", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListTablesRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"share",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Share,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"share" => Ok(GeneratedField::Share),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListTablesRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListTablesRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListTablesRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut share__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListTablesRequest {
name: name__.unwrap_or_default(),
share: share__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListTablesRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListTablesResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListTablesResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListTablesResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListTablesResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListTablesResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListTablesResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListTablesResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListTablesResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListVolumesRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if self.max_results.is_some() {
len += 1;
}
if self.page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListVolumesRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if let Some(v) = self.max_results.as_ref() {
struct_ser.serialize_field("max_results", v)?;
}
if let Some(v) = self.page_token.as_ref() {
struct_ser.serialize_field("page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListVolumesRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"max_results",
"maxResults",
"page_token",
"pageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
MaxResults,
PageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"maxResults" | "max_results" => Ok(GeneratedField::MaxResults),
"pageToken" | "page_token" => Ok(GeneratedField::PageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListVolumesRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListVolumesRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListVolumesRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut max_results__ = None;
let mut page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::MaxResults => {
if max_results__.is_some() {
return Err(serde::de::Error::duplicate_field("maxResults"));
}
max_results__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::PageToken => {
if page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("pageToken"));
}
page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListVolumesRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
max_results: max_results__,
page_token: page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListVolumesRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ListVolumesResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.items.is_empty() {
len += 1;
}
if self.next_page_token.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ListVolumesResponse", len)?;
if !self.items.is_empty() {
struct_ser.serialize_field("items", &self.items)?;
}
if let Some(v) = self.next_page_token.as_ref() {
struct_ser.serialize_field("next_page_token", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ListVolumesResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"items",
"next_page_token",
"nextPageToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Items,
NextPageToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"items" => Ok(GeneratedField::Items),
"nextPageToken" | "next_page_token" => Ok(GeneratedField::NextPageToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ListVolumesResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ListVolumesResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ListVolumesResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut items__ = None;
let mut next_page_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Items => {
if items__.is_some() {
return Err(serde::de::Error::duplicate_field("items"));
}
items__ = Some(map_.next_value()?);
}
GeneratedField::NextPageToken => {
if next_page_token__.is_some() {
return Err(serde::de::Error::duplicate_field("nextPageToken"));
}
next_page_token__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ListVolumesResponse {
items: items__.unwrap_or_default(),
next_page_token: next_page_token__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ListVolumesResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for Metadata {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.id.is_empty() {
len += 1;
}
if self.name.is_some() {
len += 1;
}
if self.description.is_some() {
len += 1;
}
if self.format.is_some() {
len += 1;
}
if !self.schema_string.is_empty() {
len += 1;
}
if !self.partition_columns.is_empty() {
len += 1;
}
if self.created_time.is_some() {
len += 1;
}
if !self.options.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.Metadata", len)?;
if !self.id.is_empty() {
struct_ser.serialize_field("id", &self.id)?;
}
if let Some(v) = self.name.as_ref() {
struct_ser.serialize_field("name", v)?;
}
if let Some(v) = self.description.as_ref() {
struct_ser.serialize_field("description", v)?;
}
if let Some(v) = self.format.as_ref() {
struct_ser.serialize_field("format", v)?;
}
if !self.schema_string.is_empty() {
struct_ser.serialize_field("schema_string", &self.schema_string)?;
}
if !self.partition_columns.is_empty() {
struct_ser.serialize_field("partition_columns", &self.partition_columns)?;
}
if let Some(v) = self.created_time.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("created_time", ToString::to_string(&v).as_str())?;
}
if !self.options.is_empty() {
struct_ser.serialize_field("options", &self.options)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for Metadata {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"id",
"name",
"description",
"format",
"schema_string",
"schemaString",
"partition_columns",
"partitionColumns",
"created_time",
"createdTime",
"options",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Id,
Name,
Description,
Format,
SchemaString,
PartitionColumns,
CreatedTime,
Options,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"id" => Ok(GeneratedField::Id),
"name" => Ok(GeneratedField::Name),
"description" => Ok(GeneratedField::Description),
"format" => Ok(GeneratedField::Format),
"schemaString" | "schema_string" => Ok(GeneratedField::SchemaString),
"partitionColumns" | "partition_columns" => Ok(GeneratedField::PartitionColumns),
"createdTime" | "created_time" => Ok(GeneratedField::CreatedTime),
"options" => Ok(GeneratedField::Options),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = Metadata;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.Metadata")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<Metadata, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut id__ = None;
let mut name__ = None;
let mut description__ = None;
let mut format__ = None;
let mut schema_string__ = None;
let mut partition_columns__ = None;
let mut created_time__ = None;
let mut options__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = map_.next_value()?;
}
GeneratedField::Description => {
if description__.is_some() {
return Err(serde::de::Error::duplicate_field("description"));
}
description__ = map_.next_value()?;
}
GeneratedField::Format => {
if format__.is_some() {
return Err(serde::de::Error::duplicate_field("format"));
}
format__ = map_.next_value()?;
}
GeneratedField::SchemaString => {
if schema_string__.is_some() {
return Err(serde::de::Error::duplicate_field("schemaString"));
}
schema_string__ = Some(map_.next_value()?);
}
GeneratedField::PartitionColumns => {
if partition_columns__.is_some() {
return Err(serde::de::Error::duplicate_field("partitionColumns"));
}
partition_columns__ = Some(map_.next_value()?);
}
GeneratedField::CreatedTime => {
if created_time__.is_some() {
return Err(serde::de::Error::duplicate_field("createdTime"));
}
created_time__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::Options => {
if options__.is_some() {
return Err(serde::de::Error::duplicate_field("options"));
}
options__ = Some(
map_.next_value::<std::collections::HashMap<_, _>>()?
);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(Metadata {
id: id__.unwrap_or_default(),
name: name__,
description: description__,
format: format__,
schema_string: schema_string__.unwrap_or_default(),
partition_columns: partition_columns__.unwrap_or_default(),
created_time: created_time__,
options: options__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.Metadata", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for MetadataDelta {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.delta_metadata.is_some() {
len += 1;
}
if self.version.is_some() {
len += 1;
}
if self.size.is_some() {
len += 1;
}
if self.num_files.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.MetadataDelta", len)?;
if let Some(v) = self.delta_metadata.as_ref() {
struct_ser.serialize_field("delta_metadata", v)?;
}
if let Some(v) = self.version.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("version", ToString::to_string(&v).as_str())?;
}
if let Some(v) = self.size.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("size", ToString::to_string(&v).as_str())?;
}
if let Some(v) = self.num_files.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("num_files", ToString::to_string(&v).as_str())?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for MetadataDelta {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"delta_metadata",
"deltaMetadata",
"version",
"size",
"num_files",
"numFiles",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
DeltaMetadata,
Version,
Size,
NumFiles,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"deltaMetadata" | "delta_metadata" => Ok(GeneratedField::DeltaMetadata),
"version" => Ok(GeneratedField::Version),
"size" => Ok(GeneratedField::Size),
"numFiles" | "num_files" => Ok(GeneratedField::NumFiles),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = MetadataDelta;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.MetadataDelta")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<MetadataDelta, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut delta_metadata__ = None;
let mut version__ = None;
let mut size__ = None;
let mut num_files__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::DeltaMetadata => {
if delta_metadata__.is_some() {
return Err(serde::de::Error::duplicate_field("deltaMetadata"));
}
delta_metadata__ = map_.next_value()?;
}
GeneratedField::Version => {
if version__.is_some() {
return Err(serde::de::Error::duplicate_field("version"));
}
version__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::Size => {
if size__.is_some() {
return Err(serde::de::Error::duplicate_field("size"));
}
size__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::NumFiles => {
if num_files__.is_some() {
return Err(serde::de::Error::duplicate_field("numFiles"));
}
num_files__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(MetadataDelta {
delta_metadata: delta_metadata__,
version: version__,
size: size__,
num_files: num_files__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.MetadataDelta", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for MetadataParquet {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.id.is_empty() {
len += 1;
}
if self.name.is_some() {
len += 1;
}
if self.description.is_some() {
len += 1;
}
if self.format.is_some() {
len += 1;
}
if !self.schema_string.is_empty() {
len += 1;
}
if !self.partition_columns.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.MetadataParquet", len)?;
if !self.id.is_empty() {
struct_ser.serialize_field("id", &self.id)?;
}
if let Some(v) = self.name.as_ref() {
struct_ser.serialize_field("name", v)?;
}
if let Some(v) = self.description.as_ref() {
struct_ser.serialize_field("description", v)?;
}
if let Some(v) = self.format.as_ref() {
struct_ser.serialize_field("format", v)?;
}
if !self.schema_string.is_empty() {
struct_ser.serialize_field("schema_string", &self.schema_string)?;
}
if !self.partition_columns.is_empty() {
struct_ser.serialize_field("partition_columns", &self.partition_columns)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for MetadataParquet {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"id",
"name",
"description",
"format",
"schema_string",
"schemaString",
"partition_columns",
"partitionColumns",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Id,
Name,
Description,
Format,
SchemaString,
PartitionColumns,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"id" => Ok(GeneratedField::Id),
"name" => Ok(GeneratedField::Name),
"description" => Ok(GeneratedField::Description),
"format" => Ok(GeneratedField::Format),
"schemaString" | "schema_string" => Ok(GeneratedField::SchemaString),
"partitionColumns" | "partition_columns" => Ok(GeneratedField::PartitionColumns),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = MetadataParquet;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.MetadataParquet")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<MetadataParquet, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut id__ = None;
let mut name__ = None;
let mut description__ = None;
let mut format__ = None;
let mut schema_string__ = None;
let mut partition_columns__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = map_.next_value()?;
}
GeneratedField::Description => {
if description__.is_some() {
return Err(serde::de::Error::duplicate_field("description"));
}
description__ = map_.next_value()?;
}
GeneratedField::Format => {
if format__.is_some() {
return Err(serde::de::Error::duplicate_field("format"));
}
format__ = map_.next_value()?;
}
GeneratedField::SchemaString => {
if schema_string__.is_some() {
return Err(serde::de::Error::duplicate_field("schemaString"));
}
schema_string__ = Some(map_.next_value()?);
}
GeneratedField::PartitionColumns => {
if partition_columns__.is_some() {
return Err(serde::de::Error::duplicate_field("partitionColumns"));
}
partition_columns__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(MetadataParquet {
id: id__.unwrap_or_default(),
name: name__,
description: description__,
format: format__,
schema_string: schema_string__.unwrap_or_default(),
partition_columns: partition_columns__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.MetadataParquet", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ParquetLogMessage {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.entry.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ParquetLogMessage", len)?;
if let Some(v) = self.entry.as_ref() {
match v {
parquet_log_message::Entry::Protocol(v) => {
struct_ser.serialize_field("protocol", v)?;
}
parquet_log_message::Entry::Metadata(v) => {
struct_ser.serialize_field("metadata", v)?;
}
}
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ParquetLogMessage {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"protocol",
"metadata",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Protocol,
Metadata,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"protocol" => Ok(GeneratedField::Protocol),
"metadata" => Ok(GeneratedField::Metadata),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ParquetLogMessage;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ParquetLogMessage")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ParquetLogMessage, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut entry__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Protocol => {
if entry__.is_some() {
return Err(serde::de::Error::duplicate_field("protocol"));
}
entry__ = map_.next_value::<::std::option::Option<_>>()?.map(parquet_log_message::Entry::Protocol)
;
}
GeneratedField::Metadata => {
if entry__.is_some() {
return Err(serde::de::Error::duplicate_field("metadata"));
}
entry__ = map_.next_value::<::std::option::Option<_>>()?.map(parquet_log_message::Entry::Metadata)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ParquetLogMessage {
entry: entry__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ParquetLogMessage", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ParquetResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.entries.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ParquetResponse", len)?;
if !self.entries.is_empty() {
struct_ser.serialize_field("entries", &self.entries)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ParquetResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"entries",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Entries,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"entries" => Ok(GeneratedField::Entries),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ParquetResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ParquetResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ParquetResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut entries__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Entries => {
if entries__.is_some() {
return Err(serde::de::Error::duplicate_field("entries"));
}
entries__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ParquetResponse {
entries: entries__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ParquetResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ProtocolDelta {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.min_reader_version != 0 {
len += 1;
}
if self.min_writer_version != 0 {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ProtocolDelta", len)?;
if self.min_reader_version != 0 {
struct_ser.serialize_field("min_reader_version", &self.min_reader_version)?;
}
if self.min_writer_version != 0 {
struct_ser.serialize_field("min_writer_version", &self.min_writer_version)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ProtocolDelta {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"min_reader_version",
"minReaderVersion",
"min_writer_version",
"minWriterVersion",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
MinReaderVersion,
MinWriterVersion,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"minReaderVersion" | "min_reader_version" => Ok(GeneratedField::MinReaderVersion),
"minWriterVersion" | "min_writer_version" => Ok(GeneratedField::MinWriterVersion),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ProtocolDelta;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ProtocolDelta")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ProtocolDelta, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut min_reader_version__ = None;
let mut min_writer_version__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::MinReaderVersion => {
if min_reader_version__.is_some() {
return Err(serde::de::Error::duplicate_field("minReaderVersion"));
}
min_reader_version__ =
Some(map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0)
;
}
GeneratedField::MinWriterVersion => {
if min_writer_version__.is_some() {
return Err(serde::de::Error::duplicate_field("minWriterVersion"));
}
min_writer_version__ =
Some(map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ProtocolDelta {
min_reader_version: min_reader_version__.unwrap_or_default(),
min_writer_version: min_writer_version__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ProtocolDelta", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for ProtocolParquet {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.min_reader_version != 0 {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.ProtocolParquet", len)?;
if self.min_reader_version != 0 {
struct_ser.serialize_field("min_reader_version", &self.min_reader_version)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for ProtocolParquet {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"min_reader_version",
"minReaderVersion",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
MinReaderVersion,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"minReaderVersion" | "min_reader_version" => Ok(GeneratedField::MinReaderVersion),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = ProtocolParquet;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.ProtocolParquet")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<ProtocolParquet, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut min_reader_version__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::MinReaderVersion => {
if min_reader_version__.is_some() {
return Err(serde::de::Error::duplicate_field("minReaderVersion"));
}
min_reader_version__ =
Some(map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(ProtocolParquet {
min_reader_version: min_reader_version__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.ProtocolParquet", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for QueryResponse {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.response.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.QueryResponse", len)?;
if let Some(v) = self.response.as_ref() {
match v {
query_response::Response::Parquet(v) => {
struct_ser.serialize_field("parquet", v)?;
}
query_response::Response::Delta(v) => {
struct_ser.serialize_field("delta", v)?;
}
}
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for QueryResponse {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"parquet",
"delta",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Parquet,
Delta,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"parquet" => Ok(GeneratedField::Parquet),
"delta" => Ok(GeneratedField::Delta),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = QueryResponse;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.QueryResponse")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<QueryResponse, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut response__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Parquet => {
if response__.is_some() {
return Err(serde::de::Error::duplicate_field("parquet"));
}
response__ = map_.next_value::<::std::option::Option<_>>()?.map(query_response::Response::Parquet)
;
}
GeneratedField::Delta => {
if response__.is_some() {
return Err(serde::de::Error::duplicate_field("delta"));
}
response__ = map_.next_value::<::std::option::Option<_>>()?.map(query_response::Response::Delta)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(QueryResponse {
response: response__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.QueryResponse", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for QueryTableRequest {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.share.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.name.is_empty() {
len += 1;
}
if self.starting_timestamp.is_some() {
len += 1;
}
if !self.predicate_hints.is_empty() {
len += 1;
}
if self.json_predicate_hints.is_some() {
len += 1;
}
if self.limit_hint.is_some() {
len += 1;
}
if self.version.is_some() {
len += 1;
}
if self.timestamp.is_some() {
len += 1;
}
if self.starting_version.is_some() {
len += 1;
}
if self.ending_version.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.QueryTableRequest", len)?;
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if let Some(v) = self.starting_timestamp.as_ref() {
struct_ser.serialize_field("starting_timestamp", v)?;
}
if !self.predicate_hints.is_empty() {
struct_ser.serialize_field("predicate_hints", &self.predicate_hints)?;
}
if let Some(v) = self.json_predicate_hints.as_ref() {
struct_ser.serialize_field("json_predicate_hints", v)?;
}
if let Some(v) = self.limit_hint.as_ref() {
struct_ser.serialize_field("limit_hint", v)?;
}
if let Some(v) = self.version.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("version", ToString::to_string(&v).as_str())?;
}
if let Some(v) = self.timestamp.as_ref() {
struct_ser.serialize_field("timestamp", v)?;
}
if let Some(v) = self.starting_version.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("starting_version", ToString::to_string(&v).as_str())?;
}
if let Some(v) = self.ending_version.as_ref() {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("ending_version", ToString::to_string(&v).as_str())?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for QueryTableRequest {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"share",
"schema",
"name",
"starting_timestamp",
"startingTimestamp",
"predicate_hints",
"predicateHints",
"json_predicate_hints",
"jsonPredicateHints",
"limit_hint",
"limitHint",
"version",
"timestamp",
"starting_version",
"startingVersion",
"ending_version",
"endingVersion",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Share,
Schema,
Name,
StartingTimestamp,
PredicateHints,
JsonPredicateHints,
LimitHint,
Version,
Timestamp,
StartingVersion,
EndingVersion,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"share" => Ok(GeneratedField::Share),
"schema" => Ok(GeneratedField::Schema),
"name" => Ok(GeneratedField::Name),
"startingTimestamp" | "starting_timestamp" => Ok(GeneratedField::StartingTimestamp),
"predicateHints" | "predicate_hints" => Ok(GeneratedField::PredicateHints),
"jsonPredicateHints" | "json_predicate_hints" => Ok(GeneratedField::JsonPredicateHints),
"limitHint" | "limit_hint" => Ok(GeneratedField::LimitHint),
"version" => Ok(GeneratedField::Version),
"timestamp" => Ok(GeneratedField::Timestamp),
"startingVersion" | "starting_version" => Ok(GeneratedField::StartingVersion),
"endingVersion" | "ending_version" => Ok(GeneratedField::EndingVersion),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = QueryTableRequest;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.QueryTableRequest")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<QueryTableRequest, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut share__ = None;
let mut schema__ = None;
let mut name__ = None;
let mut starting_timestamp__ = None;
let mut predicate_hints__ = None;
let mut json_predicate_hints__ = None;
let mut limit_hint__ = None;
let mut version__ = None;
let mut timestamp__ = None;
let mut starting_version__ = None;
let mut ending_version__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::StartingTimestamp => {
if starting_timestamp__.is_some() {
return Err(serde::de::Error::duplicate_field("startingTimestamp"));
}
starting_timestamp__ = map_.next_value()?;
}
GeneratedField::PredicateHints => {
if predicate_hints__.is_some() {
return Err(serde::de::Error::duplicate_field("predicateHints"));
}
predicate_hints__ = Some(map_.next_value()?);
}
GeneratedField::JsonPredicateHints => {
if json_predicate_hints__.is_some() {
return Err(serde::de::Error::duplicate_field("jsonPredicateHints"));
}
json_predicate_hints__ = map_.next_value()?;
}
GeneratedField::LimitHint => {
if limit_hint__.is_some() {
return Err(serde::de::Error::duplicate_field("limitHint"));
}
limit_hint__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::Version => {
if version__.is_some() {
return Err(serde::de::Error::duplicate_field("version"));
}
version__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::Timestamp => {
if timestamp__.is_some() {
return Err(serde::de::Error::duplicate_field("timestamp"));
}
timestamp__ = map_.next_value()?;
}
GeneratedField::StartingVersion => {
if starting_version__.is_some() {
return Err(serde::de::Error::duplicate_field("startingVersion"));
}
starting_version__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::EndingVersion => {
if ending_version__.is_some() {
return Err(serde::de::Error::duplicate_field("endingVersion"));
}
ending_version__ =
map_.next_value::<::std::option::Option<::pbjson::private::NumberDeserialize<_>>>()?.map(|x| x.0)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(QueryTableRequest {
share: share__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
name: name__.unwrap_or_default(),
starting_timestamp: starting_timestamp__,
predicate_hints: predicate_hints__.unwrap_or_default(),
json_predicate_hints: json_predicate_hints__,
limit_hint: limit_hint__,
version: version__,
timestamp: timestamp__,
starting_version: starting_version__,
ending_version: ending_version__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.QueryTableRequest", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for Schema {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.id.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.Schema", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.id.as_ref() {
struct_ser.serialize_field("id", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for Schema {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"share",
"id",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Share,
Id,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"share" => Ok(GeneratedField::Share),
"id" => Ok(GeneratedField::Id),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = Schema;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.Schema")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<Schema, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut share__ = None;
let mut id__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(Schema {
name: name__.unwrap_or_default(),
share: share__.unwrap_or_default(),
id: id__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.Schema", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for Share {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if self.id.is_some() {
len += 1;
}
if self.display_name.is_some() {
len += 1;
}
if self.comment.is_some() {
len += 1;
}
if !self.properties.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.Share", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if let Some(v) = self.id.as_ref() {
struct_ser.serialize_field("id", v)?;
}
if let Some(v) = self.display_name.as_ref() {
struct_ser.serialize_field("display_name", v)?;
}
if let Some(v) = self.comment.as_ref() {
struct_ser.serialize_field("comment", v)?;
}
if !self.properties.is_empty() {
struct_ser.serialize_field("properties", &self.properties)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for Share {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"id",
"display_name",
"displayName",
"comment",
"properties",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Id,
DisplayName,
Comment,
Properties,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"id" => Ok(GeneratedField::Id),
"displayName" | "display_name" => Ok(GeneratedField::DisplayName),
"comment" => Ok(GeneratedField::Comment),
"properties" => Ok(GeneratedField::Properties),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = Share;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.Share")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<Share, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut id__ = None;
let mut display_name__ = None;
let mut comment__ = None;
let mut properties__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = map_.next_value()?;
}
GeneratedField::DisplayName => {
if display_name__.is_some() {
return Err(serde::de::Error::duplicate_field("displayName"));
}
display_name__ = map_.next_value()?;
}
GeneratedField::Comment => {
if comment__.is_some() {
return Err(serde::de::Error::duplicate_field("comment"));
}
comment__ = map_.next_value()?;
}
GeneratedField::Properties => {
if properties__.is_some() {
return Err(serde::de::Error::duplicate_field("properties"));
}
properties__ = Some(
map_.next_value::<std::collections::HashMap<_, _>>()?
);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(Share {
name: name__.unwrap_or_default(),
id: id__,
display_name: display_name__,
comment: comment__,
properties: properties__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.Share", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingAwsCredentials {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.access_key_id.is_empty() {
len += 1;
}
if !self.secret_access_key.is_empty() {
len += 1;
}
if !self.session_token.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingAwsCredentials", len)?;
if !self.access_key_id.is_empty() {
struct_ser.serialize_field("access_key_id", &self.access_key_id)?;
}
if !self.secret_access_key.is_empty() {
struct_ser.serialize_field("secret_access_key", &self.secret_access_key)?;
}
if !self.session_token.is_empty() {
struct_ser.serialize_field("session_token", &self.session_token)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingAwsCredentials {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"access_key_id",
"accessKeyId",
"secret_access_key",
"secretAccessKey",
"session_token",
"sessionToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
AccessKeyId,
SecretAccessKey,
SessionToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"accessKeyId" | "access_key_id" => Ok(GeneratedField::AccessKeyId),
"secretAccessKey" | "secret_access_key" => Ok(GeneratedField::SecretAccessKey),
"sessionToken" | "session_token" => Ok(GeneratedField::SessionToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingAwsCredentials;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingAwsCredentials")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingAwsCredentials, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut access_key_id__ = None;
let mut secret_access_key__ = None;
let mut session_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::AccessKeyId => {
if access_key_id__.is_some() {
return Err(serde::de::Error::duplicate_field("accessKeyId"));
}
access_key_id__ = Some(map_.next_value()?);
}
GeneratedField::SecretAccessKey => {
if secret_access_key__.is_some() {
return Err(serde::de::Error::duplicate_field("secretAccessKey"));
}
secret_access_key__ = Some(map_.next_value()?);
}
GeneratedField::SessionToken => {
if session_token__.is_some() {
return Err(serde::de::Error::duplicate_field("sessionToken"));
}
session_token__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingAwsCredentials {
access_key_id: access_key_id__.unwrap_or_default(),
secret_access_key: secret_access_key__.unwrap_or_default(),
session_token: session_token__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingAwsCredentials", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingAzureUserDelegationSas {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.sas_token.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingAzureUserDelegationSas", len)?;
if !self.sas_token.is_empty() {
struct_ser.serialize_field("sas_token", &self.sas_token)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingAzureUserDelegationSas {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"sas_token",
"sasToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
SasToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"sasToken" | "sas_token" => Ok(GeneratedField::SasToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingAzureUserDelegationSas;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingAzureUserDelegationSas")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingAzureUserDelegationSas, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut sas_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::SasToken => {
if sas_token__.is_some() {
return Err(serde::de::Error::duplicate_field("sasToken"));
}
sas_token__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingAzureUserDelegationSas {
sas_token: sas_token__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingAzureUserDelegationSas", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingGcpOauthToken {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.oauth_token.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingGcpOauthToken", len)?;
if !self.oauth_token.is_empty() {
struct_ser.serialize_field("oauth_token", &self.oauth_token)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingGcpOauthToken {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"oauth_token",
"oauthToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
OauthToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"oauthToken" | "oauth_token" => Ok(GeneratedField::OauthToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingGcpOauthToken;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingGcpOauthToken")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingGcpOauthToken, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut oauth_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::OauthToken => {
if oauth_token__.is_some() {
return Err(serde::de::Error::duplicate_field("oauthToken"));
}
oauth_token__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingGcpOauthToken {
oauth_token: oauth_token__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingGcpOauthToken", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingR2Credentials {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.access_key_id.is_empty() {
len += 1;
}
if !self.secret_access_key.is_empty() {
len += 1;
}
if !self.session_token.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingR2Credentials", len)?;
if !self.access_key_id.is_empty() {
struct_ser.serialize_field("access_key_id", &self.access_key_id)?;
}
if !self.secret_access_key.is_empty() {
struct_ser.serialize_field("secret_access_key", &self.secret_access_key)?;
}
if !self.session_token.is_empty() {
struct_ser.serialize_field("session_token", &self.session_token)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingR2Credentials {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"access_key_id",
"accessKeyId",
"secret_access_key",
"secretAccessKey",
"session_token",
"sessionToken",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
AccessKeyId,
SecretAccessKey,
SessionToken,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"accessKeyId" | "access_key_id" => Ok(GeneratedField::AccessKeyId),
"secretAccessKey" | "secret_access_key" => Ok(GeneratedField::SecretAccessKey),
"sessionToken" | "session_token" => Ok(GeneratedField::SessionToken),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingR2Credentials;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingR2Credentials")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingR2Credentials, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut access_key_id__ = None;
let mut secret_access_key__ = None;
let mut session_token__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::AccessKeyId => {
if access_key_id__.is_some() {
return Err(serde::de::Error::duplicate_field("accessKeyId"));
}
access_key_id__ = Some(map_.next_value()?);
}
GeneratedField::SecretAccessKey => {
if secret_access_key__.is_some() {
return Err(serde::de::Error::duplicate_field("secretAccessKey"));
}
secret_access_key__ = Some(map_.next_value()?);
}
GeneratedField::SessionToken => {
if session_token__.is_some() {
return Err(serde::de::Error::duplicate_field("sessionToken"));
}
session_token__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingR2Credentials {
access_key_id: access_key_id__.unwrap_or_default(),
secret_access_key: secret_access_key__.unwrap_or_default(),
session_token: session_token__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingR2Credentials", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingSkill {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.id.is_some() {
len += 1;
}
if self.share_id.is_some() {
len += 1;
}
if self.storage_location.is_some() {
len += 1;
}
if self.description.is_some() {
len += 1;
}
if self.license.is_some() {
len += 1;
}
if !self.allowed_tools.is_empty() {
len += 1;
}
if !self.metadata.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingSkill", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.id.as_ref() {
struct_ser.serialize_field("id", v)?;
}
if let Some(v) = self.share_id.as_ref() {
struct_ser.serialize_field("share_id", v)?;
}
if let Some(v) = self.storage_location.as_ref() {
struct_ser.serialize_field("storage_location", v)?;
}
if let Some(v) = self.description.as_ref() {
struct_ser.serialize_field("description", v)?;
}
if let Some(v) = self.license.as_ref() {
struct_ser.serialize_field("license", v)?;
}
if !self.allowed_tools.is_empty() {
struct_ser.serialize_field("allowed_tools", &self.allowed_tools)?;
}
if !self.metadata.is_empty() {
struct_ser.serialize_field("metadata", &self.metadata)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingSkill {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"schema",
"share",
"id",
"share_id",
"shareId",
"storage_location",
"storageLocation",
"description",
"license",
"allowed_tools",
"allowedTools",
"metadata",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Schema,
Share,
Id,
ShareId,
StorageLocation,
Description,
License,
AllowedTools,
Metadata,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"schema" => Ok(GeneratedField::Schema),
"share" => Ok(GeneratedField::Share),
"id" => Ok(GeneratedField::Id),
"shareId" | "share_id" => Ok(GeneratedField::ShareId),
"storageLocation" | "storage_location" => Ok(GeneratedField::StorageLocation),
"description" => Ok(GeneratedField::Description),
"license" => Ok(GeneratedField::License),
"allowedTools" | "allowed_tools" => Ok(GeneratedField::AllowedTools),
"metadata" => Ok(GeneratedField::Metadata),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingSkill;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingSkill")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingSkill, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut schema__ = None;
let mut share__ = None;
let mut id__ = None;
let mut share_id__ = None;
let mut storage_location__ = None;
let mut description__ = None;
let mut license__ = None;
let mut allowed_tools__ = None;
let mut metadata__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = map_.next_value()?;
}
GeneratedField::ShareId => {
if share_id__.is_some() {
return Err(serde::de::Error::duplicate_field("shareId"));
}
share_id__ = map_.next_value()?;
}
GeneratedField::StorageLocation => {
if storage_location__.is_some() {
return Err(serde::de::Error::duplicate_field("storageLocation"));
}
storage_location__ = map_.next_value()?;
}
GeneratedField::Description => {
if description__.is_some() {
return Err(serde::de::Error::duplicate_field("description"));
}
description__ = map_.next_value()?;
}
GeneratedField::License => {
if license__.is_some() {
return Err(serde::de::Error::duplicate_field("license"));
}
license__ = map_.next_value()?;
}
GeneratedField::AllowedTools => {
if allowed_tools__.is_some() {
return Err(serde::de::Error::duplicate_field("allowedTools"));
}
allowed_tools__ = Some(map_.next_value()?);
}
GeneratedField::Metadata => {
if metadata__.is_some() {
return Err(serde::de::Error::duplicate_field("metadata"));
}
metadata__ = Some(
map_.next_value::<std::collections::HashMap<_, _>>()?
);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingSkill {
name: name__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
share: share__.unwrap_or_default(),
id: id__,
share_id: share_id__,
storage_location: storage_location__,
description: description__,
license: license__,
allowed_tools: allowed_tools__.unwrap_or_default(),
metadata: metadata__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingSkill", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingTemporaryCredentials {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if self.expiration_time != 0 {
len += 1;
}
if self.url.is_some() {
len += 1;
}
if self.credentials.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingTemporaryCredentials", len)?;
if self.expiration_time != 0 {
#[allow(clippy::needless_borrow)]
#[allow(clippy::needless_borrows_for_generic_args)]
struct_ser.serialize_field("expiration_time", ToString::to_string(&self.expiration_time).as_str())?;
}
if let Some(v) = self.url.as_ref() {
struct_ser.serialize_field("url", v)?;
}
if let Some(v) = self.credentials.as_ref() {
match v {
sharing_temporary_credentials::Credentials::AwsTempCredentials(v) => {
struct_ser.serialize_field("aws_temp_credentials", v)?;
}
sharing_temporary_credentials::Credentials::AzureUserDelegationSas(v) => {
struct_ser.serialize_field("azure_user_delegation_sas", v)?;
}
sharing_temporary_credentials::Credentials::GcpOauthToken(v) => {
struct_ser.serialize_field("gcp_oauth_token", v)?;
}
sharing_temporary_credentials::Credentials::R2Credentials(v) => {
struct_ser.serialize_field("r2_credentials", v)?;
}
}
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingTemporaryCredentials {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"expiration_time",
"expirationTime",
"url",
"aws_temp_credentials",
"awsTempCredentials",
"azure_user_delegation_sas",
"azureUserDelegationSas",
"gcp_oauth_token",
"gcpOauthToken",
"r2_credentials",
"r2Credentials",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
ExpirationTime,
Url,
AwsTempCredentials,
AzureUserDelegationSas,
GcpOauthToken,
R2Credentials,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"expirationTime" | "expiration_time" => Ok(GeneratedField::ExpirationTime),
"url" => Ok(GeneratedField::Url),
"awsTempCredentials" | "aws_temp_credentials" => Ok(GeneratedField::AwsTempCredentials),
"azureUserDelegationSas" | "azure_user_delegation_sas" => Ok(GeneratedField::AzureUserDelegationSas),
"gcpOauthToken" | "gcp_oauth_token" => Ok(GeneratedField::GcpOauthToken),
"r2Credentials" | "r2_credentials" => Ok(GeneratedField::R2Credentials),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingTemporaryCredentials;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingTemporaryCredentials")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingTemporaryCredentials, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut expiration_time__ = None;
let mut url__ = None;
let mut credentials__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::ExpirationTime => {
if expiration_time__.is_some() {
return Err(serde::de::Error::duplicate_field("expirationTime"));
}
expiration_time__ =
Some(map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?.0)
;
}
GeneratedField::Url => {
if url__.is_some() {
return Err(serde::de::Error::duplicate_field("url"));
}
url__ = map_.next_value()?;
}
GeneratedField::AwsTempCredentials => {
if credentials__.is_some() {
return Err(serde::de::Error::duplicate_field("awsTempCredentials"));
}
credentials__ = map_.next_value::<::std::option::Option<_>>()?.map(sharing_temporary_credentials::Credentials::AwsTempCredentials)
;
}
GeneratedField::AzureUserDelegationSas => {
if credentials__.is_some() {
return Err(serde::de::Error::duplicate_field("azureUserDelegationSas"));
}
credentials__ = map_.next_value::<::std::option::Option<_>>()?.map(sharing_temporary_credentials::Credentials::AzureUserDelegationSas)
;
}
GeneratedField::GcpOauthToken => {
if credentials__.is_some() {
return Err(serde::de::Error::duplicate_field("gcpOauthToken"));
}
credentials__ = map_.next_value::<::std::option::Option<_>>()?.map(sharing_temporary_credentials::Credentials::GcpOauthToken)
;
}
GeneratedField::R2Credentials => {
if credentials__.is_some() {
return Err(serde::de::Error::duplicate_field("r2Credentials"));
}
credentials__ = map_.next_value::<::std::option::Option<_>>()?.map(sharing_temporary_credentials::Credentials::R2Credentials)
;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingTemporaryCredentials {
expiration_time: expiration_time__.unwrap_or_default(),
url: url__,
credentials: credentials__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingTemporaryCredentials", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for SharingVolume {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.id.is_some() {
len += 1;
}
if self.share_id.is_some() {
len += 1;
}
if self.storage_location.is_some() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.SharingVolume", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.id.as_ref() {
struct_ser.serialize_field("id", v)?;
}
if let Some(v) = self.share_id.as_ref() {
struct_ser.serialize_field("share_id", v)?;
}
if let Some(v) = self.storage_location.as_ref() {
struct_ser.serialize_field("storage_location", v)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for SharingVolume {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"schema",
"share",
"id",
"share_id",
"shareId",
"storage_location",
"storageLocation",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Schema,
Share,
Id,
ShareId,
StorageLocation,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"schema" => Ok(GeneratedField::Schema),
"share" => Ok(GeneratedField::Share),
"id" => Ok(GeneratedField::Id),
"shareId" | "share_id" => Ok(GeneratedField::ShareId),
"storageLocation" | "storage_location" => Ok(GeneratedField::StorageLocation),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = SharingVolume;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.SharingVolume")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<SharingVolume, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut schema__ = None;
let mut share__ = None;
let mut id__ = None;
let mut share_id__ = None;
let mut storage_location__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = map_.next_value()?;
}
GeneratedField::ShareId => {
if share_id__.is_some() {
return Err(serde::de::Error::duplicate_field("shareId"));
}
share_id__ = map_.next_value()?;
}
GeneratedField::StorageLocation => {
if storage_location__.is_some() {
return Err(serde::de::Error::duplicate_field("storageLocation"));
}
storage_location__ = map_.next_value()?;
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(SharingVolume {
name: name__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
share: share__.unwrap_or_default(),
id: id__,
share_id: share_id__,
storage_location: storage_location__,
})
}
}
deserializer.deserialize_struct("open_sharing.v1.SharingVolume", FIELDS, GeneratedVisitor)
}
}
impl serde::Serialize for Table {
#[allow(deprecated)]
fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
use serde::ser::SerializeStruct;
let mut len = 0;
if !self.name.is_empty() {
len += 1;
}
if !self.schema.is_empty() {
len += 1;
}
if !self.share.is_empty() {
len += 1;
}
if self.id.is_some() {
len += 1;
}
if self.share_id.is_some() {
len += 1;
}
if self.location.is_some() {
len += 1;
}
if !self.auxiliary_locations.is_empty() {
len += 1;
}
if !self.access_modes.is_empty() {
len += 1;
}
let mut struct_ser = serializer.serialize_struct("open_sharing.v1.Table", len)?;
if !self.name.is_empty() {
struct_ser.serialize_field("name", &self.name)?;
}
if !self.schema.is_empty() {
struct_ser.serialize_field("schema", &self.schema)?;
}
if !self.share.is_empty() {
struct_ser.serialize_field("share", &self.share)?;
}
if let Some(v) = self.id.as_ref() {
struct_ser.serialize_field("id", v)?;
}
if let Some(v) = self.share_id.as_ref() {
struct_ser.serialize_field("share_id", v)?;
}
if let Some(v) = self.location.as_ref() {
struct_ser.serialize_field("location", v)?;
}
if !self.auxiliary_locations.is_empty() {
struct_ser.serialize_field("auxiliary_locations", &self.auxiliary_locations)?;
}
if !self.access_modes.is_empty() {
struct_ser.serialize_field("access_modes", &self.access_modes)?;
}
struct_ser.end()
}
}
impl<'de> serde::Deserialize<'de> for Table {
#[allow(deprecated)]
fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
const FIELDS: &[&str] = &[
"name",
"schema",
"share",
"id",
"share_id",
"shareId",
"location",
"auxiliary_locations",
"auxiliaryLocations",
"access_modes",
"accessModes",
];
#[allow(clippy::enum_variant_names)]
enum GeneratedField {
Name,
Schema,
Share,
Id,
ShareId,
Location,
AuxiliaryLocations,
AccessModes,
__SkipField__,
}
impl<'de> serde::Deserialize<'de> for GeneratedField {
fn deserialize<D>(deserializer: D) -> std::result::Result<GeneratedField, D::Error>
where
D: serde::Deserializer<'de>,
{
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = GeneratedField;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(formatter, "expected one of: {:?}", &FIELDS)
}
#[allow(unused_variables)]
fn visit_str<E>(self, value: &str) -> std::result::Result<GeneratedField, E>
where
E: serde::de::Error,
{
match value {
"name" => Ok(GeneratedField::Name),
"schema" => Ok(GeneratedField::Schema),
"share" => Ok(GeneratedField::Share),
"id" => Ok(GeneratedField::Id),
"shareId" | "share_id" => Ok(GeneratedField::ShareId),
"location" => Ok(GeneratedField::Location),
"auxiliaryLocations" | "auxiliary_locations" => Ok(GeneratedField::AuxiliaryLocations),
"accessModes" | "access_modes" => Ok(GeneratedField::AccessModes),
_ => Ok(GeneratedField::__SkipField__),
}
}
}
deserializer.deserialize_identifier(GeneratedVisitor)
}
}
struct GeneratedVisitor;
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
type Value = Table;
fn expecting(&self, formatter: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
formatter.write_str("struct open_sharing.v1.Table")
}
fn visit_map<V>(self, mut map_: V) -> std::result::Result<Table, V::Error>
where
V: serde::de::MapAccess<'de>,
{
let mut name__ = None;
let mut schema__ = None;
let mut share__ = None;
let mut id__ = None;
let mut share_id__ = None;
let mut location__ = None;
let mut auxiliary_locations__ = None;
let mut access_modes__ = None;
while let Some(k) = map_.next_key()? {
match k {
GeneratedField::Name => {
if name__.is_some() {
return Err(serde::de::Error::duplicate_field("name"));
}
name__ = Some(map_.next_value()?);
}
GeneratedField::Schema => {
if schema__.is_some() {
return Err(serde::de::Error::duplicate_field("schema"));
}
schema__ = Some(map_.next_value()?);
}
GeneratedField::Share => {
if share__.is_some() {
return Err(serde::de::Error::duplicate_field("share"));
}
share__ = Some(map_.next_value()?);
}
GeneratedField::Id => {
if id__.is_some() {
return Err(serde::de::Error::duplicate_field("id"));
}
id__ = map_.next_value()?;
}
GeneratedField::ShareId => {
if share_id__.is_some() {
return Err(serde::de::Error::duplicate_field("shareId"));
}
share_id__ = map_.next_value()?;
}
GeneratedField::Location => {
if location__.is_some() {
return Err(serde::de::Error::duplicate_field("location"));
}
location__ = map_.next_value()?;
}
GeneratedField::AuxiliaryLocations => {
if auxiliary_locations__.is_some() {
return Err(serde::de::Error::duplicate_field("auxiliaryLocations"));
}
auxiliary_locations__ = Some(map_.next_value()?);
}
GeneratedField::AccessModes => {
if access_modes__.is_some() {
return Err(serde::de::Error::duplicate_field("accessModes"));
}
access_modes__ = Some(map_.next_value()?);
}
GeneratedField::__SkipField__ => {
let _ = map_.next_value::<serde::de::IgnoredAny>()?;
}
}
}
Ok(Table {
name: name__.unwrap_or_default(),
schema: schema__.unwrap_or_default(),
share: share__.unwrap_or_default(),
id: id__,
share_id: share_id__,
location: location__,
auxiliary_locations: auxiliary_locations__.unwrap_or_default(),
access_modes: access_modes__.unwrap_or_default(),
})
}
}
deserializer.deserialize_struct("open_sharing.v1.Table", FIELDS, GeneratedVisitor)
}
}