Changeset View
Changeset View
Standalone View
Standalone View
swh/graph/grpc/swhgraph_pb2_grpc.py
- This file was moved from swh/graph/rpc/swhgraph_pb2_grpc.py.
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! | # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! | ||||
"""Client and server classes corresponding to protobuf-defined services.""" | """Client and server classes corresponding to protobuf-defined services.""" | ||||
import grpc | import grpc | ||||
from swh.graph.rpc import swhgraph_pb2 as swh_dot_graph_dot_rpc_dot_swhgraph__pb2 | from swh.graph.grpc import swhgraph_pb2 as swh_dot_graph_dot_grpc_dot_swhgraph__pb2 | ||||
class TraversalServiceStub(object): | class TraversalServiceStub(object): | ||||
"""Graph traversal service | """Graph traversal service | ||||
""" | """ | ||||
def __init__(self, channel): | def __init__(self, channel): | ||||
"""Constructor. | """Constructor. | ||||
Args: | Args: | ||||
channel: A grpc.Channel. | channel: A grpc.Channel. | ||||
""" | """ | ||||
self.GetNode = channel.unary_unary( | self.GetNode = channel.unary_unary( | ||||
'/swh.graph.TraversalService/GetNode', | '/swh.graph.TraversalService/GetNode', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.GetNodeRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.GetNodeRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.FromString, | ||||
) | ) | ||||
self.Traverse = channel.unary_stream( | self.Traverse = channel.unary_stream( | ||||
'/swh.graph.TraversalService/Traverse', | '/swh.graph.TraversalService/Traverse', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.FromString, | ||||
) | ) | ||||
self.FindPathTo = channel.unary_unary( | self.FindPathTo = channel.unary_unary( | ||||
'/swh.graph.TraversalService/FindPathTo', | '/swh.graph.TraversalService/FindPathTo', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathToRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathToRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.FromString, | ||||
) | ) | ||||
self.FindPathBetween = channel.unary_unary( | self.FindPathBetween = channel.unary_unary( | ||||
'/swh.graph.TraversalService/FindPathBetween', | '/swh.graph.TraversalService/FindPathBetween', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathBetweenRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathBetweenRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.FromString, | ||||
) | ) | ||||
self.CountNodes = channel.unary_unary( | self.CountNodes = channel.unary_unary( | ||||
'/swh.graph.TraversalService/CountNodes', | '/swh.graph.TraversalService/CountNodes', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.FromString, | ||||
) | ) | ||||
self.CountEdges = channel.unary_unary( | self.CountEdges = channel.unary_unary( | ||||
'/swh.graph.TraversalService/CountEdges', | '/swh.graph.TraversalService/CountEdges', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.FromString, | ||||
) | ) | ||||
self.Stats = channel.unary_unary( | self.Stats = channel.unary_unary( | ||||
'/swh.graph.TraversalService/Stats', | '/swh.graph.TraversalService/Stats', | ||||
request_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsRequest.SerializeToString, | request_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsRequest.SerializeToString, | ||||
response_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsResponse.FromString, | response_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsResponse.FromString, | ||||
) | ) | ||||
class TraversalServiceServicer(object): | class TraversalServiceServicer(object): | ||||
"""Graph traversal service | """Graph traversal service | ||||
""" | """ | ||||
def GetNode(self, request, context): | def GetNode(self, request, context): | ||||
▲ Show 20 Lines • Show All 74 Lines • ▼ Show 20 Lines | def Stats(self, request, context): | ||||
context.set_details('Method not implemented!') | context.set_details('Method not implemented!') | ||||
raise NotImplementedError('Method not implemented!') | raise NotImplementedError('Method not implemented!') | ||||
def add_TraversalServiceServicer_to_server(servicer, server): | def add_TraversalServiceServicer_to_server(servicer, server): | ||||
rpc_method_handlers = { | rpc_method_handlers = { | ||||
'GetNode': grpc.unary_unary_rpc_method_handler( | 'GetNode': grpc.unary_unary_rpc_method_handler( | ||||
servicer.GetNode, | servicer.GetNode, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.GetNodeRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.GetNodeRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.SerializeToString, | ||||
), | ), | ||||
'Traverse': grpc.unary_stream_rpc_method_handler( | 'Traverse': grpc.unary_stream_rpc_method_handler( | ||||
servicer.Traverse, | servicer.Traverse, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.SerializeToString, | ||||
), | ), | ||||
'FindPathTo': grpc.unary_unary_rpc_method_handler( | 'FindPathTo': grpc.unary_unary_rpc_method_handler( | ||||
servicer.FindPathTo, | servicer.FindPathTo, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathToRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathToRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.SerializeToString, | ||||
), | ), | ||||
'FindPathBetween': grpc.unary_unary_rpc_method_handler( | 'FindPathBetween': grpc.unary_unary_rpc_method_handler( | ||||
servicer.FindPathBetween, | servicer.FindPathBetween, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathBetweenRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathBetweenRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.SerializeToString, | ||||
), | ), | ||||
'CountNodes': grpc.unary_unary_rpc_method_handler( | 'CountNodes': grpc.unary_unary_rpc_method_handler( | ||||
servicer.CountNodes, | servicer.CountNodes, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.SerializeToString, | ||||
), | ), | ||||
'CountEdges': grpc.unary_unary_rpc_method_handler( | 'CountEdges': grpc.unary_unary_rpc_method_handler( | ||||
servicer.CountEdges, | servicer.CountEdges, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.SerializeToString, | ||||
), | ), | ||||
'Stats': grpc.unary_unary_rpc_method_handler( | 'Stats': grpc.unary_unary_rpc_method_handler( | ||||
servicer.Stats, | servicer.Stats, | ||||
request_deserializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsRequest.FromString, | request_deserializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsRequest.FromString, | ||||
response_serializer=swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsResponse.SerializeToString, | response_serializer=swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsResponse.SerializeToString, | ||||
), | ), | ||||
} | } | ||||
generic_handler = grpc.method_handlers_generic_handler( | generic_handler = grpc.method_handlers_generic_handler( | ||||
'swh.graph.TraversalService', rpc_method_handlers) | 'swh.graph.TraversalService', rpc_method_handlers) | ||||
server.add_generic_rpc_handlers((generic_handler,)) | server.add_generic_rpc_handlers((generic_handler,)) | ||||
# This class is part of an EXPERIMENTAL API. | # This class is part of an EXPERIMENTAL API. | ||||
class TraversalService(object): | class TraversalService(object): | ||||
"""Graph traversal service | """Graph traversal service | ||||
""" | """ | ||||
@staticmethod | @staticmethod | ||||
def GetNode(request, | def GetNode(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/GetNode', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/GetNode', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.GetNodeRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.GetNodeRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def Traverse(request, | def Traverse(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_stream(request, target, '/swh.graph.TraversalService/Traverse', | return grpc.experimental.unary_stream(request, target, '/swh.graph.TraversalService/Traverse', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Node.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Node.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def FindPathTo(request, | def FindPathTo(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/FindPathTo', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/FindPathTo', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathToRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathToRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def FindPathBetween(request, | def FindPathBetween(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/FindPathBetween', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/FindPathBetween', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.FindPathBetweenRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.FindPathBetweenRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.Path.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.Path.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def CountNodes(request, | def CountNodes(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/CountNodes', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/CountNodes', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def CountEdges(request, | def CountEdges(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/CountEdges', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/CountEdges', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.TraversalRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.CountResponse.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.CountResponse.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | ||||
@staticmethod | @staticmethod | ||||
def Stats(request, | def Stats(request, | ||||
target, | target, | ||||
options=(), | options=(), | ||||
channel_credentials=None, | channel_credentials=None, | ||||
call_credentials=None, | call_credentials=None, | ||||
insecure=False, | insecure=False, | ||||
compression=None, | compression=None, | ||||
wait_for_ready=None, | wait_for_ready=None, | ||||
timeout=None, | timeout=None, | ||||
metadata=None): | metadata=None): | ||||
return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/Stats', | return grpc.experimental.unary_unary(request, target, '/swh.graph.TraversalService/Stats', | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsRequest.SerializeToString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsRequest.SerializeToString, | ||||
swh_dot_graph_dot_rpc_dot_swhgraph__pb2.StatsResponse.FromString, | swh_dot_graph_dot_grpc_dot_swhgraph__pb2.StatsResponse.FromString, | ||||
options, channel_credentials, | options, channel_credentials, | ||||
insecure, call_credentials, compression, wait_for_ready, timeout, metadata) | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |