From 771c776529a4cbd917fff69f6a1812a113177b29 Mon Sep 17 00:00:00 2001 From: keigohtr Date: Mon, 30 Sep 2019 14:46:44 +0900 Subject: [PATCH 1/3] Add jsonData --- rekcurd.proto | 20 +++++--------------- 1 file changed, 5 insertions(+), 15 deletions(-) diff --git a/rekcurd.proto b/rekcurd.proto index b15feef..973602d 100644 --- a/rekcurd.proto +++ b/rekcurd.proto @@ -47,7 +47,7 @@ enum EnumVersionInfo { // RekcurdMessage message. message RekcurdMessage { Status status = 1; - JsonFormatString meta = 2; + google.protobuf.Value meta = 2; DefaultData data = 3; Score score = 4; } @@ -65,11 +65,6 @@ message Status { StatusFlag status = 4; } -// JsonFormatString message. -message JsonFormatString { - string val = 1; -} - // DefaultData message. message DefaultData { repeated string names = 1; @@ -78,7 +73,7 @@ message DefaultData { google.protobuf.ListValue ndarray = 3; bytes binData = 4; string strData = 5; - StringList strDataList = 6; + google.protobuf.Value jsonData = 6; } } @@ -88,11 +83,6 @@ message Tensor { repeated double val = 2; } -// StringList message. -message StringList { - repeated string val = 1; -} - // Score message. message Score { repeated float val = 1; @@ -133,8 +123,8 @@ message EvaluationMetrics { repeated float precision = 3; repeated float recall = 4; repeated float fvalue = 5; - StringList label = 6; - JsonFormatString option = 7; + google.protobuf.Value label = 6; + google.protobuf.Value option = 7; } // EvaluationResponse message. @@ -148,7 +138,7 @@ message EvaluationResultResponse { message Detail { RekcurdMessage input = 1; RekcurdMessage output = 2; - StringList label = 3; + google.protobuf.Value label = 3; bool isCorrect = 4; } From 62d53b38d929be627ea63e8e653fc2794a74dd96 Mon Sep 17 00:00:00 2001 From: keigohtr Date: Mon, 30 Sep 2019 14:47:01 +0900 Subject: [PATCH 2/3] Update to latest spec for health check --- rekcurd.proto | 2 ++ 1 file changed, 2 insertions(+) diff --git a/rekcurd.proto b/rekcurd.proto index 973602d..45dc541 100644 --- a/rekcurd.proto +++ b/rekcurd.proto @@ -26,6 +26,8 @@ message HealthCheckResponse { // https://github.com/grpc/grpc/blob/master/doc/health-checking.md service Health { rpc Check(HealthCheckRequest) returns (HealthCheckResponse); + + rpc Watch(HealthCheckRequest) returns (stream HealthCheckResponse); } From 47260e730ab2ddcb49ae327bb7383317f1210c9a Mon Sep 17 00:00:00 2001 From: keigohtr Date: Mon, 30 Sep 2019 14:49:12 +0900 Subject: [PATCH 3/3] Update the generated files --- protobuf/rekcurd_pb2.py | 487 +++++++++++++++-------------------- protobuf/rekcurd_pb2_grpc.py | 17 ++ 2 files changed, 226 insertions(+), 278 deletions(-) diff --git a/protobuf/rekcurd_pb2.py b/protobuf/rekcurd_pb2.py index 702ad59..3621297 100644 --- a/protobuf/rekcurd_pb2.py +++ b/protobuf/rekcurd_pb2.py @@ -1,3 +1,4 @@ +# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: rekcurd.proto @@ -8,7 +9,6 @@ from google.protobuf import message as _message from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf import descriptor_pb2 # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -22,7 +22,8 @@ name='rekcurd.proto', package='rekcurd.protos', syntax='proto3', - serialized_pb=_b('\n\rrekcurd.proto\x12\x0erekcurd.protos\x1a google/protobuf/descriptor.proto\x1a\x1cgoogle/protobuf/struct.proto\"%\n\x12HealthCheckRequest\x12\x0f\n\x07service\x18\x01 \x01(\t\"\x94\x01\n\x13HealthCheckResponse\x12\x41\n\x06status\x18\x01 \x01(\x0e\x32\x31.rekcurd.protos.HealthCheckResponse.ServingStatus\":\n\rServingStatus\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0b\n\x07SERVING\x10\x01\x12\x0f\n\x0bNOT_SERVING\x10\x02\"\xb9\x01\n\x0eRekcurdMessage\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12.\n\x04meta\x18\x02 \x01(\x0b\x32 .rekcurd.protos.JsonFormatString\x12)\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1b.rekcurd.protos.DefaultData\x12$\n\x05score\x18\x04 \x01(\x0b\x32\x15.rekcurd.protos.Score\"\x8f\x01\n\x06Status\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0c\n\x04info\x18\x02 \x01(\t\x12\x0e\n\x06reason\x18\x03 \x01(\t\x12\x31\n\x06status\x18\x04 \x01(\x0e\x32!.rekcurd.protos.Status.StatusFlag\"&\n\nStatusFlag\x12\x0b\n\x07SUCCESS\x10\x00\x12\x0b\n\x07\x46\x41ILURE\x10\x01\"\x1f\n\x10JsonFormatString\x12\x0b\n\x03val\x18\x01 \x01(\t\"\xdc\x01\n\x0b\x44\x65\x66\x61ultData\x12\r\n\x05names\x18\x01 \x03(\t\x12(\n\x06tensor\x18\x02 \x01(\x0b\x32\x16.rekcurd.protos.TensorH\x00\x12-\n\x07ndarray\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.ListValueH\x00\x12\x11\n\x07\x62inData\x18\x04 \x01(\x0cH\x00\x12\x11\n\x07strData\x18\x05 \x01(\tH\x00\x12\x31\n\x0bstrDataList\x18\x06 \x01(\x0b\x32\x1a.rekcurd.protos.StringListH\x00\x42\x0c\n\ndata_oneof\"$\n\x06Tensor\x12\r\n\x05shape\x18\x01 \x03(\x05\x12\x0b\n\x03val\x18\x02 \x03(\x01\"\x19\n\nStringList\x12\x0b\n\x03val\x18\x01 \x03(\t\"\x14\n\x05Score\x12\x0b\n\x03val\x18\x01 \x03(\x02\"\x14\n\x12ServiceInfoRequest\"\x81\x01\n\x13ServiceInfoResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x17\n\x0f\x61pplicationName\x18\x02 \x01(\t\x12\x13\n\x0bserviceName\x18\x03 \x01(\t\x12\x14\n\x0cserviceLevel\x18\x04 \x01(\t\"/\n\nFileStream\x12\x0f\n\x07\x62inData\x18\x01 \x01(\x0c\x12\x10\n\x08\x66ilePath\x18\x02 \x01(\t\"&\n\x12SwitchModelRequest\x12\x10\n\x08\x66ilePath\x18\x01 \x01(\t\":\n\x12\x45valuationDataPath\x12\x10\n\x08\x64\x61taPath\x18\x01 \x01(\t\x12\x12\n\nresultPath\x18\x02 \x01(\t\"\xc2\x01\n\x11\x45valuationMetrics\x12\x0b\n\x03num\x18\x01 \x01(\x05\x12\x10\n\x08\x61\x63\x63uracy\x18\x02 \x01(\x02\x12\x11\n\tprecision\x18\x03 \x03(\x02\x12\x0e\n\x06recall\x18\x04 \x03(\x02\x12\x0e\n\x06\x66value\x18\x05 \x03(\x02\x12)\n\x05label\x18\x06 \x01(\x0b\x32\x1a.rekcurd.protos.StringList\x12\x30\n\x06option\x18\x07 \x01(\x0b\x32 .rekcurd.protos.JsonFormatString\"p\n\x12\x45valuationResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x32\n\x07metrics\x18\x02 \x01(\x0b\x32!.rekcurd.protos.EvaluationMetrics\"\xdf\x02\n\x18\x45valuationResultResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x32\n\x07metrics\x18\x02 \x01(\x0b\x32!.rekcurd.protos.EvaluationMetrics\x12?\n\x06\x64\x65tail\x18\x03 \x03(\x0b\x32/.rekcurd.protos.EvaluationResultResponse.Detail\x1a\xa5\x01\n\x06\x44\x65tail\x12-\n\x05input\x18\x01 \x01(\x0b\x32\x1e.rekcurd.protos.RekcurdMessage\x12.\n\x06output\x18\x02 \x01(\x0b\x32\x1e.rekcurd.protos.RekcurdMessage\x12)\n\x05label\x18\x03 \x01(\x0b\x32\x1a.rekcurd.protos.StringList\x12\x11\n\tisCorrect\x18\x04 \x01(\x08*1\n\x0f\x45numVersionInfo\x12\x06\n\x02v0\x10\x00\x12\x06\n\x02v1\x10\x01\x12\x06\n\x02v2\x10\x02\x12\x06\n\x02v3\x10\x03\x32Z\n\x06Health\x12P\n\x05\x43heck\x12\".rekcurd.protos.HealthCheckRequest\x1a#.rekcurd.protos.HealthCheckResponse2\x91\x04\n\x10RekcurdDashboard\x12X\n\x0bServiceInfo\x12\".rekcurd.protos.ServiceInfoRequest\x1a#.rekcurd.protos.ServiceInfoResponse\"\x00\x12\x45\n\x0bUploadModel\x12\x1a.rekcurd.protos.FileStream\x1a\x16.rekcurd.protos.Status\"\x00(\x01\x12K\n\x0bSwitchModel\x12\".rekcurd.protos.SwitchModelRequest\x1a\x16.rekcurd.protos.Status\"\x00\x12N\n\x14UploadEvaluationData\x12\x1a.rekcurd.protos.FileStream\x1a\x16.rekcurd.protos.Status\"\x00(\x01\x12Y\n\rEvaluateModel\x12\".rekcurd.protos.EvaluationDataPath\x1a\".rekcurd.protos.EvaluationResponse\"\x00\x12\x64\n\x10\x45valuationResult\x12\".rekcurd.protos.EvaluationDataPath\x1a(.rekcurd.protos.EvaluationResultResponse\"\x00\x30\x01\x32\xf3\x02\n\rRekcurdWorker\x12K\n\x07Predict\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00\x12X\n\x12PredictInputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00(\x01\x12Y\n\x13PredictOutputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00\x30\x01\x12`\n\x18PredictInputOutputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00(\x01\x30\x01:B\n\x1arekcurd_grpc_proto_version\x12\x1c.google.protobuf.FileOptions\x18\xd0\x86\x03 \x01(\tB\x06\x82\xb5\x18\x02v3b\x06proto3') + serialized_options=_b('\202\265\030\002v3'), + serialized_pb=_b('\n\rrekcurd.proto\x12\x0erekcurd.protos\x1a google/protobuf/descriptor.proto\x1a\x1cgoogle/protobuf/struct.proto\"%\n\x12HealthCheckRequest\x12\x0f\n\x07service\x18\x01 \x01(\t\"\x94\x01\n\x13HealthCheckResponse\x12\x41\n\x06status\x18\x01 \x01(\x0e\x32\x31.rekcurd.protos.HealthCheckResponse.ServingStatus\":\n\rServingStatus\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0b\n\x07SERVING\x10\x01\x12\x0f\n\x0bNOT_SERVING\x10\x02\"\xaf\x01\n\x0eRekcurdMessage\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12$\n\x04meta\x18\x02 \x01(\x0b\x32\x16.google.protobuf.Value\x12)\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x1b.rekcurd.protos.DefaultData\x12$\n\x05score\x18\x04 \x01(\x0b\x32\x15.rekcurd.protos.Score\"\x8f\x01\n\x06Status\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0c\n\x04info\x18\x02 \x01(\t\x12\x0e\n\x06reason\x18\x03 \x01(\t\x12\x31\n\x06status\x18\x04 \x01(\x0e\x32!.rekcurd.protos.Status.StatusFlag\"&\n\nStatusFlag\x12\x0b\n\x07SUCCESS\x10\x00\x12\x0b\n\x07\x46\x41ILURE\x10\x01\"\xd5\x01\n\x0b\x44\x65\x66\x61ultData\x12\r\n\x05names\x18\x01 \x03(\t\x12(\n\x06tensor\x18\x02 \x01(\x0b\x32\x16.rekcurd.protos.TensorH\x00\x12-\n\x07ndarray\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.ListValueH\x00\x12\x11\n\x07\x62inData\x18\x04 \x01(\x0cH\x00\x12\x11\n\x07strData\x18\x05 \x01(\tH\x00\x12*\n\x08jsonData\x18\x06 \x01(\x0b\x32\x16.google.protobuf.ValueH\x00\x42\x0c\n\ndata_oneof\"$\n\x06Tensor\x12\r\n\x05shape\x18\x01 \x03(\x05\x12\x0b\n\x03val\x18\x02 \x03(\x01\"\x14\n\x05Score\x12\x0b\n\x03val\x18\x01 \x03(\x02\"\x14\n\x12ServiceInfoRequest\"\x81\x01\n\x13ServiceInfoResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x17\n\x0f\x61pplicationName\x18\x02 \x01(\t\x12\x13\n\x0bserviceName\x18\x03 \x01(\t\x12\x14\n\x0cserviceLevel\x18\x04 \x01(\t\"/\n\nFileStream\x12\x0f\n\x07\x62inData\x18\x01 \x01(\x0c\x12\x10\n\x08\x66ilePath\x18\x02 \x01(\t\"&\n\x12SwitchModelRequest\x12\x10\n\x08\x66ilePath\x18\x01 \x01(\t\":\n\x12\x45valuationDataPath\x12\x10\n\x08\x64\x61taPath\x18\x01 \x01(\t\x12\x12\n\nresultPath\x18\x02 \x01(\t\"\xb4\x01\n\x11\x45valuationMetrics\x12\x0b\n\x03num\x18\x01 \x01(\x05\x12\x10\n\x08\x61\x63\x63uracy\x18\x02 \x01(\x02\x12\x11\n\tprecision\x18\x03 \x03(\x02\x12\x0e\n\x06recall\x18\x04 \x03(\x02\x12\x0e\n\x06\x66value\x18\x05 \x03(\x02\x12%\n\x05label\x18\x06 \x01(\x0b\x32\x16.google.protobuf.Value\x12&\n\x06option\x18\x07 \x01(\x0b\x32\x16.google.protobuf.Value\"p\n\x12\x45valuationResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x32\n\x07metrics\x18\x02 \x01(\x0b\x32!.rekcurd.protos.EvaluationMetrics\"\xdb\x02\n\x18\x45valuationResultResponse\x12&\n\x06status\x18\x01 \x01(\x0b\x32\x16.rekcurd.protos.Status\x12\x32\n\x07metrics\x18\x02 \x01(\x0b\x32!.rekcurd.protos.EvaluationMetrics\x12?\n\x06\x64\x65tail\x18\x03 \x03(\x0b\x32/.rekcurd.protos.EvaluationResultResponse.Detail\x1a\xa1\x01\n\x06\x44\x65tail\x12-\n\x05input\x18\x01 \x01(\x0b\x32\x1e.rekcurd.protos.RekcurdMessage\x12.\n\x06output\x18\x02 \x01(\x0b\x32\x1e.rekcurd.protos.RekcurdMessage\x12%\n\x05label\x18\x03 \x01(\x0b\x32\x16.google.protobuf.Value\x12\x11\n\tisCorrect\x18\x04 \x01(\x08*1\n\x0f\x45numVersionInfo\x12\x06\n\x02v0\x10\x00\x12\x06\n\x02v1\x10\x01\x12\x06\n\x02v2\x10\x02\x12\x06\n\x02v3\x10\x03\x32\xae\x01\n\x06Health\x12P\n\x05\x43heck\x12\".rekcurd.protos.HealthCheckRequest\x1a#.rekcurd.protos.HealthCheckResponse\x12R\n\x05Watch\x12\".rekcurd.protos.HealthCheckRequest\x1a#.rekcurd.protos.HealthCheckResponse0\x01\x32\x91\x04\n\x10RekcurdDashboard\x12X\n\x0bServiceInfo\x12\".rekcurd.protos.ServiceInfoRequest\x1a#.rekcurd.protos.ServiceInfoResponse\"\x00\x12\x45\n\x0bUploadModel\x12\x1a.rekcurd.protos.FileStream\x1a\x16.rekcurd.protos.Status\"\x00(\x01\x12K\n\x0bSwitchModel\x12\".rekcurd.protos.SwitchModelRequest\x1a\x16.rekcurd.protos.Status\"\x00\x12N\n\x14UploadEvaluationData\x12\x1a.rekcurd.protos.FileStream\x1a\x16.rekcurd.protos.Status\"\x00(\x01\x12Y\n\rEvaluateModel\x12\".rekcurd.protos.EvaluationDataPath\x1a\".rekcurd.protos.EvaluationResponse\"\x00\x12\x64\n\x10\x45valuationResult\x12\".rekcurd.protos.EvaluationDataPath\x1a(.rekcurd.protos.EvaluationResultResponse\"\x00\x30\x01\x32\xf3\x02\n\rRekcurdWorker\x12K\n\x07Predict\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00\x12X\n\x12PredictInputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00(\x01\x12Y\n\x13PredictOutputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00\x30\x01\x12`\n\x18PredictInputOutputStream\x12\x1e.rekcurd.protos.RekcurdMessage\x1a\x1e.rekcurd.protos.RekcurdMessage\"\x00(\x01\x30\x01:B\n\x1arekcurd_grpc_proto_version\x12\x1c.google.protobuf.FileOptions\x18\xd0\x86\x03 \x01(\tB\x06\x82\xb5\x18\x02v3b\x06proto3') , dependencies=[google_dot_protobuf_dot_descriptor__pb2.DESCRIPTOR,google_dot_protobuf_dot_struct__pb2.DESCRIPTOR,]) @@ -34,25 +35,25 @@ values=[ _descriptor.EnumValueDescriptor( name='v0', index=0, number=0, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='v1', index=1, number=1, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='v2', index=2, number=2, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='v3', index=3, number=3, - options=None, + serialized_options=None, type=None), ], containing_type=None, - options=None, - serialized_start=1932, - serialized_end=1981, + serialized_options=None, + serialized_start=1837, + serialized_end=1886, ) _sym_db.RegisterEnumDescriptor(_ENUMVERSIONINFO) @@ -69,7 +70,7 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=True, extension_scope=None, - options=None, file=DESCRIPTOR) + serialized_options=None, file=DESCRIPTOR) _HEALTHCHECKRESPONSE_SERVINGSTATUS = _descriptor.EnumDescriptor( name='ServingStatus', @@ -79,19 +80,19 @@ values=[ _descriptor.EnumValueDescriptor( name='UNKNOWN', index=0, number=0, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='SERVING', index=1, number=1, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='NOT_SERVING', index=2, number=2, - options=None, + serialized_options=None, type=None), ], containing_type=None, - options=None, + serialized_options=None, serialized_start=227, serialized_end=285, ) @@ -105,17 +106,17 @@ values=[ _descriptor.EnumValueDescriptor( name='SUCCESS', index=0, number=0, - options=None, + serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='FAILURE', index=1, number=1, - options=None, + serialized_options=None, type=None), ], containing_type=None, - options=None, - serialized_start=581, - serialized_end=619, + serialized_options=None, + serialized_start=571, + serialized_end=609, ) _sym_db.RegisterEnumDescriptor(_STATUS_STATUSFLAG) @@ -133,14 +134,14 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], @@ -164,7 +165,7 @@ has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -172,7 +173,7 @@ enum_types=[ _HEALTHCHECKRESPONSE_SERVINGSTATUS, ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], @@ -196,42 +197,42 @@ has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='meta', full_name='rekcurd.protos.RekcurdMessage.meta', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='data', full_name='rekcurd.protos.RekcurdMessage.data', index=2, number=3, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='score', full_name='rekcurd.protos.RekcurdMessage.score', index=3, number=4, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=288, - serialized_end=473, + serialized_end=463, ) @@ -248,28 +249,28 @@ has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='info', full_name='rekcurd.protos.Status.info', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='reason', full_name='rekcurd.protos.Status.reason', index=2, number=3, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='status', full_name='rekcurd.protos.Status.status', index=3, number=4, type=14, cpp_type=8, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], @@ -277,45 +278,14 @@ enum_types=[ _STATUS_STATUSFLAG, ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=476, - serialized_end=619, -) - - -_JSONFORMATSTRING = _descriptor.Descriptor( - name='JsonFormatString', - full_name='rekcurd.protos.JsonFormatString', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='val', full_name='rekcurd.protos.JsonFormatString.val', index=0, - number=1, type=9, cpp_type=9, label=1, - has_default_value=False, default_value=_b("").decode('utf-8'), - message_type=None, enum_type=None, containing_type=None, - is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), - ], - extensions=[ - ], - nested_types=[], - enum_types=[ - ], - options=None, - is_extendable=False, - syntax='proto3', - extension_ranges=[], - oneofs=[ - ], - serialized_start=621, - serialized_end=652, + serialized_start=466, + serialized_end=609, ) @@ -332,49 +302,49 @@ has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='tensor', full_name='rekcurd.protos.DefaultData.tensor', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='ndarray', full_name='rekcurd.protos.DefaultData.ndarray', index=2, number=3, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='binData', full_name='rekcurd.protos.DefaultData.binData', index=3, number=4, type=12, cpp_type=9, label=1, has_default_value=False, default_value=_b(""), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='strData', full_name='rekcurd.protos.DefaultData.strData', index=4, number=5, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( - name='strDataList', full_name='rekcurd.protos.DefaultData.strDataList', index=5, + name='jsonData', full_name='rekcurd.protos.DefaultData.jsonData', index=5, number=6, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], @@ -383,8 +353,8 @@ name='data_oneof', full_name='rekcurd.protos.DefaultData.data_oneof', index=0, containing_type=None, fields=[]), ], - serialized_start=655, - serialized_end=875, + serialized_start=612, + serialized_end=825, ) @@ -401,59 +371,28 @@ has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='val', full_name='rekcurd.protos.Tensor.val', index=1, number=2, type=1, cpp_type=5, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), - ], - extensions=[ - ], - nested_types=[], - enum_types=[ - ], - options=None, - is_extendable=False, - syntax='proto3', - extension_ranges=[], - oneofs=[ - ], - serialized_start=877, - serialized_end=913, -) - - -_STRINGLIST = _descriptor.Descriptor( - name='StringList', - full_name='rekcurd.protos.StringList', - filename=None, - file=DESCRIPTOR, - containing_type=None, - fields=[ - _descriptor.FieldDescriptor( - name='val', full_name='rekcurd.protos.StringList.val', index=0, - number=1, type=9, cpp_type=9, label=3, - has_default_value=False, default_value=[], - message_type=None, enum_type=None, containing_type=None, - is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=915, - serialized_end=940, + serialized_start=827, + serialized_end=863, ) @@ -470,21 +409,21 @@ has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=942, - serialized_end=962, + serialized_start=865, + serialized_end=885, ) @@ -501,14 +440,14 @@ nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=964, - serialized_end=984, + serialized_start=887, + serialized_end=907, ) @@ -525,42 +464,42 @@ has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='applicationName', full_name='rekcurd.protos.ServiceInfoResponse.applicationName', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='serviceName', full_name='rekcurd.protos.ServiceInfoResponse.serviceName', index=2, number=3, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='serviceLevel', full_name='rekcurd.protos.ServiceInfoResponse.serviceLevel', index=3, number=4, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=987, - serialized_end=1116, + serialized_start=910, + serialized_end=1039, ) @@ -577,28 +516,28 @@ has_default_value=False, default_value=_b(""), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='filePath', full_name='rekcurd.protos.FileStream.filePath', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1118, - serialized_end=1165, + serialized_start=1041, + serialized_end=1088, ) @@ -615,21 +554,21 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1167, - serialized_end=1205, + serialized_start=1090, + serialized_end=1128, ) @@ -646,28 +585,28 @@ has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='resultPath', full_name='rekcurd.protos.EvaluationDataPath.resultPath', index=1, number=2, type=9, cpp_type=9, label=1, has_default_value=False, default_value=_b("").decode('utf-8'), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1207, - serialized_end=1265, + serialized_start=1130, + serialized_end=1188, ) @@ -684,63 +623,63 @@ has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='accuracy', full_name='rekcurd.protos.EvaluationMetrics.accuracy', index=1, number=2, type=2, cpp_type=6, label=1, has_default_value=False, default_value=float(0), message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='precision', full_name='rekcurd.protos.EvaluationMetrics.precision', index=2, number=3, type=2, cpp_type=6, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='recall', full_name='rekcurd.protos.EvaluationMetrics.recall', index=3, number=4, type=2, cpp_type=6, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='fvalue', full_name='rekcurd.protos.EvaluationMetrics.fvalue', index=4, number=5, type=2, cpp_type=6, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='label', full_name='rekcurd.protos.EvaluationMetrics.label', index=5, number=6, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='option', full_name='rekcurd.protos.EvaluationMetrics.option', index=6, number=7, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1268, - serialized_end=1462, + serialized_start=1191, + serialized_end=1371, ) @@ -757,28 +696,28 @@ has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='metrics', full_name='rekcurd.protos.EvaluationResponse.metrics', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1464, - serialized_end=1576, + serialized_start=1373, + serialized_end=1485, ) @@ -795,42 +734,42 @@ has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='output', full_name='rekcurd.protos.EvaluationResultResponse.Detail.output', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='label', full_name='rekcurd.protos.EvaluationResultResponse.Detail.label', index=2, number=3, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='isCorrect', full_name='rekcurd.protos.EvaluationResultResponse.Detail.isCorrect', index=3, number=4, type=8, cpp_type=7, label=1, has_default_value=False, default_value=False, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1765, - serialized_end=1930, + serialized_start=1674, + serialized_end=1835, ) _EVALUATIONRESULTRESPONSE = _descriptor.Descriptor( @@ -846,48 +785,48 @@ has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='metrics', full_name='rekcurd.protos.EvaluationResultResponse.metrics', index=1, number=2, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), _descriptor.FieldDescriptor( name='detail', full_name='rekcurd.protos.EvaluationResultResponse.detail', index=2, number=3, type=11, cpp_type=10, label=3, has_default_value=False, default_value=[], message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, - options=None, file=DESCRIPTOR), + serialized_options=None, file=DESCRIPTOR), ], extensions=[ ], nested_types=[_EVALUATIONRESULTRESPONSE_DETAIL, ], enum_types=[ ], - options=None, + serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], - serialized_start=1579, - serialized_end=1930, + serialized_start=1488, + serialized_end=1835, ) _HEALTHCHECKRESPONSE.fields_by_name['status'].enum_type = _HEALTHCHECKRESPONSE_SERVINGSTATUS _HEALTHCHECKRESPONSE_SERVINGSTATUS.containing_type = _HEALTHCHECKRESPONSE _REKCURDMESSAGE.fields_by_name['status'].message_type = _STATUS -_REKCURDMESSAGE.fields_by_name['meta'].message_type = _JSONFORMATSTRING +_REKCURDMESSAGE.fields_by_name['meta'].message_type = google_dot_protobuf_dot_struct__pb2._VALUE _REKCURDMESSAGE.fields_by_name['data'].message_type = _DEFAULTDATA _REKCURDMESSAGE.fields_by_name['score'].message_type = _SCORE _STATUS.fields_by_name['status'].enum_type = _STATUS_STATUSFLAG _STATUS_STATUSFLAG.containing_type = _STATUS _DEFAULTDATA.fields_by_name['tensor'].message_type = _TENSOR _DEFAULTDATA.fields_by_name['ndarray'].message_type = google_dot_protobuf_dot_struct__pb2._LISTVALUE -_DEFAULTDATA.fields_by_name['strDataList'].message_type = _STRINGLIST +_DEFAULTDATA.fields_by_name['jsonData'].message_type = google_dot_protobuf_dot_struct__pb2._VALUE _DEFAULTDATA.oneofs_by_name['data_oneof'].fields.append( _DEFAULTDATA.fields_by_name['tensor']) _DEFAULTDATA.fields_by_name['tensor'].containing_oneof = _DEFAULTDATA.oneofs_by_name['data_oneof'] @@ -901,16 +840,16 @@ _DEFAULTDATA.fields_by_name['strData']) _DEFAULTDATA.fields_by_name['strData'].containing_oneof = _DEFAULTDATA.oneofs_by_name['data_oneof'] _DEFAULTDATA.oneofs_by_name['data_oneof'].fields.append( - _DEFAULTDATA.fields_by_name['strDataList']) -_DEFAULTDATA.fields_by_name['strDataList'].containing_oneof = _DEFAULTDATA.oneofs_by_name['data_oneof'] + _DEFAULTDATA.fields_by_name['jsonData']) +_DEFAULTDATA.fields_by_name['jsonData'].containing_oneof = _DEFAULTDATA.oneofs_by_name['data_oneof'] _SERVICEINFORESPONSE.fields_by_name['status'].message_type = _STATUS -_EVALUATIONMETRICS.fields_by_name['label'].message_type = _STRINGLIST -_EVALUATIONMETRICS.fields_by_name['option'].message_type = _JSONFORMATSTRING +_EVALUATIONMETRICS.fields_by_name['label'].message_type = google_dot_protobuf_dot_struct__pb2._VALUE +_EVALUATIONMETRICS.fields_by_name['option'].message_type = google_dot_protobuf_dot_struct__pb2._VALUE _EVALUATIONRESPONSE.fields_by_name['status'].message_type = _STATUS _EVALUATIONRESPONSE.fields_by_name['metrics'].message_type = _EVALUATIONMETRICS _EVALUATIONRESULTRESPONSE_DETAIL.fields_by_name['input'].message_type = _REKCURDMESSAGE _EVALUATIONRESULTRESPONSE_DETAIL.fields_by_name['output'].message_type = _REKCURDMESSAGE -_EVALUATIONRESULTRESPONSE_DETAIL.fields_by_name['label'].message_type = _STRINGLIST +_EVALUATIONRESULTRESPONSE_DETAIL.fields_by_name['label'].message_type = google_dot_protobuf_dot_struct__pb2._VALUE _EVALUATIONRESULTRESPONSE_DETAIL.containing_type = _EVALUATIONRESULTRESPONSE _EVALUATIONRESULTRESPONSE.fields_by_name['status'].message_type = _STATUS _EVALUATIONRESULTRESPONSE.fields_by_name['metrics'].message_type = _EVALUATIONMETRICS @@ -919,10 +858,8 @@ DESCRIPTOR.message_types_by_name['HealthCheckResponse'] = _HEALTHCHECKRESPONSE DESCRIPTOR.message_types_by_name['RekcurdMessage'] = _REKCURDMESSAGE DESCRIPTOR.message_types_by_name['Status'] = _STATUS -DESCRIPTOR.message_types_by_name['JsonFormatString'] = _JSONFORMATSTRING DESCRIPTOR.message_types_by_name['DefaultData'] = _DEFAULTDATA DESCRIPTOR.message_types_by_name['Tensor'] = _TENSOR -DESCRIPTOR.message_types_by_name['StringList'] = _STRINGLIST DESCRIPTOR.message_types_by_name['Score'] = _SCORE DESCRIPTOR.message_types_by_name['ServiceInfoRequest'] = _SERVICEINFOREQUEST DESCRIPTOR.message_types_by_name['ServiceInfoResponse'] = _SERVICEINFORESPONSE @@ -936,146 +873,131 @@ DESCRIPTOR.extensions_by_name['rekcurd_grpc_proto_version'] = rekcurd_grpc_proto_version _sym_db.RegisterFileDescriptor(DESCRIPTOR) -HealthCheckRequest = _reflection.GeneratedProtocolMessageType('HealthCheckRequest', (_message.Message,), dict( - DESCRIPTOR = _HEALTHCHECKREQUEST, - __module__ = 'rekcurd_pb2' +HealthCheckRequest = _reflection.GeneratedProtocolMessageType('HealthCheckRequest', (_message.Message,), { + 'DESCRIPTOR' : _HEALTHCHECKREQUEST, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.HealthCheckRequest) - )) + }) _sym_db.RegisterMessage(HealthCheckRequest) -HealthCheckResponse = _reflection.GeneratedProtocolMessageType('HealthCheckResponse', (_message.Message,), dict( - DESCRIPTOR = _HEALTHCHECKRESPONSE, - __module__ = 'rekcurd_pb2' +HealthCheckResponse = _reflection.GeneratedProtocolMessageType('HealthCheckResponse', (_message.Message,), { + 'DESCRIPTOR' : _HEALTHCHECKRESPONSE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.HealthCheckResponse) - )) + }) _sym_db.RegisterMessage(HealthCheckResponse) -RekcurdMessage = _reflection.GeneratedProtocolMessageType('RekcurdMessage', (_message.Message,), dict( - DESCRIPTOR = _REKCURDMESSAGE, - __module__ = 'rekcurd_pb2' +RekcurdMessage = _reflection.GeneratedProtocolMessageType('RekcurdMessage', (_message.Message,), { + 'DESCRIPTOR' : _REKCURDMESSAGE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.RekcurdMessage) - )) + }) _sym_db.RegisterMessage(RekcurdMessage) -Status = _reflection.GeneratedProtocolMessageType('Status', (_message.Message,), dict( - DESCRIPTOR = _STATUS, - __module__ = 'rekcurd_pb2' +Status = _reflection.GeneratedProtocolMessageType('Status', (_message.Message,), { + 'DESCRIPTOR' : _STATUS, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.Status) - )) + }) _sym_db.RegisterMessage(Status) -JsonFormatString = _reflection.GeneratedProtocolMessageType('JsonFormatString', (_message.Message,), dict( - DESCRIPTOR = _JSONFORMATSTRING, - __module__ = 'rekcurd_pb2' - # @@protoc_insertion_point(class_scope:rekcurd.protos.JsonFormatString) - )) -_sym_db.RegisterMessage(JsonFormatString) - -DefaultData = _reflection.GeneratedProtocolMessageType('DefaultData', (_message.Message,), dict( - DESCRIPTOR = _DEFAULTDATA, - __module__ = 'rekcurd_pb2' +DefaultData = _reflection.GeneratedProtocolMessageType('DefaultData', (_message.Message,), { + 'DESCRIPTOR' : _DEFAULTDATA, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.DefaultData) - )) + }) _sym_db.RegisterMessage(DefaultData) -Tensor = _reflection.GeneratedProtocolMessageType('Tensor', (_message.Message,), dict( - DESCRIPTOR = _TENSOR, - __module__ = 'rekcurd_pb2' +Tensor = _reflection.GeneratedProtocolMessageType('Tensor', (_message.Message,), { + 'DESCRIPTOR' : _TENSOR, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.Tensor) - )) + }) _sym_db.RegisterMessage(Tensor) -StringList = _reflection.GeneratedProtocolMessageType('StringList', (_message.Message,), dict( - DESCRIPTOR = _STRINGLIST, - __module__ = 'rekcurd_pb2' - # @@protoc_insertion_point(class_scope:rekcurd.protos.StringList) - )) -_sym_db.RegisterMessage(StringList) - -Score = _reflection.GeneratedProtocolMessageType('Score', (_message.Message,), dict( - DESCRIPTOR = _SCORE, - __module__ = 'rekcurd_pb2' +Score = _reflection.GeneratedProtocolMessageType('Score', (_message.Message,), { + 'DESCRIPTOR' : _SCORE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.Score) - )) + }) _sym_db.RegisterMessage(Score) -ServiceInfoRequest = _reflection.GeneratedProtocolMessageType('ServiceInfoRequest', (_message.Message,), dict( - DESCRIPTOR = _SERVICEINFOREQUEST, - __module__ = 'rekcurd_pb2' +ServiceInfoRequest = _reflection.GeneratedProtocolMessageType('ServiceInfoRequest', (_message.Message,), { + 'DESCRIPTOR' : _SERVICEINFOREQUEST, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.ServiceInfoRequest) - )) + }) _sym_db.RegisterMessage(ServiceInfoRequest) -ServiceInfoResponse = _reflection.GeneratedProtocolMessageType('ServiceInfoResponse', (_message.Message,), dict( - DESCRIPTOR = _SERVICEINFORESPONSE, - __module__ = 'rekcurd_pb2' +ServiceInfoResponse = _reflection.GeneratedProtocolMessageType('ServiceInfoResponse', (_message.Message,), { + 'DESCRIPTOR' : _SERVICEINFORESPONSE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.ServiceInfoResponse) - )) + }) _sym_db.RegisterMessage(ServiceInfoResponse) -FileStream = _reflection.GeneratedProtocolMessageType('FileStream', (_message.Message,), dict( - DESCRIPTOR = _FILESTREAM, - __module__ = 'rekcurd_pb2' +FileStream = _reflection.GeneratedProtocolMessageType('FileStream', (_message.Message,), { + 'DESCRIPTOR' : _FILESTREAM, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.FileStream) - )) + }) _sym_db.RegisterMessage(FileStream) -SwitchModelRequest = _reflection.GeneratedProtocolMessageType('SwitchModelRequest', (_message.Message,), dict( - DESCRIPTOR = _SWITCHMODELREQUEST, - __module__ = 'rekcurd_pb2' +SwitchModelRequest = _reflection.GeneratedProtocolMessageType('SwitchModelRequest', (_message.Message,), { + 'DESCRIPTOR' : _SWITCHMODELREQUEST, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.SwitchModelRequest) - )) + }) _sym_db.RegisterMessage(SwitchModelRequest) -EvaluationDataPath = _reflection.GeneratedProtocolMessageType('EvaluationDataPath', (_message.Message,), dict( - DESCRIPTOR = _EVALUATIONDATAPATH, - __module__ = 'rekcurd_pb2' +EvaluationDataPath = _reflection.GeneratedProtocolMessageType('EvaluationDataPath', (_message.Message,), { + 'DESCRIPTOR' : _EVALUATIONDATAPATH, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.EvaluationDataPath) - )) + }) _sym_db.RegisterMessage(EvaluationDataPath) -EvaluationMetrics = _reflection.GeneratedProtocolMessageType('EvaluationMetrics', (_message.Message,), dict( - DESCRIPTOR = _EVALUATIONMETRICS, - __module__ = 'rekcurd_pb2' +EvaluationMetrics = _reflection.GeneratedProtocolMessageType('EvaluationMetrics', (_message.Message,), { + 'DESCRIPTOR' : _EVALUATIONMETRICS, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.EvaluationMetrics) - )) + }) _sym_db.RegisterMessage(EvaluationMetrics) -EvaluationResponse = _reflection.GeneratedProtocolMessageType('EvaluationResponse', (_message.Message,), dict( - DESCRIPTOR = _EVALUATIONRESPONSE, - __module__ = 'rekcurd_pb2' +EvaluationResponse = _reflection.GeneratedProtocolMessageType('EvaluationResponse', (_message.Message,), { + 'DESCRIPTOR' : _EVALUATIONRESPONSE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.EvaluationResponse) - )) + }) _sym_db.RegisterMessage(EvaluationResponse) -EvaluationResultResponse = _reflection.GeneratedProtocolMessageType('EvaluationResultResponse', (_message.Message,), dict( +EvaluationResultResponse = _reflection.GeneratedProtocolMessageType('EvaluationResultResponse', (_message.Message,), { - Detail = _reflection.GeneratedProtocolMessageType('Detail', (_message.Message,), dict( - DESCRIPTOR = _EVALUATIONRESULTRESPONSE_DETAIL, - __module__ = 'rekcurd_pb2' + 'Detail' : _reflection.GeneratedProtocolMessageType('Detail', (_message.Message,), { + 'DESCRIPTOR' : _EVALUATIONRESULTRESPONSE_DETAIL, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.EvaluationResultResponse.Detail) - )) + }) , - DESCRIPTOR = _EVALUATIONRESULTRESPONSE, - __module__ = 'rekcurd_pb2' + 'DESCRIPTOR' : _EVALUATIONRESULTRESPONSE, + '__module__' : 'rekcurd_pb2' # @@protoc_insertion_point(class_scope:rekcurd.protos.EvaluationResultResponse) - )) + }) _sym_db.RegisterMessage(EvaluationResultResponse) _sym_db.RegisterMessage(EvaluationResultResponse.Detail) google_dot_protobuf_dot_descriptor__pb2.FileOptions.RegisterExtension(rekcurd_grpc_proto_version) -DESCRIPTOR.has_options = True -DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\202\265\030\002v3')) +DESCRIPTOR._options = None _HEALTH = _descriptor.ServiceDescriptor( name='Health', full_name='rekcurd.protos.Health', file=DESCRIPTOR, index=0, - options=None, - serialized_start=1983, - serialized_end=2073, + serialized_options=None, + serialized_start=1889, + serialized_end=2063, methods=[ _descriptor.MethodDescriptor( name='Check', @@ -1084,7 +1006,16 @@ containing_service=None, input_type=_HEALTHCHECKREQUEST, output_type=_HEALTHCHECKRESPONSE, - options=None, + serialized_options=None, + ), + _descriptor.MethodDescriptor( + name='Watch', + full_name='rekcurd.protos.Health.Watch', + index=1, + containing_service=None, + input_type=_HEALTHCHECKREQUEST, + output_type=_HEALTHCHECKRESPONSE, + serialized_options=None, ), ]) _sym_db.RegisterServiceDescriptor(_HEALTH) @@ -1097,9 +1028,9 @@ full_name='rekcurd.protos.RekcurdDashboard', file=DESCRIPTOR, index=1, - options=None, - serialized_start=2076, - serialized_end=2605, + serialized_options=None, + serialized_start=2066, + serialized_end=2595, methods=[ _descriptor.MethodDescriptor( name='ServiceInfo', @@ -1108,7 +1039,7 @@ containing_service=None, input_type=_SERVICEINFOREQUEST, output_type=_SERVICEINFORESPONSE, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='UploadModel', @@ -1117,7 +1048,7 @@ containing_service=None, input_type=_FILESTREAM, output_type=_STATUS, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='SwitchModel', @@ -1126,7 +1057,7 @@ containing_service=None, input_type=_SWITCHMODELREQUEST, output_type=_STATUS, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='UploadEvaluationData', @@ -1135,7 +1066,7 @@ containing_service=None, input_type=_FILESTREAM, output_type=_STATUS, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='EvaluateModel', @@ -1144,7 +1075,7 @@ containing_service=None, input_type=_EVALUATIONDATAPATH, output_type=_EVALUATIONRESPONSE, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='EvaluationResult', @@ -1153,7 +1084,7 @@ containing_service=None, input_type=_EVALUATIONDATAPATH, output_type=_EVALUATIONRESULTRESPONSE, - options=None, + serialized_options=None, ), ]) _sym_db.RegisterServiceDescriptor(_REKCURDDASHBOARD) @@ -1166,9 +1097,9 @@ full_name='rekcurd.protos.RekcurdWorker', file=DESCRIPTOR, index=2, - options=None, - serialized_start=2608, - serialized_end=2979, + serialized_options=None, + serialized_start=2598, + serialized_end=2969, methods=[ _descriptor.MethodDescriptor( name='Predict', @@ -1177,7 +1108,7 @@ containing_service=None, input_type=_REKCURDMESSAGE, output_type=_REKCURDMESSAGE, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='PredictInputStream', @@ -1186,7 +1117,7 @@ containing_service=None, input_type=_REKCURDMESSAGE, output_type=_REKCURDMESSAGE, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='PredictOutputStream', @@ -1195,7 +1126,7 @@ containing_service=None, input_type=_REKCURDMESSAGE, output_type=_REKCURDMESSAGE, - options=None, + serialized_options=None, ), _descriptor.MethodDescriptor( name='PredictInputOutputStream', @@ -1204,7 +1135,7 @@ containing_service=None, input_type=_REKCURDMESSAGE, output_type=_REKCURDMESSAGE, - options=None, + serialized_options=None, ), ]) _sym_db.RegisterServiceDescriptor(_REKCURDWORKER) diff --git a/protobuf/rekcurd_pb2_grpc.py b/protobuf/rekcurd_pb2_grpc.py index f1e76e2..f00b6fa 100644 --- a/protobuf/rekcurd_pb2_grpc.py +++ b/protobuf/rekcurd_pb2_grpc.py @@ -20,6 +20,11 @@ def __init__(self, channel): request_serializer=rekcurd__pb2.HealthCheckRequest.SerializeToString, response_deserializer=rekcurd__pb2.HealthCheckResponse.FromString, ) + self.Watch = channel.unary_stream( + '/rekcurd.protos.Health/Watch', + request_serializer=rekcurd__pb2.HealthCheckRequest.SerializeToString, + response_deserializer=rekcurd__pb2.HealthCheckResponse.FromString, + ) class HealthServicer(object): @@ -34,6 +39,13 @@ def Check(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def Watch(self, request, context): + # missing associated documentation comment in .proto file + pass + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def add_HealthServicer_to_server(servicer, server): rpc_method_handlers = { @@ -42,6 +54,11 @@ def add_HealthServicer_to_server(servicer, server): request_deserializer=rekcurd__pb2.HealthCheckRequest.FromString, response_serializer=rekcurd__pb2.HealthCheckResponse.SerializeToString, ), + 'Watch': grpc.unary_stream_rpc_method_handler( + servicer.Watch, + request_deserializer=rekcurd__pb2.HealthCheckRequest.FromString, + response_serializer=rekcurd__pb2.HealthCheckResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'rekcurd.protos.Health', rpc_method_handlers)