File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -239,15 +239,15 @@ impl ForeignDataWrapper<EtcdFdwError> for EtcdFdw {
239239 columns : & [ Column ] ,
240240 _sorts : & [ Sort ] ,
241241 limit : & Option < Limit > ,
242- _options : & std:: collections:: HashMap < String , String > ,
242+ options : & std:: collections:: HashMap < String , String > ,
243243 ) -> Result < ( ) , EtcdFdwError > {
244244 // parse the options defined when `CREATE FOREIGN TABLE`
245- let prefix = _options . get ( "prefix" ) . cloned ( ) ;
246- let range_end = _options . get ( "range_end" ) . cloned ( ) ;
247- let key_start = _options . get ( "key" ) . cloned ( ) ;
248- let keys_only = _options . get ( "keys_only" ) . map ( |v| v == "true" ) . unwrap_or ( false ) ;
249- let revision = _options . get ( "revision" ) . and_then ( |v| v. parse :: < i64 > ( ) . ok ( ) ) . unwrap_or ( 0 ) ;
250- let serializable = _options . get ( "consistency" ) . map ( |v| v == "s" ) . unwrap_or ( false ) ;
245+ let prefix = options . get ( "prefix" ) . cloned ( ) ;
246+ let range_end = options . get ( "range_end" ) . cloned ( ) ;
247+ let key_start = options . get ( "key" ) . cloned ( ) ;
248+ let keys_only = options . get ( "keys_only" ) . map ( |v| v == "true" ) . unwrap_or ( false ) ;
249+ let revision = options . get ( "revision" ) . and_then ( |v| v. parse :: < i64 > ( ) . ok ( ) ) . unwrap_or ( 0 ) ;
250+ let serializable = options . get ( "consistency" ) . map ( |v| v == "s" ) . unwrap_or ( false ) ;
251251 let mut get_options = GetOptions :: new ( ) ;
252252
253253 // prefix and range are mutually exclusive
You can’t perform that action at this time.
0 commit comments