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 41d50621df deploy: 431be3facb0645528397aa800166089e4a21a834
41d50621df is described below
commit 41d50621df2485f6de66724cf7d492fd932bd172
Author: tustvold <[email protected]>
AuthorDate: Sat Sep 23 17:22:27 2023 +0000
deploy: 431be3facb0645528397aa800166089e4a21a834
---
.../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 +-
16 files changed, 99 insertions(+), 99 deletions(-)
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 9ff1ec854f..251d32984c 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 FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/transport/channel/struct.Channel.html"
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ 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.1/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 99a0841f9e..ac87472f4a 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.1/tonic/client/grpc/struct.Grpc.html"
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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.1/tonic/client/grpc/struct.Grpc.html"
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 061c9b4758..5bf51c3686 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: Location,
- ticket: Ticket,
+ 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>,
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 9d7f23bcf5..b9e4b64946 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.1/tonic/codec/decode/struct.Streaming.html"
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>,
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.1/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>>,
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><FlightData></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><<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
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 fe7991dfbf..cb2a3edab7 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.1/tonic/codec/decode/struct.Streaming.html"
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.10.1/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="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 945c591650..8216ca2e15 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<FlightData>,
+ upload_tx: &mut Sender<<a class="struct"
href="../../../arrow_flight/gen/struct.FlightData.html" title="struct
arrow_flight::gen::FlightData">FlightData</a>>,
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 58c1019540..8b831e911c 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: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/transport/channel/struct.Channel.html"
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ 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.1/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: FlightDescriptor,
+ descriptor: <a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>,
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 93b2e8ab6d..9ea904c5a0 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: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/transport/channel/struct.Channel.html"
title="struct tonic::transport::channel::Channel">Channel</a>>,
- descriptor: FlightDescriptor,
+ 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.1/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>,
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 7cfb17b13b..e57cf7d307 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.1/tonic/client/grpc/struct.Grpc.html"
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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.1/tonic/client/grpc/struct.Grpc.html"
title="struct tonic::client::grpc::Grpc">Grpc</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 b78a2f9108..80833db1c6 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.1/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.1/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.1/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.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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/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 [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">handshake</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_flights</a><'life0, 'async_trait>(
+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 [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 class="fn">get_flight_info</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_action</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_actions</a><'life0, 'async_trait>(
+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 [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_exchange</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 efd2418212..206f369f7f 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 ec9b3e8115..2faf7ba1cf 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.1/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.1/tonic/status/struct.Status.html"
title="struct tonic::status::Status">Status</a>>>,
+ input_stream: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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.1/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.1/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 580907bc18..a38b686838 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><PutResult, <a class="struct"
href="https://docs.rs/tonic/0.10.1/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><<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.1/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.1/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 8d4391bd43..3cdb92283f 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.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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/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 [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">handshake</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_flights</a><'life0, 'async_trait>(
+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 [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 class="fn">get_flight_info</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_action</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_actions</a><'life0, 'async_trait>(
+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 [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_exchange</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 21de50af45..3a056393d6 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.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">handshake</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_flights</a><'life0, 'async_trait>(
+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"> [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 class="fn">get_flight_info</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
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
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_action</a><'life0, 'async_trait>(
+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
[...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">list_actions</a><'life0, 'async_trait>(
+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><' [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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
class="fn">do_exchange</a><'life0, 'async_trait>(
+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 [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.10.1/tonic/request/struct.Request.html"
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.10.1/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 [...]
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 22d024b506..cb1eca5418 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 FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::middleware::MiddlewareScenarioImpl\">MiddlewareScenarioImpl</a>"],["impl
FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html\"
title=\"struct arrow [...]
+"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/middleware/struct.MiddlewareScenarioImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::middleware::MiddlewareScenarioImpl\">MiddlewareScenarioImpl</a>"],["impl
<a cl [...]
};if (window.register_implementors)
{window.register_implementors(implementors);} else {window.pending_implementors
= implementors;}})()
\ No newline at end of file