This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
The following commit(s) were added to refs/heads/asf-site by this push:
new e1ff581e31 deploy: 51ac6fec8755147cd6b1dfe7d76bfdcfacad0463
e1ff581e31 is described below
commit e1ff581e3132aab0b936618ccc9b6f084ef949f2
Author: tustvold <[email protected]>
AuthorDate: Wed Oct 18 14:00:50 2023 +0000
deploy: 51ac6fec8755147cd6b1dfe7d76bfdcfacad0463
---
arrow_avro/index.html | 2 +-
arrow_avro/reader/header/index.html | 2 +-
arrow_avro/reader/index.html | 2 +-
.../auth_basic_proto/fn.authenticate.html | 2 +-
.../auth_basic_proto/type.Client.html | 2 +-
.../fn.consume_flight_location.html | 4 +-
.../fn.receive_batch_flight_data.html | 4 +-
.../fn.receive_schema_flight_data.html | 2 +-
.../integration_test/fn.send_batch.html | 2 +-
.../integration_test/fn.upload_data.html | 4 +-
.../integration_test/fn.verify_data.html | 4 +-
.../integration_test/type.Client.html | 2 +-
.../struct.AuthBasicProtoScenarioImpl.html | 54 +++++++++++-----------
.../flight_server_scenarios/fn.endpoint.html | 2 +-
.../integration_test/fn.save_uploaded_chunks.html | 4 +-
.../integration_test/fn.send_app_metadata.html | 2 +-
.../integration_test/struct.FlightServiceImpl.html | 54 +++++++++++-----------
.../middleware/struct.MiddlewareScenarioImpl.html | 54 +++++++++++-----------
.../flight_service_server/trait.FlightService.js | 2 +-
src/arrow_avro/lib.rs.html | 20 ++++++++
src/arrow_avro/reader/header.rs.html | 6 ++-
src/arrow_avro/reader/mod.rs.html | 4 +-
22 files changed, 129 insertions(+), 105 deletions(-)
diff --git a/arrow_avro/index.html b/arrow_avro/index.html
index 5bd46fb114..6fbd3f945b 100644
--- a/arrow_avro/index.html
+++ b/arrow_avro/index.html
@@ -1,3 +1,3 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Convert
data to / from the Apache Arrow memory format and Apache
Avro"><title>arrow_avro - Rust</title><link rel="preload" as="font"
type="font/woff2" crossorigin
href="../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" crosso [...]
- <li><a id="all-types" href="all.html">All
Items</a></li></ul><section><ul class="block"><li><a
href="#modules">Modules</a></li></ul></section></div></nav><main><div
class="width-limiter"><nav class="sub"><form
class="search-form"><span></span><input class="search-input" name="search"
aria-label="Run search in the documentation" autocomplete="off"
spellcheck="false" placeholder="Click or press ‘S’ to search, ‘?’ for more
options…" type="search"><div id="help-button" title="hel [...]
+ <li><a id="all-types" href="all.html">All
Items</a></li></ul><section><ul class="block"><li><a
href="#modules">Modules</a></li></ul></section></div></nav><main><div
class="width-limiter"><nav class="sub"><form
class="search-form"><span></span><input class="search-input" name="search"
aria-label="Run search in the documentation" autocomplete="off"
spellcheck="false" placeholder="Click or press ‘S’ to search, ‘?’ for more
options…" type="search"><div id="help-button" title="hel [...]
</div></details><h2 id="modules" class="small-section-header"><a
href="#modules">Modules</a></h2><ul class="item-table"><li><div
class="item-name"><a class="mod" href="compression/index.html" title="mod
arrow_avro::compression">compression</a><span title="Restricted
Visibility"> 🔒</span> </div></li><li><div class="item-name"><a class="mod"
href="reader/index.html" title="mod arrow_avro::reader">reader</a></div><div
class="desc docblock-short">Read Avro data to Arrow</div></li><li><d [...]
\ No newline at end of file
diff --git a/arrow_avro/reader/header/index.html
b/arrow_avro/reader/header/index.html
index 64768bf2cb..5d24902f01 100644
--- a/arrow_avro/reader/header/index.html
+++ b/arrow_avro/reader/header/index.html
@@ -1,2 +1,2 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Decoder
for `Header`"><title>arrow_avro::reader::header - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" crossorigin href="../../../static
[...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Decoder
for `Header`"><title>arrow_avro::reader::header - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" crossorigin href="../../../static
[...]
</div></details><h2 id="structs" class="small-section-header"><a
href="#structs">Structs</a></h2><ul class="item-table"><li><div
class="item-name"><a class="struct" href="struct.Header.html" title="struct
arrow_avro::reader::header::Header">Header</a></div><div class="desc
docblock-short">A decoded header for an <a
href="https://avro.apache.org/docs/1.11.1/specification/#object-container-files";>Object
Container File</a></div></li><li><div class="item-name"><a class="struct"
href="struct. [...]
\ No newline at end of file
diff --git a/arrow_avro/reader/index.html b/arrow_avro/reader/index.html
index 6d48166a04..5d1e3b0bb8 100644
--- a/arrow_avro/reader/index.html
+++ b/arrow_avro/reader/index.html
@@ -1,2 +1,2 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Read Avro
data to Arrow"><title>arrow_avro::reader - Rust</title><link rel="preload"
as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/Fira [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Read Avro
data to Arrow"><title>arrow_avro::reader - Rust</title><link rel="preload"
as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/Fira [...]
</div></details><h2 id="modules" class="small-section-header"><a
href="#modules">Modules</a></h2><ul class="item-table"><li><div
class="item-name"><a class="mod" href="block/index.html" title="mod
arrow_avro::reader::block">block</a><span title="Restricted
Visibility"> 🔒</span> </div><div class="desc docblock-short">Decoder for
<a href="block/struct.Block.html" title="struct
arrow_avro::reader::block::Block"><code>Block</code></a></div></li><li><div
class="item-name"><a class="mod" [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
index 0c1010f09c..7986483419 100644
---
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
+++
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `authenticate` fn in crate
`arrow_integration_testing`."><title>authenticate in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/Source [...]
- client: &mut <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ client: &mut FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
username: &<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.str.html";>str</a>,
password: &<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.str.html";>str</a>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.E [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
index f216fe2f9d..0cf3814fa2 100644
---
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
+++
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
@@ -1,3 +1,3 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
inner: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/client/grpc/struct.Grpc.html";
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.inner"
class="structfield small-section-header"><a href="#structfield.inner"
class="anchor field">§</a><code>inner: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/client/grpc/struct.Grpc.html";
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
[...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
index 47cb363af5..a727b14fa9 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `consume_flight_location` fn in crate
`arrow_integration_testing`."><title>consume_flight_location in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../ [...]
- location: <a class="struct"
href="../../../arrow_flight/gen/struct.Location.html" title="struct
arrow_flight::gen::Location">Location</a>,
- ticket: <a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>,
+ location: Location,
+ ticket: Ticket,
expected_data: &[<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
index c1eb551d04..1cefb77e21 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `receive_batch_flight_data` fn in crate
`arrow_integration_testing`."><title>receive_batch_flight_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href=".. [...]
- resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>,
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>,
schema: <a class="type"
href="../../../arrow_schema/schema/type.SchemaRef.html" title="type
arrow_schema::schema::SchemaRef">SchemaRef</a>,
dictionaries_by_id: &mut <a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.i64.html";>i64</a>, <a
class="type" href="../../../arrow_array/array/type.ArrayRef.html" title="type
arrow_array::array::ArrayRef">ArrayRef</a>>
-) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightData.html" title="struct
arrow_flight::gen::FlightData">FlightData</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
+) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum
core::option::Option">Option</a><FlightData></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
index 456be61743..a729d20f1f 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
@@ -1,3 +1,3 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `receive_schema_flight_data` fn in crate
`arrow_integration_testing`."><title>receive_schema_flight_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin href="
[...]
- resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
index 646707a5c3..da7d3ad327 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `send_batch` fn in crate
`arrow_integration_testing`."><title>send_batch in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSeri [...]
- upload_tx: &mut Sender<<a class="struct"
href="../../../arrow_flight/gen/struct.FlightData.html" title="struct
arrow_flight::gen::FlightData">FlightData</a>>,
+ upload_tx: &mut Sender<FlightData>,
metadata: &[<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.u8.html";>u8</a>],
batch: &<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>,
options: &<a class="struct"
href="../../../arrow_ipc/writer/struct.IpcWriteOptions.html" title="struct
arrow_ipc::writer::IpcWriteOptions">IpcWriteOptions</a>
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
index e7700802ed..d8c99495c4 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
@@ -1,6 +1,6 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `upload_data` fn in crate
`arrow_integration_testing`."><title>upload_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSe [...]
- client: <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ client: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
schema: <a class="type"
href="../../../arrow_schema/schema/type.SchemaRef.html" title="type
arrow_schema::schema::SchemaRef">SchemaRef</a>,
- descriptor: <a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>,
+ descriptor: FlightDescriptor,
original_data: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/vec/struct.Vec.html";
title="struct alloc::vec::Vec">Vec</a><<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
index de328ae638..3a25bec5b8 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `verify_data` fn in crate
`arrow_integration_testing`."><title>verify_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSe [...]
- client: <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
- descriptor: <a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>,
+ client: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ descriptor: FlightDescriptor,
expected_data: &[<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
index 051caab8b7..46c9cb72ff 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
@@ -1,3 +1,3 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
inner: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/client/grpc/struct.Grpc.html";
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.inner"
class="structfield small-section-header"><a href="#structfield.inner"
class="anchor field">§</a><code>inner: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/client/grpc/struct.Grpc.html";
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/transport/channel/struct.Channel.html";
[...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
b/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
index 570059ff88..e69df3c1b6 100644
---
a/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
@@ -8,44 +8,44 @@
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section><sect [...]
&self,
token: <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>>
-) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section></div [...]
+) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section></div [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#118-124">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'as [...]
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#118-124">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#126-173">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#126-173">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#175-181">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
cla [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#175-181">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#183-189">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#183-189">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -56,37 +56,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#191-198">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#191-198">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#200-210">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#200-210">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#212-218">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#212-218">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#220-227">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchan
[...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#220-227">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git a/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
b/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
index ba5057ac3c..8734b593b2 100644
--- a/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
+++ b/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `endpoint` fn in crate
`arrow_integration_testing`."><title>endpoint in
arrow_integration_testing::flight_server_scenarios - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac52 [...]
\ No newline at end of file
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `endpoint` fn in crate
`arrow_integration_testing`."><title>endpoint in
arrow_integration_testing::flight_server_scenarios - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac52 [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
index b6d466a605..b5c5bc5758 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
@@ -1,8 +1,8 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `save_uploaded_chunks` fn in crate
`arrow_integration_testing`."><title>save_uploaded_chunks in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../sta [...]
uploaded_chunks: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><Mutex<<a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct" href [...]
schema_ref: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><<a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>>,
- input_stream: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>,
- response_tx: Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="../../../arrow_flight/gen/struct.PutResult.html" title="struct
arrow_flight::gen::PutResult">PutResult</a>, <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
+ input_stream: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>,
+ response_tx: Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><PutResult, <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
schema: <a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>,
key: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct
tonic::status::Status">Status</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
index 6266c3170a..d5ae6cbf90 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
@@ -1,4 +1,4 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `send_app_metadata` fn in crate
`arrow_integration_testing`."><title>send_app_metadata in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.fi [...]
- tx: &mut Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="../../../arrow_flight/gen/struct.PutResult.html" title="struct
arrow_flight::gen::PutResult">PutResult</a>, <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
+ tx: &mut Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><PutResult, <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
app_metadata: &[<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.u8.html";>u8</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/status/struct.Status.html";
title="struct
tonic::status::Status">Status</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
index d7855b5812..5538e14a17 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
@@ -1,44 +1,44 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `FlightServiceImpl` struct in crate
`arrow_integration_testing`."><title>FlightServiceImpl in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../stati [...]
server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>,
uploaded_chunks: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><Mutex<<a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct" href [...]
-}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.server_location"
class="structfield small-section-header"><a href="#structfield.server_location"
class="anchor field">§</a><code>server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a></code></span><span
id="structfield.uploaded_chunks" class="structfield [...]
+}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.server_location"
class="structfield small-section-header"><a href="#structfield.server_location"
class="anchor field">§</a><code>server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a></code></span><span
id="structfield.uploaded_chunks" class="structfield [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#99-149">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'asy [...]
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#99-149">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#151-156">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#151-156">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#158-163">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
cla [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#158-163">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#165-210">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#165-210">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -49,37 +49,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#212-259">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#212-259">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#261-266">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#261-266">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#268-273">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#268-273">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#275-280">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchan
[...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#275-280">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git
a/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
b/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
index a5dd57c695..8d5682f0a1 100644
---
a/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
@@ -1,41 +1,41 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `MiddlewareScenarioImpl` struct in crate
`arrow_integration_testing`."><title>MiddlewareScenarioImpl in
arrow_integration_testing::flight_server_scenarios::middleware -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../s [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `MiddlewareScenarioImpl` struct in crate
`arrow_integration_testing`."><title>MiddlewareScenarioImpl in
arrow_integration_testing::flight_server_scenarios::middleware -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../s [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#67-72">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'async_trait>(
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#67-72">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#74-79">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymetho
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#74-79">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#81-86">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
class="fn"> [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#81-86">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#88-122">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymeth
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#88-122">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -46,37 +46,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#124-129">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#124-129">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#131-136">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_actio
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#131-136">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#138-143">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a><' [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#138-143">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#145-150">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchange"
cl [...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#145-150">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git
a/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
b/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
index aa7082f4db..76e97c85f1 100644
--- a/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
+++ b/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
@@ -1,4 +1,4 @@
(function() {var implementors = {
"arrow_flight":[],
-"arrow_integration_testing":[["impl <a class=\"trait\"
href=\"arrow_flight/gen/flight_service_server/trait.FlightService.html\"
title=\"trait
arrow_flight::gen::flight_service_server::FlightService\">FlightService</a> for
<a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::integration_test::FlightServiceImpl\">FlightServiceImpl</a>"],["impl
<a class [...]
+"arrow_integration_testing":[["impl FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::integration_test::FlightServiceImpl\">FlightServiceImpl</a>"],["impl
FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html\"
title=\"struct arrow_integration_ [...]
};if (window.register_implementors)
{window.register_implementors(implementors);} else {window.pending_implementors
= implementors;}})()
\ No newline at end of file
diff --git a/src/arrow_avro/lib.rs.html b/src/arrow_avro/lib.rs.html
index e02cdd3284..907427e991 100644
--- a/src/arrow_avro/lib.rs.html
+++ b/src/arrow_avro/lib.rs.html
@@ -26,6 +26,16 @@
<a href="#26" id="26">26</a>
<a href="#27" id="27">27</a>
<a href="#28" id="28">28</a>
+<a href="#29" id="29">29</a>
+<a href="#30" id="30">30</a>
+<a href="#31" id="31">31</a>
+<a href="#32" id="32">32</a>
+<a href="#33" id="33">33</a>
+<a href="#34" id="34">34</a>
+<a href="#35" id="35">35</a>
+<a href="#36" id="36">36</a>
+<a href="#37" id="37">37</a>
+<a href="#38" id="38">38</a>
</pre></div><pre class="rust"><code><span class="comment">// Licensed to the
Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
@@ -54,4 +64,14 @@
<span class="kw">mod </span>schema;
<span class="kw">mod </span>compression;
+
+<span class="attr">#[cfg(test)]
+</span><span class="kw">mod </span>test_util {
+ <span class="kw">pub fn </span>arrow_test_data(path: <span
class="kw-2">&</span>str) -> String {
+ <span class="kw">match </span>std::env::var(<span
class="string">"ARROW_TEST_DATA"</span>) {
+ <span class="prelude-val">Ok</span>(dir) => <span
class="macro">format!</span>(<span
class="string">"{dir}/{path}"</span>),
+ <span class="prelude-val">Err</span>(<span class="kw">_</span>)
=> <span class="macro">format!</span>(<span
class="string">"../testing/data/{path}"</span>),
+ }
+ }
+}
</code></pre></div></section></main></body></html>
\ No newline at end of file
diff --git a/src/arrow_avro/reader/header.rs.html
b/src/arrow_avro/reader/header.rs.html
index a9b12632ca..107b4778a7 100644
--- a/src/arrow_avro/reader/header.rs.html
+++ b/src/arrow_avro/reader/header.rs.html
@@ -287,6 +287,7 @@
<a href="#287" id="287">287</a>
<a href="#288" id="288">288</a>
<a href="#289" id="289">289</a>
+<a href="#290" id="290">290</a>
</pre></div><pre class="rust"><code><span class="comment">// Licensed to the
Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
@@ -529,6 +530,7 @@
<span class="kw">use super</span>::<span class="kw-2">*</span>;
<span class="kw">use </span><span
class="kw">crate</span>::reader::read_header;
<span class="kw">use </span><span
class="kw">crate</span>::schema::SCHEMA_METADATA_KEY;
+ <span class="kw">use </span><span
class="kw">crate</span>::test_util::arrow_test_data;
<span class="kw">use </span>std::fs::File;
<span class="kw">use </span>std::io::{BufRead, BufReader};
@@ -555,7 +557,7 @@
<span class="attr">#[test]
</span><span class="kw">fn </span>test_header() {
- <span class="kw">let </span>header = decode_file(<span
class="string">"../testing/data/avro/alltypes_plain.avro"</span>);
+ <span class="kw">let </span>header = decode_file(<span
class="kw-2">&</span>arrow_test_data(<span
class="string">"avro/alltypes_plain.avro"</span>));
<span class="kw">let </span>schema_json =
header.get(SCHEMA_METADATA_KEY).unwrap();
<span class="kw">let </span>expected = <span
class="string">br#"{"type":"record","name":"topLevelRecord","fields":[{"name":"id","type":["int","null"]},{"name":"bool_col","type":["boolean","null"]},{"name":"tinyint_col","type":["int","null"]},{"name":"smallint_col&
[...]
<span class="macro">assert_eq!</span>(schema_json, expected);
@@ -565,7 +567,7 @@
<span class="number">226966037233754408753420635932530907102
</span>);
- <span class="kw">let </span>header = decode_file(<span
class="string">"../testing/data/avro/fixed_length_decimal.avro"</span>);
+ <span class="kw">let </span>header = decode_file(<span
class="kw-2">&</span>arrow_test_data(<span
class="string">"avro/fixed_length_decimal.avro"</span>));
<span class="kw">let </span>schema_json =
header.get(SCHEMA_METADATA_KEY).unwrap();
<span class="kw">let </span>expected = <span
class="string">br#"{"type":"record","name":"topLevelRecord","fields":[{"name":"value","type":[{"type":"fixed","name":"fixed","namespace":"topLevelRecord.value","size":11,"logicalType":"decimal","precision":25,"scale":2},"null"]}]}&quo
[...]
<span class="macro">assert_eq!</span>(schema_json, expected);
diff --git a/src/arrow_avro/reader/mod.rs.html
b/src/arrow_avro/reader/mod.rs.html
index b39f028cfe..c532a2817a 100644
--- a/src/arrow_avro/reader/mod.rs.html
+++ b/src/arrow_avro/reader/mod.rs.html
@@ -90,6 +90,7 @@
<a href="#90" id="90">90</a>
<a href="#91" id="91">91</a>
<a href="#92" id="92">92</a>
+<a href="#93" id="93">93</a>
</pre></div><pre class="rust"><code><span class="comment">// Licensed to the
Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
@@ -168,12 +169,13 @@
<span class="attr">#[cfg(test)]
</span><span class="kw">mod </span>test {
<span class="kw">use </span><span
class="kw">crate</span>::reader::{read_blocks, read_header};
+ <span class="kw">use </span><span
class="kw">crate</span>::test_util::arrow_test_data;
<span class="kw">use </span>std::fs::File;
<span class="kw">use </span>std::io::BufReader;
<span class="attr">#[test]
</span><span class="kw">fn </span>test_mux() {
- <span class="kw">let </span>file = File::open(<span
class="string">"../testing/data/avro/alltypes_plain.avro"</span>).unwrap();
+ <span class="kw">let </span>file = File::open(arrow_test_data(<span
class="string">"avro/alltypes_plain.avro"</span>)).unwrap();
<span class="kw">let </span><span class="kw-2">mut </span>reader =
BufReader::new(file);
<span class="kw">let </span>header = read_header(<span
class="kw-2">&mut </span>reader).unwrap();
<span class="kw">for </span>result <span class="kw">in
</span>read_blocks(reader) {
