@@ -78,7 +78,9 @@ impl<'de> Deserialize<'de> for SelectionCriteria {
78
78
where
79
79
D : Deserializer < ' de > ,
80
80
{
81
- Ok ( SelectionCriteria :: ReadPreference ( ReadPreference :: deserialize ( deserializer) ?) )
81
+ Ok ( SelectionCriteria :: ReadPreference (
82
+ ReadPreference :: deserialize ( deserializer) ?,
83
+ ) )
82
84
}
83
85
}
84
86
@@ -131,11 +133,22 @@ impl<'de> Deserialize<'de> for ReadPreference {
131
133
132
134
match preference. mode . as_str ( ) {
133
135
"Primary" => Ok ( ReadPreference :: Primary ) ,
134
- "Secondary" => Ok ( ReadPreference :: Secondary { options : preference. options } ) ,
135
- "PrimaryPreferred" => Ok ( ReadPreference :: PrimaryPreferred { options : preference. options } ) ,
136
- "SecondaryPreferred" => Ok ( ReadPreference :: SecondaryPreferred { options : preference. options } ) ,
137
- "Nearest" => Ok ( ReadPreference :: Nearest { options : preference. options } ) ,
138
- other => Err ( D :: Error :: custom ( format ! ( "Unknown read preference mode: {}" , other) ) ) ,
136
+ "Secondary" => Ok ( ReadPreference :: Secondary {
137
+ options : preference. options ,
138
+ } ) ,
139
+ "PrimaryPreferred" => Ok ( ReadPreference :: PrimaryPreferred {
140
+ options : preference. options ,
141
+ } ) ,
142
+ "SecondaryPreferred" => Ok ( ReadPreference :: SecondaryPreferred {
143
+ options : preference. options ,
144
+ } ) ,
145
+ "Nearest" => Ok ( ReadPreference :: Nearest {
146
+ options : preference. options ,
147
+ } ) ,
148
+ other => Err ( D :: Error :: custom ( format ! (
149
+ "Unknown read preference mode: {}" ,
150
+ other
151
+ ) ) ) ,
139
152
}
140
153
}
141
154
}
@@ -157,7 +170,10 @@ pub struct ReadPreferenceOptions {
157
170
/// `max_staleness` must be at least 90 seconds. If a `max_staleness` less than 90 seconds is
158
171
/// specified for an operation, the operation will return an error.
159
172
#[ builder( default ) ]
160
- #[ serde( rename = "maxStalenessSeconds" , deserialize_with = "deserialize_duration_from_u64_seconds" ) ]
173
+ #[ serde(
174
+ rename = "maxStalenessSeconds" ,
175
+ deserialize_with = "deserialize_duration_from_u64_seconds"
176
+ ) ]
161
177
pub max_staleness : Option < Duration > ,
162
178
163
179
/// Specifies hedging behavior for reads. These options only apply to sharded clusters on
0 commit comments