Skip to content
Snippets Groups Projects
Verified Commit 28c62562 authored by Timm Fitschen's avatar Timm Fitschen
Browse files

REMOVE python prototype client

parent e0509a08
No related branches found
No related tags found
2 merge requests!44Release 0.6,!43Merge f-GRPC-main to dev
Pipeline #15920 passed
../../proto/EntityService.proto
\ No newline at end of file
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: EntityService.proto
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
DESCRIPTOR = _descriptor.FileDescriptor(
name='EntityService.proto',
package='org.caosdb.grpc',
syntax='proto3',
serialized_options=b'P\001',
create_key=_descriptor._internal_create_key,
serialized_pb=b'\n\x13\x45ntityService.proto\x12\x0forg.caosdb.grpc\"8\n\x06\x45ntity\x12\x0b\n\x03\x65id\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x13\n\x0b\x64\x65scription\x18\x03 \x01(\t2X\n\x18\x45ntityTransactionService\x12<\n\x08retrieve\x12\x17.org.caosdb.grpc.Entity\x1a\x17.org.caosdb.grpc.EntityB\x02P\x01\x62\x06proto3'
)
_ENTITY = _descriptor.Descriptor(
name='Entity',
full_name='org.caosdb.grpc.Entity',
filename=None,
file=DESCRIPTOR,
containing_type=None,
create_key=_descriptor._internal_create_key,
fields=[
_descriptor.FieldDescriptor(
name='eid', full_name='org.caosdb.grpc.Entity.eid', 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,
serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key),
_descriptor.FieldDescriptor(
name='name', full_name='org.caosdb.grpc.Entity.name', 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,
serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key),
_descriptor.FieldDescriptor(
name='description', full_name='org.caosdb.grpc.Entity.description', 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,
serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=40,
serialized_end=96,
)
DESCRIPTOR.message_types_by_name['Entity'] = _ENTITY
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
Entity = _reflection.GeneratedProtocolMessageType('Entity', (_message.Message,), {
'DESCRIPTOR' : _ENTITY,
'__module__' : 'EntityService_pb2'
# @@protoc_insertion_point(class_scope:org.caosdb.grpc.Entity)
})
_sym_db.RegisterMessage(Entity)
DESCRIPTOR._options = None
_ENTITYTRANSACTIONSERVICE = _descriptor.ServiceDescriptor(
name='EntityTransactionService',
full_name='org.caosdb.grpc.EntityTransactionService',
file=DESCRIPTOR,
index=0,
serialized_options=None,
create_key=_descriptor._internal_create_key,
serialized_start=98,
serialized_end=186,
methods=[
_descriptor.MethodDescriptor(
name='retrieve',
full_name='org.caosdb.grpc.EntityTransactionService.retrieve',
index=0,
containing_service=None,
input_type=_ENTITY,
output_type=_ENTITY,
serialized_options=None,
create_key=_descriptor._internal_create_key,
),
])
_sym_db.RegisterServiceDescriptor(_ENTITYTRANSACTIONSERVICE)
DESCRIPTOR.services_by_name['EntityTransactionService'] = _ENTITYTRANSACTIONSERVICE
# @@protoc_insertion_point(module_scope)
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import EntityService_pb2 as EntityService__pb2
class EntityTransactionServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.retrieve = channel.unary_unary(
'/org.caosdb.grpc.EntityTransactionService/retrieve',
request_serializer=EntityService__pb2.Entity.SerializeToString,
response_deserializer=EntityService__pb2.Entity.FromString,
)
class EntityTransactionServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
def retrieve(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_EntityTransactionServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'retrieve': grpc.unary_unary_rpc_method_handler(
servicer.retrieve,
request_deserializer=EntityService__pb2.Entity.FromString,
response_serializer=EntityService__pb2.Entity.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.caosdb.grpc.EntityTransactionService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class EntityTransactionService(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def retrieve(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/org.caosdb.grpc.EntityTransactionService/retrieve',
EntityService__pb2.Entity.SerializeToString,
EntityService__pb2.Entity.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
import grpc
import EntityService_pb2_grpc as pb2_grpc
import EntityService_pb2 as pb2
class Client():
def __init__(self):
self.host = 'localhost'
self.port = 8080
# instantiate a channel
self.channel = grpc.insecure_channel(f'{self.host}:{self.port}')
# bind the client and the server
self.stub = pb2_grpc.EntityTransactionServiceStub(self.channel)
def get(self, entity_id):
message = pb2.Entity(eid=entity_id)
print(f'{message}')
return self.stub.retrieve(message)
if __name__ == '__main__':
client = Client()
result = client.get("25")
print(f'{result}')
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment