tensorflow_serving_client/
session_service.rs

1// This file is generated by rust-protobuf 2.14.0. Do not edit
2// @generated
3
4// https://github.com/rust-lang/rust-clippy/issues/702
5#![allow(unknown_lints)]
6#![allow(clippy::all)]
7
8#![cfg_attr(rustfmt, rustfmt_skip)]
9
10#![allow(box_pointers)]
11#![allow(dead_code)]
12#![allow(missing_docs)]
13#![allow(non_camel_case_types)]
14#![allow(non_snake_case)]
15#![allow(non_upper_case_globals)]
16#![allow(trivial_casts)]
17#![allow(unsafe_code)]
18#![allow(unused_imports)]
19#![allow(unused_results)]
20//! Generated file from `tensorflow_serving/apis/session_service.proto`
21
22use protobuf::Message as Message_imported_for_functions;
23use protobuf::ProtobufEnum as ProtobufEnum_imported_for_functions;
24
25/// Generated files are compatible only with the same version
26/// of protobuf runtime.
27// const _PROTOBUF_VERSION_CHECK: () = ::protobuf::VERSION_2_14_0;
28
29#[derive(PartialEq,Clone,Default)]
30pub struct SessionRunRequest {
31    // message fields
32    pub model_spec: ::protobuf::SingularPtrField<super::model::ModelSpec>,
33    pub feed: ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto>,
34    pub fetch: ::protobuf::RepeatedField<::std::string::String>,
35    pub target: ::protobuf::RepeatedField<::std::string::String>,
36    pub options: ::protobuf::SingularPtrField<super::config::RunOptions>,
37    // special fields
38    pub unknown_fields: ::protobuf::UnknownFields,
39    pub cached_size: ::protobuf::CachedSize,
40}
41
42impl<'a> ::std::default::Default for &'a SessionRunRequest {
43    fn default() -> &'a SessionRunRequest {
44        <SessionRunRequest as ::protobuf::Message>::default_instance()
45    }
46}
47
48impl SessionRunRequest {
49    pub fn new() -> SessionRunRequest {
50        ::std::default::Default::default()
51    }
52
53    // .tensorflow.serving.ModelSpec model_spec = 1;
54
55
56    pub fn get_model_spec(&self) -> &super::model::ModelSpec {
57        self.model_spec.as_ref().unwrap_or_else(|| super::model::ModelSpec::default_instance())
58    }
59    pub fn clear_model_spec(&mut self) {
60        self.model_spec.clear();
61    }
62
63    pub fn has_model_spec(&self) -> bool {
64        self.model_spec.is_some()
65    }
66
67    // Param is passed by value, moved
68    pub fn set_model_spec(&mut self, v: super::model::ModelSpec) {
69        self.model_spec = ::protobuf::SingularPtrField::some(v);
70    }
71
72    // Mutable pointer to the field.
73    // If field is not initialized, it is initialized with default value first.
74    pub fn mut_model_spec(&mut self) -> &mut super::model::ModelSpec {
75        if self.model_spec.is_none() {
76            self.model_spec.set_default();
77        }
78        self.model_spec.as_mut().unwrap()
79    }
80
81    // Take field
82    pub fn take_model_spec(&mut self) -> super::model::ModelSpec {
83        self.model_spec.take().unwrap_or_else(|| super::model::ModelSpec::new())
84    }
85
86    // repeated .tensorflow.NamedTensorProto feed = 2;
87
88
89    pub fn get_feed(&self) -> &[super::named_tensor::NamedTensorProto] {
90        &self.feed
91    }
92    pub fn clear_feed(&mut self) {
93        self.feed.clear();
94    }
95
96    // Param is passed by value, moved
97    pub fn set_feed(&mut self, v: ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto>) {
98        self.feed = v;
99    }
100
101    // Mutable pointer to the field.
102    pub fn mut_feed(&mut self) -> &mut ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto> {
103        &mut self.feed
104    }
105
106    // Take field
107    pub fn take_feed(&mut self) -> ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto> {
108        ::std::mem::replace(&mut self.feed, ::protobuf::RepeatedField::new())
109    }
110
111    // repeated string fetch = 3;
112
113
114    pub fn get_fetch(&self) -> &[::std::string::String] {
115        &self.fetch
116    }
117    pub fn clear_fetch(&mut self) {
118        self.fetch.clear();
119    }
120
121    // Param is passed by value, moved
122    pub fn set_fetch(&mut self, v: ::protobuf::RepeatedField<::std::string::String>) {
123        self.fetch = v;
124    }
125
126    // Mutable pointer to the field.
127    pub fn mut_fetch(&mut self) -> &mut ::protobuf::RepeatedField<::std::string::String> {
128        &mut self.fetch
129    }
130
131    // Take field
132    pub fn take_fetch(&mut self) -> ::protobuf::RepeatedField<::std::string::String> {
133        ::std::mem::replace(&mut self.fetch, ::protobuf::RepeatedField::new())
134    }
135
136    // repeated string target = 4;
137
138
139    pub fn get_target(&self) -> &[::std::string::String] {
140        &self.target
141    }
142    pub fn clear_target(&mut self) {
143        self.target.clear();
144    }
145
146    // Param is passed by value, moved
147    pub fn set_target(&mut self, v: ::protobuf::RepeatedField<::std::string::String>) {
148        self.target = v;
149    }
150
151    // Mutable pointer to the field.
152    pub fn mut_target(&mut self) -> &mut ::protobuf::RepeatedField<::std::string::String> {
153        &mut self.target
154    }
155
156    // Take field
157    pub fn take_target(&mut self) -> ::protobuf::RepeatedField<::std::string::String> {
158        ::std::mem::replace(&mut self.target, ::protobuf::RepeatedField::new())
159    }
160
161    // .tensorflow.RunOptions options = 5;
162
163
164    pub fn get_options(&self) -> &super::config::RunOptions {
165        self.options.as_ref().unwrap_or_else(|| super::config::RunOptions::default_instance())
166    }
167    pub fn clear_options(&mut self) {
168        self.options.clear();
169    }
170
171    pub fn has_options(&self) -> bool {
172        self.options.is_some()
173    }
174
175    // Param is passed by value, moved
176    pub fn set_options(&mut self, v: super::config::RunOptions) {
177        self.options = ::protobuf::SingularPtrField::some(v);
178    }
179
180    // Mutable pointer to the field.
181    // If field is not initialized, it is initialized with default value first.
182    pub fn mut_options(&mut self) -> &mut super::config::RunOptions {
183        if self.options.is_none() {
184            self.options.set_default();
185        }
186        self.options.as_mut().unwrap()
187    }
188
189    // Take field
190    pub fn take_options(&mut self) -> super::config::RunOptions {
191        self.options.take().unwrap_or_else(|| super::config::RunOptions::new())
192    }
193}
194
195impl ::protobuf::Message for SessionRunRequest {
196    fn is_initialized(&self) -> bool {
197        for v in &self.model_spec {
198            if !v.is_initialized() {
199                return false;
200            }
201        };
202        for v in &self.feed {
203            if !v.is_initialized() {
204                return false;
205            }
206        };
207        for v in &self.options {
208            if !v.is_initialized() {
209                return false;
210            }
211        };
212        true
213    }
214
215    fn merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()> {
216        while !is.eof()? {
217            let (field_number, wire_type) = is.read_tag_unpack()?;
218            match field_number {
219                1 => {
220                    ::protobuf::rt::read_singular_message_into(wire_type, is, &mut self.model_spec)?;
221                },
222                2 => {
223                    ::protobuf::rt::read_repeated_message_into(wire_type, is, &mut self.feed)?;
224                },
225                3 => {
226                    ::protobuf::rt::read_repeated_string_into(wire_type, is, &mut self.fetch)?;
227                },
228                4 => {
229                    ::protobuf::rt::read_repeated_string_into(wire_type, is, &mut self.target)?;
230                },
231                5 => {
232                    ::protobuf::rt::read_singular_message_into(wire_type, is, &mut self.options)?;
233                },
234                _ => {
235                    ::protobuf::rt::read_unknown_or_skip_group(field_number, wire_type, is, self.mut_unknown_fields())?;
236                },
237            };
238        }
239        ::std::result::Result::Ok(())
240    }
241
242    // Compute sizes of nested messages
243    #[allow(unused_variables)]
244    fn compute_size(&self) -> u32 {
245        let mut my_size = 0;
246        if let Some(ref v) = self.model_spec.as_ref() {
247            let len = v.compute_size();
248            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
249        }
250        for value in &self.feed {
251            let len = value.compute_size();
252            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
253        };
254        for value in &self.fetch {
255            my_size += ::protobuf::rt::string_size(3, &value);
256        };
257        for value in &self.target {
258            my_size += ::protobuf::rt::string_size(4, &value);
259        };
260        if let Some(ref v) = self.options.as_ref() {
261            let len = v.compute_size();
262            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
263        }
264        my_size += ::protobuf::rt::unknown_fields_size(self.get_unknown_fields());
265        self.cached_size.set(my_size);
266        my_size
267    }
268
269    fn write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()> {
270        if let Some(ref v) = self.model_spec.as_ref() {
271            os.write_tag(1, ::protobuf::wire_format::WireTypeLengthDelimited)?;
272            os.write_raw_varint32(v.get_cached_size())?;
273            v.write_to_with_cached_sizes(os)?;
274        }
275        for v in &self.feed {
276            os.write_tag(2, ::protobuf::wire_format::WireTypeLengthDelimited)?;
277            os.write_raw_varint32(v.get_cached_size())?;
278            v.write_to_with_cached_sizes(os)?;
279        };
280        for v in &self.fetch {
281            os.write_string(3, &v)?;
282        };
283        for v in &self.target {
284            os.write_string(4, &v)?;
285        };
286        if let Some(ref v) = self.options.as_ref() {
287            os.write_tag(5, ::protobuf::wire_format::WireTypeLengthDelimited)?;
288            os.write_raw_varint32(v.get_cached_size())?;
289            v.write_to_with_cached_sizes(os)?;
290        }
291        os.write_unknown_fields(self.get_unknown_fields())?;
292        ::std::result::Result::Ok(())
293    }
294
295    fn get_cached_size(&self) -> u32 {
296        self.cached_size.get()
297    }
298
299    fn get_unknown_fields(&self) -> &::protobuf::UnknownFields {
300        &self.unknown_fields
301    }
302
303    fn mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields {
304        &mut self.unknown_fields
305    }
306
307    fn as_any(&self) -> &dyn (::std::any::Any) {
308        self as &dyn (::std::any::Any)
309    }
310    fn as_any_mut(&mut self) -> &mut dyn (::std::any::Any) {
311        self as &mut dyn (::std::any::Any)
312    }
313    fn into_any(self: Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)> {
314        self
315    }
316
317    fn descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor {
318        Self::descriptor_static()
319    }
320
321    fn new() -> SessionRunRequest {
322        SessionRunRequest::new()
323    }
324
325    fn descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor {
326        static mut descriptor: ::protobuf::lazy::Lazy<::protobuf::reflect::MessageDescriptor> = ::protobuf::lazy::Lazy::INIT;
327        unsafe {
328            descriptor.get(|| {
329                let mut fields = ::std::vec::Vec::new();
330                fields.push(::protobuf::reflect::accessor::make_singular_ptr_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::model::ModelSpec>>(
331                    "model_spec",
332                    |m: &SessionRunRequest| { &m.model_spec },
333                    |m: &mut SessionRunRequest| { &mut m.model_spec },
334                ));
335                fields.push(::protobuf::reflect::accessor::make_repeated_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::named_tensor::NamedTensorProto>>(
336                    "feed",
337                    |m: &SessionRunRequest| { &m.feed },
338                    |m: &mut SessionRunRequest| { &mut m.feed },
339                ));
340                fields.push(::protobuf::reflect::accessor::make_repeated_field_accessor::<_, ::protobuf::types::ProtobufTypeString>(
341                    "fetch",
342                    |m: &SessionRunRequest| { &m.fetch },
343                    |m: &mut SessionRunRequest| { &mut m.fetch },
344                ));
345                fields.push(::protobuf::reflect::accessor::make_repeated_field_accessor::<_, ::protobuf::types::ProtobufTypeString>(
346                    "target",
347                    |m: &SessionRunRequest| { &m.target },
348                    |m: &mut SessionRunRequest| { &mut m.target },
349                ));
350                fields.push(::protobuf::reflect::accessor::make_singular_ptr_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::config::RunOptions>>(
351                    "options",
352                    |m: &SessionRunRequest| { &m.options },
353                    |m: &mut SessionRunRequest| { &mut m.options },
354                ));
355                ::protobuf::reflect::MessageDescriptor::new_pb_name::<SessionRunRequest>(
356                    "SessionRunRequest",
357                    fields,
358                    file_descriptor_proto()
359                )
360            })
361        }
362    }
363
364    fn default_instance() -> &'static SessionRunRequest {
365        static mut instance: ::protobuf::lazy::Lazy<SessionRunRequest> = ::protobuf::lazy::Lazy::INIT;
366        unsafe {
367            instance.get(SessionRunRequest::new)
368        }
369    }
370}
371
372impl ::protobuf::Clear for SessionRunRequest {
373    fn clear(&mut self) {
374        self.model_spec.clear();
375        self.feed.clear();
376        self.fetch.clear();
377        self.target.clear();
378        self.options.clear();
379        self.unknown_fields.clear();
380    }
381}
382
383impl ::std::fmt::Debug for SessionRunRequest {
384    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
385        ::protobuf::text_format::fmt(self, f)
386    }
387}
388
389impl ::protobuf::reflect::ProtobufValue for SessionRunRequest {
390    fn as_ref(&self) -> ::protobuf::reflect::ReflectValueRef {
391        ::protobuf::reflect::ReflectValueRef::Message(self)
392    }
393}
394
395#[derive(PartialEq,Clone,Default)]
396pub struct SessionRunResponse {
397    // message fields
398    pub model_spec: ::protobuf::SingularPtrField<super::model::ModelSpec>,
399    pub tensor: ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto>,
400    pub metadata: ::protobuf::SingularPtrField<super::config::RunMetadata>,
401    // special fields
402    pub unknown_fields: ::protobuf::UnknownFields,
403    pub cached_size: ::protobuf::CachedSize,
404}
405
406impl<'a> ::std::default::Default for &'a SessionRunResponse {
407    fn default() -> &'a SessionRunResponse {
408        <SessionRunResponse as ::protobuf::Message>::default_instance()
409    }
410}
411
412impl SessionRunResponse {
413    pub fn new() -> SessionRunResponse {
414        ::std::default::Default::default()
415    }
416
417    // .tensorflow.serving.ModelSpec model_spec = 3;
418
419
420    pub fn get_model_spec(&self) -> &super::model::ModelSpec {
421        self.model_spec.as_ref().unwrap_or_else(|| super::model::ModelSpec::default_instance())
422    }
423    pub fn clear_model_spec(&mut self) {
424        self.model_spec.clear();
425    }
426
427    pub fn has_model_spec(&self) -> bool {
428        self.model_spec.is_some()
429    }
430
431    // Param is passed by value, moved
432    pub fn set_model_spec(&mut self, v: super::model::ModelSpec) {
433        self.model_spec = ::protobuf::SingularPtrField::some(v);
434    }
435
436    // Mutable pointer to the field.
437    // If field is not initialized, it is initialized with default value first.
438    pub fn mut_model_spec(&mut self) -> &mut super::model::ModelSpec {
439        if self.model_spec.is_none() {
440            self.model_spec.set_default();
441        }
442        self.model_spec.as_mut().unwrap()
443    }
444
445    // Take field
446    pub fn take_model_spec(&mut self) -> super::model::ModelSpec {
447        self.model_spec.take().unwrap_or_else(|| super::model::ModelSpec::new())
448    }
449
450    // repeated .tensorflow.NamedTensorProto tensor = 1;
451
452
453    pub fn get_tensor(&self) -> &[super::named_tensor::NamedTensorProto] {
454        &self.tensor
455    }
456    pub fn clear_tensor(&mut self) {
457        self.tensor.clear();
458    }
459
460    // Param is passed by value, moved
461    pub fn set_tensor(&mut self, v: ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto>) {
462        self.tensor = v;
463    }
464
465    // Mutable pointer to the field.
466    pub fn mut_tensor(&mut self) -> &mut ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto> {
467        &mut self.tensor
468    }
469
470    // Take field
471    pub fn take_tensor(&mut self) -> ::protobuf::RepeatedField<super::named_tensor::NamedTensorProto> {
472        ::std::mem::replace(&mut self.tensor, ::protobuf::RepeatedField::new())
473    }
474
475    // .tensorflow.RunMetadata metadata = 2;
476
477
478    pub fn get_metadata(&self) -> &super::config::RunMetadata {
479        self.metadata.as_ref().unwrap_or_else(|| super::config::RunMetadata::default_instance())
480    }
481    pub fn clear_metadata(&mut self) {
482        self.metadata.clear();
483    }
484
485    pub fn has_metadata(&self) -> bool {
486        self.metadata.is_some()
487    }
488
489    // Param is passed by value, moved
490    pub fn set_metadata(&mut self, v: super::config::RunMetadata) {
491        self.metadata = ::protobuf::SingularPtrField::some(v);
492    }
493
494    // Mutable pointer to the field.
495    // If field is not initialized, it is initialized with default value first.
496    pub fn mut_metadata(&mut self) -> &mut super::config::RunMetadata {
497        if self.metadata.is_none() {
498            self.metadata.set_default();
499        }
500        self.metadata.as_mut().unwrap()
501    }
502
503    // Take field
504    pub fn take_metadata(&mut self) -> super::config::RunMetadata {
505        self.metadata.take().unwrap_or_else(|| super::config::RunMetadata::new())
506    }
507}
508
509impl ::protobuf::Message for SessionRunResponse {
510    fn is_initialized(&self) -> bool {
511        for v in &self.model_spec {
512            if !v.is_initialized() {
513                return false;
514            }
515        };
516        for v in &self.tensor {
517            if !v.is_initialized() {
518                return false;
519            }
520        };
521        for v in &self.metadata {
522            if !v.is_initialized() {
523                return false;
524            }
525        };
526        true
527    }
528
529    fn merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()> {
530        while !is.eof()? {
531            let (field_number, wire_type) = is.read_tag_unpack()?;
532            match field_number {
533                3 => {
534                    ::protobuf::rt::read_singular_message_into(wire_type, is, &mut self.model_spec)?;
535                },
536                1 => {
537                    ::protobuf::rt::read_repeated_message_into(wire_type, is, &mut self.tensor)?;
538                },
539                2 => {
540                    ::protobuf::rt::read_singular_message_into(wire_type, is, &mut self.metadata)?;
541                },
542                _ => {
543                    ::protobuf::rt::read_unknown_or_skip_group(field_number, wire_type, is, self.mut_unknown_fields())?;
544                },
545            };
546        }
547        ::std::result::Result::Ok(())
548    }
549
550    // Compute sizes of nested messages
551    #[allow(unused_variables)]
552    fn compute_size(&self) -> u32 {
553        let mut my_size = 0;
554        if let Some(ref v) = self.model_spec.as_ref() {
555            let len = v.compute_size();
556            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
557        }
558        for value in &self.tensor {
559            let len = value.compute_size();
560            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
561        };
562        if let Some(ref v) = self.metadata.as_ref() {
563            let len = v.compute_size();
564            my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
565        }
566        my_size += ::protobuf::rt::unknown_fields_size(self.get_unknown_fields());
567        self.cached_size.set(my_size);
568        my_size
569    }
570
571    fn write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()> {
572        if let Some(ref v) = self.model_spec.as_ref() {
573            os.write_tag(3, ::protobuf::wire_format::WireTypeLengthDelimited)?;
574            os.write_raw_varint32(v.get_cached_size())?;
575            v.write_to_with_cached_sizes(os)?;
576        }
577        for v in &self.tensor {
578            os.write_tag(1, ::protobuf::wire_format::WireTypeLengthDelimited)?;
579            os.write_raw_varint32(v.get_cached_size())?;
580            v.write_to_with_cached_sizes(os)?;
581        };
582        if let Some(ref v) = self.metadata.as_ref() {
583            os.write_tag(2, ::protobuf::wire_format::WireTypeLengthDelimited)?;
584            os.write_raw_varint32(v.get_cached_size())?;
585            v.write_to_with_cached_sizes(os)?;
586        }
587        os.write_unknown_fields(self.get_unknown_fields())?;
588        ::std::result::Result::Ok(())
589    }
590
591    fn get_cached_size(&self) -> u32 {
592        self.cached_size.get()
593    }
594
595    fn get_unknown_fields(&self) -> &::protobuf::UnknownFields {
596        &self.unknown_fields
597    }
598
599    fn mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields {
600        &mut self.unknown_fields
601    }
602
603    fn as_any(&self) -> &dyn (::std::any::Any) {
604        self as &dyn (::std::any::Any)
605    }
606    fn as_any_mut(&mut self) -> &mut dyn (::std::any::Any) {
607        self as &mut dyn (::std::any::Any)
608    }
609    fn into_any(self: Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)> {
610        self
611    }
612
613    fn descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor {
614        Self::descriptor_static()
615    }
616
617    fn new() -> SessionRunResponse {
618        SessionRunResponse::new()
619    }
620
621    fn descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor {
622        static mut descriptor: ::protobuf::lazy::Lazy<::protobuf::reflect::MessageDescriptor> = ::protobuf::lazy::Lazy::INIT;
623        unsafe {
624            descriptor.get(|| {
625                let mut fields = ::std::vec::Vec::new();
626                fields.push(::protobuf::reflect::accessor::make_singular_ptr_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::model::ModelSpec>>(
627                    "model_spec",
628                    |m: &SessionRunResponse| { &m.model_spec },
629                    |m: &mut SessionRunResponse| { &mut m.model_spec },
630                ));
631                fields.push(::protobuf::reflect::accessor::make_repeated_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::named_tensor::NamedTensorProto>>(
632                    "tensor",
633                    |m: &SessionRunResponse| { &m.tensor },
634                    |m: &mut SessionRunResponse| { &mut m.tensor },
635                ));
636                fields.push(::protobuf::reflect::accessor::make_singular_ptr_field_accessor::<_, ::protobuf::types::ProtobufTypeMessage<super::config::RunMetadata>>(
637                    "metadata",
638                    |m: &SessionRunResponse| { &m.metadata },
639                    |m: &mut SessionRunResponse| { &mut m.metadata },
640                ));
641                ::protobuf::reflect::MessageDescriptor::new_pb_name::<SessionRunResponse>(
642                    "SessionRunResponse",
643                    fields,
644                    file_descriptor_proto()
645                )
646            })
647        }
648    }
649
650    fn default_instance() -> &'static SessionRunResponse {
651        static mut instance: ::protobuf::lazy::Lazy<SessionRunResponse> = ::protobuf::lazy::Lazy::INIT;
652        unsafe {
653            instance.get(SessionRunResponse::new)
654        }
655    }
656}
657
658impl ::protobuf::Clear for SessionRunResponse {
659    fn clear(&mut self) {
660        self.model_spec.clear();
661        self.tensor.clear();
662        self.metadata.clear();
663        self.unknown_fields.clear();
664    }
665}
666
667impl ::std::fmt::Debug for SessionRunResponse {
668    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
669        ::protobuf::text_format::fmt(self, f)
670    }
671}
672
673impl ::protobuf::reflect::ProtobufValue for SessionRunResponse {
674    fn as_ref(&self) -> ::protobuf::reflect::ReflectValueRef {
675        ::protobuf::reflect::ReflectValueRef::Message(self)
676    }
677}
678
679static file_descriptor_proto_data: &'static [u8] = b"\
680    \n-tensorflow_serving/apis/session_service.proto\x12\x12tensorflow.servi\
681    ng\x1a#tensorflow_serving/apis/model.proto\x1a%tensorflow/core/protobuf/\
682    config.proto\x1a+tensorflow/core/protobuf/named_tensor.proto\"\xe3\x01\n\
683    \x11SessionRunRequest\x12<\n\nmodel_spec\x18\x01\x20\x01(\x0b2\x1d.tenso\
684    rflow.serving.ModelSpecR\tmodelSpec\x120\n\x04feed\x18\x02\x20\x03(\x0b2\
685    \x1c.tensorflow.NamedTensorProtoR\x04feed\x12\x14\n\x05fetch\x18\x03\x20\
686    \x03(\tR\x05fetch\x12\x16\n\x06target\x18\x04\x20\x03(\tR\x06target\x120\
687    \n\x07options\x18\x05\x20\x01(\x0b2\x16.tensorflow.RunOptionsR\x07option\
688    s\"\xbd\x01\n\x12SessionRunResponse\x12<\n\nmodel_spec\x18\x03\x20\x01(\
689    \x0b2\x1d.tensorflow.serving.ModelSpecR\tmodelSpec\x124\n\x06tensor\x18\
690    \x01\x20\x03(\x0b2\x1c.tensorflow.NamedTensorProtoR\x06tensor\x123\n\x08\
691    metadata\x18\x02\x20\x01(\x0b2\x17.tensorflow.RunMetadataR\x08metadata2m\
692    \n\x0eSessionService\x12[\n\nSessionRun\x12%.tensorflow.serving.SessionR\
693    unRequest\x1a&.tensorflow.serving.SessionRunResponseB\x03\xf8\x01\x01J\
694    \xea\r\n\x06\x12\x04\0\02\x01\n\x08\n\x01\x0c\x12\x03\0\0\x12\n\x08\n\
695    \x01\x08\x12\x03\x02\0\x1f\n\t\n\x02\x08\x1f\x12\x03\x02\0\x1f\n\t\n\x02\
696    \x03\0\x12\x03\x04\0-\n\t\n\x02\x03\x01\x12\x03\x05\0/\n\t\n\x02\x03\x02\
697    \x12\x03\x06\05\n\x08\n\x01\x02\x12\x03\x08\0\x1b\n\n\n\x02\x04\0\x12\
698    \x04\n\0\x1d\x01\n\n\n\x03\x04\0\x01\x12\x03\n\x08\x19\nj\n\x04\x04\0\
699    \x02\0\x12\x03\r\x02\x1b\x1a]\x20Model\x20Specification.\x20If\x20versio\
700    n\x20is\x20not\x20specified,\x20will\x20use\x20the\x20latest\n\x20(numer\
701    ical)\x20version.\n\n\x0c\n\x05\x04\0\x02\0\x06\x12\x03\r\x02\x0b\n\x0c\
702    \n\x05\x04\0\x02\0\x01\x12\x03\r\x0c\x16\n\x0c\n\x05\x04\0\x02\0\x03\x12\
703    \x03\r\x19\x1a\nJ\n\x04\x04\0\x02\x01\x12\x03\x10\x02%\x1a=\x20Tensors\
704    \x20to\x20be\x20fed\x20in\x20the\x20step.\x20Each\x20feed\x20is\x20a\x20\
705    named\x20tensor.\n\n\x0c\n\x05\x04\0\x02\x01\x04\x12\x03\x10\x02\n\n\x0c\
706    \n\x05\x04\0\x02\x01\x06\x12\x03\x10\x0b\x1b\n\x0c\n\x05\x04\0\x02\x01\
707    \x01\x12\x03\x10\x1c\x20\n\x0c\n\x05\x04\0\x02\x01\x03\x12\x03\x10#$\n\
708    \xcd\x01\n\x04\x04\0\x02\x02\x12\x03\x15\x02\x1c\x1a\xbf\x01\x20Fetches.\
709    \x20A\x20list\x20of\x20tensor\x20names.\x20The\x20caller\x20expects\x20a\
710    \x20tensor\x20to\n\x20be\x20returned\x20for\x20each\x20fetch[i]\x20(see\
711    \x20RunResponse.tensor).\x20The\n\x20order\x20of\x20specified\x20fetches\
712    \x20does\x20not\x20change\x20the\x20execution\x20order.\n\n\x0c\n\x05\
713    \x04\0\x02\x02\x04\x12\x03\x15\x02\n\n\x0c\n\x05\x04\0\x02\x02\x05\x12\
714    \x03\x15\x0b\x11\n\x0c\n\x05\x04\0\x02\x02\x01\x12\x03\x15\x12\x17\n\x0c\
715    \n\x05\x04\0\x02\x02\x03\x12\x03\x15\x1a\x1b\ny\n\x04\x04\0\x02\x03\x12\
716    \x03\x19\x02\x1d\x1al\x20Target\x20Nodes.\x20A\x20list\x20of\x20node\x20\
717    names.\x20The\x20named\x20nodes\x20will\x20be\x20run\n\x20to\x20but\x20t\
718    heir\x20outputs\x20will\x20not\x20be\x20fetched.\n\n\x0c\n\x05\x04\0\x02\
719    \x03\x04\x12\x03\x19\x02\n\n\x0c\n\x05\x04\0\x02\x03\x05\x12\x03\x19\x0b\
720    \x11\n\x0c\n\x05\x04\0\x02\x03\x01\x12\x03\x19\x12\x18\n\x0c\n\x05\x04\0\
721    \x02\x03\x03\x12\x03\x19\x1b\x1c\n?\n\x04\x04\0\x02\x04\x12\x03\x1c\x02\
722    \x19\x1a2\x20Options\x20for\x20the\x20run\x20call.\x20**Currently\x20ign\
723    ored.**\n\n\x0c\n\x05\x04\0\x02\x04\x06\x12\x03\x1c\x02\x0c\n\x0c\n\x05\
724    \x04\0\x02\x04\x01\x12\x03\x1c\r\x14\n\x0c\n\x05\x04\0\x02\x04\x03\x12\
725    \x03\x1c\x17\x18\n\n\n\x02\x04\x01\x12\x04\x1f\0)\x01\n\n\n\x03\x04\x01\
726    \x01\x12\x03\x1f\x08\x1a\nB\n\x04\x04\x01\x02\0\x12\x03!\x02\x1b\x1a5\
727    \x20Effective\x20Model\x20Specification\x20used\x20for\x20session\x20run\
728    .\n\n\x0c\n\x05\x04\x01\x02\0\x06\x12\x03!\x02\x0b\n\x0c\n\x05\x04\x01\
729    \x02\0\x01\x12\x03!\x0c\x16\n\x0c\n\x05\x04\x01\x02\0\x03\x12\x03!\x19\
730    \x1a\nu\n\x04\x04\x01\x02\x01\x12\x03%\x02'\x1ah\x20NOTE:\x20The\x20orde\
731    r\x20of\x20the\x20returned\x20tensors\x20may\x20or\x20may\x20not\x20matc\
732    h\n\x20the\x20fetch\x20order\x20specified\x20in\x20RunRequest.\n\n\x0c\n\
733    \x05\x04\x01\x02\x01\x04\x12\x03%\x02\n\n\x0c\n\x05\x04\x01\x02\x01\x06\
734    \x12\x03%\x0b\x1b\n\x0c\n\x05\x04\x01\x02\x01\x01\x12\x03%\x1c\"\n\x0c\n\
735    \x05\x04\x01\x02\x01\x03\x12\x03%%&\n=\n\x04\x04\x01\x02\x02\x12\x03(\
736    \x02\x1b\x1a0\x20Returned\x20metadata\x20if\x20requested\x20in\x20the\
737    \x20options.\n\n\x0c\n\x05\x04\x01\x02\x02\x06\x12\x03(\x02\r\n\x0c\n\
738    \x05\x04\x01\x02\x02\x01\x12\x03(\x0e\x16\n\x0c\n\x05\x04\x01\x02\x02\
739    \x03\x12\x03(\x19\x1a\n\xb8\x02\n\x02\x06\0\x12\x04/\02\x01\x1a\xab\x02\
740    \x20SessionService\x20defines\x20a\x20service\x20with\x20which\x20a\x20c\
741    lient\x20can\x20interact\x20to\x20execute\n\x20Tensorflow\x20model\x20in\
742    ference.\x20The\x20SessionService::SessionRun\x20method\x20is\x20similar\
743    \n\x20to\x20MasterService::RunStep\x20of\x20Tensorflow,\x20except\x20tha\
744    t\x20all\x20sessions\x20are\x20ready\n\x20to\x20run,\x20and\x20you\x20re\
745    quest\x20a\x20specific\x20model/session\x20with\x20ModelSpec.\n\n\n\n\
746    \x03\x06\0\x01\x12\x03/\x08\x16\n/\n\x04\x06\0\x02\0\x12\x031\x02A\x1a\"\
747    \x20Runs\x20inference\x20of\x20a\x20given\x20model.\n\n\x0c\n\x05\x06\0\
748    \x02\0\x01\x12\x031\x06\x10\n\x0c\n\x05\x06\0\x02\0\x02\x12\x031\x11\"\n\
749    \x0c\n\x05\x06\0\x02\0\x03\x12\x031-?b\x06proto3\
750";
751
752static mut file_descriptor_proto_lazy: ::protobuf::lazy::Lazy<::protobuf::descriptor::FileDescriptorProto> = ::protobuf::lazy::Lazy::INIT;
753
754fn parse_descriptor_proto() -> ::protobuf::descriptor::FileDescriptorProto {
755    ::protobuf::parse_from_bytes(file_descriptor_proto_data).unwrap()
756}
757
758pub fn file_descriptor_proto() -> &'static ::protobuf::descriptor::FileDescriptorProto {
759    unsafe {
760        file_descriptor_proto_lazy.get(|| {
761            parse_descriptor_proto()
762        })
763    }
764}
tensorflow_serving_client/session_service.rs

tensorflow_serving_client/
session_service.rs
