Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 1 | # Generated by the protocol buffer compiler. DO NOT EDIT! |
| 2 | # source: schema.proto |
| 3 | |
| 4 | import sys |
| 5 | _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) |
| 6 | from google.protobuf import descriptor as _descriptor |
| 7 | from google.protobuf import message as _message |
| 8 | from google.protobuf import reflection as _reflection |
| 9 | from google.protobuf import symbol_database as _symbol_database |
| 10 | from google.protobuf import descriptor_pb2 |
| 11 | # @@protoc_insertion_point(imports) |
| 12 | |
| 13 | _sym_db = _symbol_database.Default() |
| 14 | |
| 15 | |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 16 | from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 17 | |
| 18 | |
| 19 | DESCRIPTOR = _descriptor.FileDescriptor( |
| 20 | name='schema.proto', |
| 21 | package='schema', |
| 22 | syntax='proto3', |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 23 | serialized_pb=_b('\n\x0cschema.proto\x12\x06schema\x1a\x1bgoogle/protobuf/empty.proto\"A\n\tProtoFile\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\r\n\x05proto\x18\x02 \x01(\t\x12\x12\n\ndescriptor\x18\x03 \x01(\x0c\",\n\x07Schemas\x12!\n\x06protos\x18\x01 \x03(\x0b\x32\x11.schema.ProtoFile2G\n\rSchemaService\x12\x36\n\tGetSchema\x12\x16.google.protobuf.Empty\x1a\x0f.schema.Schemas\"\x00\x62\x06proto3') |
| 24 | , |
| 25 | dependencies=[google_dot_protobuf_dot_empty__pb2.DESCRIPTOR,]) |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 26 | _sym_db.RegisterFileDescriptor(DESCRIPTOR) |
| 27 | |
| 28 | |
| 29 | |
| 30 | |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 31 | _PROTOFILE = _descriptor.Descriptor( |
| 32 | name='ProtoFile', |
| 33 | full_name='schema.ProtoFile', |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 34 | filename=None, |
| 35 | file=DESCRIPTOR, |
| 36 | containing_type=None, |
| 37 | fields=[ |
| 38 | _descriptor.FieldDescriptor( |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 39 | name='file_name', full_name='schema.ProtoFile.file_name', index=0, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 40 | number=1, type=9, cpp_type=9, label=1, |
| 41 | has_default_value=False, default_value=_b("").decode('utf-8'), |
| 42 | message_type=None, enum_type=None, containing_type=None, |
| 43 | is_extension=False, extension_scope=None, |
| 44 | options=None), |
| 45 | _descriptor.FieldDescriptor( |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 46 | name='proto', full_name='schema.ProtoFile.proto', index=1, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 47 | number=2, type=9, cpp_type=9, label=1, |
| 48 | has_default_value=False, default_value=_b("").decode('utf-8'), |
| 49 | message_type=None, enum_type=None, containing_type=None, |
| 50 | is_extension=False, extension_scope=None, |
| 51 | options=None), |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 52 | _descriptor.FieldDescriptor( |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 53 | name='descriptor', full_name='schema.ProtoFile.descriptor', index=2, |
| 54 | number=3, type=12, cpp_type=9, label=1, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 55 | has_default_value=False, default_value=_b(""), |
| 56 | message_type=None, enum_type=None, containing_type=None, |
| 57 | is_extension=False, extension_scope=None, |
| 58 | options=None), |
| 59 | ], |
| 60 | extensions=[ |
| 61 | ], |
| 62 | nested_types=[], |
| 63 | enum_types=[ |
| 64 | ], |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 65 | options=None, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 66 | is_extendable=False, |
| 67 | syntax='proto3', |
| 68 | extension_ranges=[], |
| 69 | oneofs=[ |
| 70 | ], |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 71 | serialized_start=53, |
| 72 | serialized_end=118, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 73 | ) |
| 74 | |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 75 | |
| 76 | _SCHEMAS = _descriptor.Descriptor( |
| 77 | name='Schemas', |
| 78 | full_name='schema.Schemas', |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 79 | filename=None, |
| 80 | file=DESCRIPTOR, |
| 81 | containing_type=None, |
| 82 | fields=[ |
| 83 | _descriptor.FieldDescriptor( |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 84 | name='protos', full_name='schema.Schemas.protos', index=0, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 85 | number=1, type=11, cpp_type=10, label=3, |
| 86 | has_default_value=False, default_value=[], |
| 87 | message_type=None, enum_type=None, containing_type=None, |
| 88 | is_extension=False, extension_scope=None, |
| 89 | options=None), |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 90 | ], |
| 91 | extensions=[ |
| 92 | ], |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 93 | nested_types=[], |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 94 | enum_types=[ |
| 95 | ], |
| 96 | options=None, |
| 97 | is_extendable=False, |
| 98 | syntax='proto3', |
| 99 | extension_ranges=[], |
| 100 | oneofs=[ |
| 101 | ], |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 102 | serialized_start=120, |
| 103 | serialized_end=164, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 104 | ) |
| 105 | |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 106 | _SCHEMAS.fields_by_name['protos'].message_type = _PROTOFILE |
| 107 | DESCRIPTOR.message_types_by_name['ProtoFile'] = _PROTOFILE |
| 108 | DESCRIPTOR.message_types_by_name['Schemas'] = _SCHEMAS |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 109 | |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 110 | ProtoFile = _reflection.GeneratedProtocolMessageType('ProtoFile', (_message.Message,), dict( |
| 111 | DESCRIPTOR = _PROTOFILE, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 112 | __module__ = 'schema_pb2' |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 113 | # @@protoc_insertion_point(class_scope:schema.ProtoFile) |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 114 | )) |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 115 | _sym_db.RegisterMessage(ProtoFile) |
| 116 | |
| 117 | Schemas = _reflection.GeneratedProtocolMessageType('Schemas', (_message.Message,), dict( |
| 118 | DESCRIPTOR = _SCHEMAS, |
| 119 | __module__ = 'schema_pb2' |
| 120 | # @@protoc_insertion_point(class_scope:schema.Schemas) |
| 121 | )) |
| 122 | _sym_db.RegisterMessage(Schemas) |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 123 | |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 124 | |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 125 | import grpc |
| 126 | from grpc.beta import implementations as beta_implementations |
| 127 | from grpc.beta import interfaces as beta_interfaces |
| 128 | from grpc.framework.common import cardinality |
| 129 | from grpc.framework.interfaces.face import utilities as face_utilities |
| 130 | |
| 131 | |
| 132 | class SchemaServiceStub(object): |
| 133 | """Schema services |
| 134 | """ |
| 135 | |
| 136 | def __init__(self, channel): |
| 137 | """Constructor. |
| 138 | |
| 139 | Args: |
| 140 | channel: A grpc.Channel. |
| 141 | """ |
| 142 | self.GetSchema = channel.unary_unary( |
| 143 | '/schema.SchemaService/GetSchema', |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 144 | request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 145 | response_deserializer=Schemas.FromString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 146 | ) |
| 147 | |
| 148 | |
| 149 | class SchemaServiceServicer(object): |
| 150 | """Schema services |
| 151 | """ |
| 152 | |
| 153 | def GetSchema(self, request, context): |
| 154 | """Return active grpc schemas |
| 155 | """ |
| 156 | context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
| 157 | context.set_details('Method not implemented!') |
| 158 | raise NotImplementedError('Method not implemented!') |
| 159 | |
| 160 | |
| 161 | def add_SchemaServiceServicer_to_server(servicer, server): |
| 162 | rpc_method_handlers = { |
| 163 | 'GetSchema': grpc.unary_unary_rpc_method_handler( |
| 164 | servicer.GetSchema, |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 165 | request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 166 | response_serializer=Schemas.SerializeToString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 167 | ), |
| 168 | } |
| 169 | generic_handler = grpc.method_handlers_generic_handler( |
| 170 | 'schema.SchemaService', rpc_method_handlers) |
| 171 | server.add_generic_rpc_handlers((generic_handler,)) |
| 172 | |
| 173 | |
| 174 | class BetaSchemaServiceServicer(object): |
| 175 | """Schema services |
| 176 | """ |
| 177 | def GetSchema(self, request, context): |
| 178 | """Return active grpc schemas |
| 179 | """ |
| 180 | context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) |
| 181 | |
| 182 | |
| 183 | class BetaSchemaServiceStub(object): |
| 184 | """Schema services |
| 185 | """ |
| 186 | def GetSchema(self, request, timeout, metadata=None, with_call=False, protocol_options=None): |
| 187 | """Return active grpc schemas |
| 188 | """ |
| 189 | raise NotImplementedError() |
| 190 | GetSchema.future = None |
| 191 | |
| 192 | |
| 193 | def beta_create_SchemaService_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None): |
| 194 | request_deserializers = { |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 195 | ('schema.SchemaService', 'GetSchema'): google_dot_protobuf_dot_empty__pb2.Empty.FromString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 196 | } |
| 197 | response_serializers = { |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 198 | ('schema.SchemaService', 'GetSchema'): Schemas.SerializeToString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 199 | } |
| 200 | method_implementations = { |
| 201 | ('schema.SchemaService', 'GetSchema'): face_utilities.unary_unary_inline(servicer.GetSchema), |
| 202 | } |
| 203 | server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout) |
| 204 | return beta_implementations.server(method_implementations, options=server_options) |
| 205 | |
| 206 | |
| 207 | def beta_create_SchemaService_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None): |
| 208 | request_serializers = { |
Zsolt Haraszti | 7eeb2b3 | 2016-11-06 14:04:55 -0800 | [diff] [blame] | 209 | ('schema.SchemaService', 'GetSchema'): google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 210 | } |
| 211 | response_deserializers = { |
Zsolt Haraszti | 2bdb6b3 | 2016-11-03 16:56:17 -0700 | [diff] [blame] | 212 | ('schema.SchemaService', 'GetSchema'): Schemas.FromString, |
Zsolt Haraszti | 034db37 | 2016-10-03 22:26:41 -0700 | [diff] [blame] | 213 | } |
| 214 | cardinalities = { |
| 215 | 'GetSchema': cardinality.Cardinality.UNARY_UNARY, |
| 216 | } |
| 217 | stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size) |
| 218 | return beta_implementations.dynamic_stub(channel, 'schema.SchemaService', cardinalities, options=stub_options) |
| 219 | # @@protoc_insertion_point(module_scope) |