| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/flight/ |
| H A D | serialization_internal.h | 39 struct FlightData { struct
59 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer); argument
|
| H A D | serialization_internal.cc | 408 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer) { in WritePayload()
415 grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
422 grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
440 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
452 bool ReadPayload(grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
458 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* reader, in ReadPayload()
|
| H A D | customize_protobuf.h | 78 class FlightData; variable
|
| /dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/flight/ |
| H A D | serialization_internal.h | 39 struct FlightData { struct
61 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer); argument
|
| H A D | serialization_internal.cc | 397 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer) { in WritePayload()
408 grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
419 grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
445 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
457 bool ReadPayload(grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
463 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* reader, in ReadPayload()
|
| H A D | customize_protobuf.h | 78 class FlightData; variable
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/flight/ |
| H A D | serialization_internal.h | 39 struct FlightData { struct
59 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer); argument
|
| H A D | serialization_internal.cc | 402 grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* writer) { in WritePayload()
409 grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
416 grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* writer) { in WritePayload()
434 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
446 bool ReadPayload(grpc::ServerReaderWriter<pb::FlightData, pb::FlightData>* reader, in ReadPayload()
452 bool ReadPayload(grpc::ClientReaderWriter<pb::FlightData, pb::PutResult>* reader, in ReadPayload()
|
| H A D | customize_protobuf.h | 85 class FlightData; variable
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/arrow-flight/src/ |
| H A D | utils.rs | 35 ) -> (Vec<FlightData>, FlightData) { in flight_data_from_arrow_batch()
49 impl From<EncodedData> for FlightData { implementation
73 ) -> FlightData { in flight_data_from_arrow_schema()
141 data: &FlightData, in flight_data_to_arrow_batch()
|
| H A D | arrow.flight.protocol.rs | 176 pub struct FlightData { struct
181 pub flight_descriptor: ::core::option::Option<FlightDescriptor>,
185 pub data_header: ::prost::alloc::vec::Vec<u8>,
189 pub app_metadata: ::prost::alloc::vec::Vec<u8>,
196 pub data_body: ::prost::alloc::vec::Vec<u8>,
357 tonic::Response<tonic::codec::Streaming<super::FlightData>>, in do_get()
412 tonic::Response<tonic::codec::Streaming<super::FlightData>>, in do_exchange()
583 request: tonic::Request<tonic::Streaming<super::FlightData>>, in do_put()
598 request: tonic::Request<tonic::Streaming<super::FlightData>>, in do_exchange()
872 request: tonic::Request<tonic::Streaming<super::FlightData>>, in call()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/arrow/src/flight/ |
| H A D | mod.rs | 31 impl From<&RecordBatch> for FlightData { implementation
53 impl From<&Schema> for FlightData { implementation
95 data: &FlightData, in flight_data_to_batch()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/go/arrow/flight/ |
| H A D | Flight.pb.go | 908 type FlightData struct { struct
909 state protoimpl.MessageState
910 sizeCache protoimpl.SizeCache
911 unknownFields protoimpl.UnknownFields
931 func (x *FlightData) Reset() {
940 func (x *FlightData) String() string {
944 func (*FlightData) ProtoMessage() {}
959 func (*FlightData) Descriptor() ([]byte, []int) {
970 func (x *FlightData) GetDataHeader() []byte {
977 func (x *FlightData) GetAppMetadata() []byte {
[all …]
|
| H A D | record_batch_writer.go | 30 Send(*FlightData) error
|
| /dports/databases/arrow/apache-arrow-6.0.1/go/arrow/flight/ |
| H A D | Flight.pb.go | 908 type FlightData struct { struct
909 state protoimpl.MessageState
910 sizeCache protoimpl.SizeCache
911 unknownFields protoimpl.UnknownFields
931 func (x *FlightData) Reset() {
940 func (x *FlightData) String() string {
944 func (*FlightData) ProtoMessage() {}
959 func (*FlightData) Descriptor() ([]byte, []int) {
970 func (x *FlightData) GetDataHeader() []byte {
977 func (x *FlightData) GetAppMetadata() []byte {
[all …]
|
| H A D | record_batch_writer.go | 31 Send(*FlightData) error
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/integration-testing/src/flight_client_scenarios/ |
| H A D | integration_test.rs | 124 upload_tx: &mut mpsc::Sender<FlightData>, in send_batch()
246 resp: &mut Streaming<FlightData>, in receive_batch_flight_data()
249 ) -> Option<FlightData> { in receive_batch_flight_data()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/arrow-flight/src/ |
| H A D | arrow.flight.protocol.rs | 175 pub struct FlightData { struct
180 pub flight_descriptor: ::std::option::Option<FlightDescriptor>,
184 pub data_header: std::vec::Vec<u8>,
188 pub app_metadata: std::vec::Vec<u8>,
195 pub data_body: std::vec::Vec<u8>,
356 tonic::Response<tonic::codec::Streaming<super::FlightData>>, in do_get()
411 tonic::Response<tonic::codec::Streaming<super::FlightData>>, in do_exchange()
577 request: tonic::Request<tonic::Streaming<super::FlightData>>, in do_put()
592 request: tonic::Request<tonic::Streaming<super::FlightData>>, in do_exchange()
855 request: tonic::Request<tonic::Streaming<super::FlightData>>, in call()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/arrow-flight/examples/ |
| H A D | server.rs | 94 _request: Request<Streaming<FlightData>>, in do_put()
115 _request: Request<Streaming<FlightData>>, in do_exchange()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/arrow-flight/examples/ |
| H A D | server.rs | 89 _request: Request<Streaming<FlightData>>, in do_put()
110 _request: Request<Streaming<FlightData>>, in do_exchange()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/integration-testing/src/flight_server_scenarios/ |
| H A D | middleware.rs | 121 _request: Request<Streaming<FlightData>>, in do_put()
142 _request: Request<Streaming<FlightData>>, in do_exchange()
|
| H A D | integration_test.rs | 204 request: Request<Streaming<FlightData>>, in do_put()
267 _request: Request<Streaming<FlightData>>, in do_exchange()
326 mut input_stream: Streaming<FlightData>, in save_uploaded_chunks()
|
| H A D | auth_basic_proto.rs | 188 request: Request<Streaming<FlightData>>, in do_put()
216 request: Request<Streaming<FlightData>>, in do_exchange()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/datafusion/examples/ |
| H A D | flight_server.rs | 150 _request: Request<Streaming<FlightData>>, in do_put()
171 _request: Request<Streaming<FlightData>>, in do_exchange()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/examples/ |
| H A D | flight_server.rs | 173 _request: Request<Streaming<FlightData>>, in do_put()
194 _request: Request<Streaming<FlightData>>, in do_exchange()
|