# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2
from seldon_core.proto import prediction_pb2 as proto_dot_prediction__pb2
[docs]class GenericStub(object):
"""[END Messages]
[START Services]
"""
[docs] def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.TransformInput = channel.unary_unary(
'/seldon.protos.Generic/TransformInput',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.TransformOutput = channel.unary_unary(
'/seldon.protos.Generic/TransformOutput',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.Route = channel.unary_unary(
'/seldon.protos.Generic/Route',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.Aggregate = channel.unary_unary(
'/seldon.protos.Generic/Aggregate',
request_serializer=proto_dot_prediction__pb2.SeldonMessageList.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.SendFeedback = channel.unary_unary(
'/seldon.protos.Generic/SendFeedback',
request_serializer=proto_dot_prediction__pb2.Feedback.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
[docs]class GenericServicer(object):
"""[END Messages]
[START Services]
"""
[docs] def Route(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!')
[docs] def Aggregate(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!')
[docs] def SendFeedback(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!')
[docs]def add_GenericServicer_to_server(servicer, server):
rpc_method_handlers = {
'TransformInput': grpc.unary_unary_rpc_method_handler(
servicer.TransformInput,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'TransformOutput': grpc.unary_unary_rpc_method_handler(
servicer.TransformOutput,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'Route': grpc.unary_unary_rpc_method_handler(
servicer.Route,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'Aggregate': grpc.unary_unary_rpc_method_handler(
servicer.Aggregate,
request_deserializer=proto_dot_prediction__pb2.SeldonMessageList.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'SendFeedback': grpc.unary_unary_rpc_method_handler(
servicer.SendFeedback,
request_deserializer=proto_dot_prediction__pb2.Feedback.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'seldon.protos.Generic', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class Generic(object):
"""[END Messages]
[START Services]
"""
[docs] @staticmethod
def Route(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Generic/Route',
proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod
def Aggregate(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Generic/Aggregate',
proto_dot_prediction__pb2.SeldonMessageList.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod
def SendFeedback(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Generic/SendFeedback',
proto_dot_prediction__pb2.Feedback.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs]class ModelStub(object):
"""Missing associated documentation comment in .proto file."""
[docs] def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Predict = channel.unary_unary(
'/seldon.protos.Model/Predict',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.SendFeedback = channel.unary_unary(
'/seldon.protos.Model/SendFeedback',
request_serializer=proto_dot_prediction__pb2.Feedback.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.Metadata = channel.unary_unary(
'/seldon.protos.Model/Metadata',
request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonModelMetadata.FromString,
)
[docs]class ModelServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def Predict(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!')
[docs] def SendFeedback(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!')
[docs]def add_ModelServicer_to_server(servicer, server):
rpc_method_handlers = {
'Predict': grpc.unary_unary_rpc_method_handler(
servicer.Predict,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'SendFeedback': grpc.unary_unary_rpc_method_handler(
servicer.SendFeedback,
request_deserializer=proto_dot_prediction__pb2.Feedback.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'Metadata': grpc.unary_unary_rpc_method_handler(
servicer.Metadata,
request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonModelMetadata.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'seldon.protos.Model', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class Model(object):
"""Missing associated documentation comment in .proto file."""
[docs] @staticmethod
def Predict(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Model/Predict',
proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod
def SendFeedback(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Model/SendFeedback',
proto_dot_prediction__pb2.Feedback.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs]class RouterStub(object):
"""Missing associated documentation comment in .proto file."""
[docs] def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Route = channel.unary_unary(
'/seldon.protos.Router/Route',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.SendFeedback = channel.unary_unary(
'/seldon.protos.Router/SendFeedback',
request_serializer=proto_dot_prediction__pb2.Feedback.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
[docs]class RouterServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def Route(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!')
[docs] def SendFeedback(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!')
[docs]def add_RouterServicer_to_server(servicer, server):
rpc_method_handlers = {
'Route': grpc.unary_unary_rpc_method_handler(
servicer.Route,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'SendFeedback': grpc.unary_unary_rpc_method_handler(
servicer.SendFeedback,
request_deserializer=proto_dot_prediction__pb2.Feedback.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'seldon.protos.Router', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class Router(object):
"""Missing associated documentation comment in .proto file."""
[docs] @staticmethod
def Route(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Router/Route',
proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod
def SendFeedback(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Router/SendFeedback',
proto_dot_prediction__pb2.Feedback.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
# This class is part of an EXPERIMENTAL API.
# This class is part of an EXPERIMENTAL API.
[docs]class CombinerStub(object):
"""Missing associated documentation comment in .proto file."""
[docs] def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Aggregate = channel.unary_unary(
'/seldon.protos.Combiner/Aggregate',
request_serializer=proto_dot_prediction__pb2.SeldonMessageList.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
[docs]class CombinerServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def Aggregate(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!')
[docs]def add_CombinerServicer_to_server(servicer, server):
rpc_method_handlers = {
'Aggregate': grpc.unary_unary_rpc_method_handler(
servicer.Aggregate,
request_deserializer=proto_dot_prediction__pb2.SeldonMessageList.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'seldon.protos.Combiner', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class Combiner(object):
"""Missing associated documentation comment in .proto file."""
[docs] @staticmethod
def Aggregate(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Combiner/Aggregate',
proto_dot_prediction__pb2.SeldonMessageList.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs]class SeldonStub(object):
"""Missing associated documentation comment in .proto file."""
[docs] def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Predict = channel.unary_unary(
'/seldon.protos.Seldon/Predict',
request_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.SendFeedback = channel.unary_unary(
'/seldon.protos.Seldon/SendFeedback',
request_serializer=proto_dot_prediction__pb2.Feedback.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
)
self.ModelMetadata = channel.unary_unary(
'/seldon.protos.Seldon/ModelMetadata',
request_serializer=proto_dot_prediction__pb2.SeldonModelMetadataRequest.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonModelMetadata.FromString,
)
self.GraphMetadata = channel.unary_unary(
'/seldon.protos.Seldon/GraphMetadata',
request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
response_deserializer=proto_dot_prediction__pb2.SeldonGraphMetadata.FromString,
)
[docs]class SeldonServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def Predict(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!')
[docs] def SendFeedback(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!')
[docs]def add_SeldonServicer_to_server(servicer, server):
rpc_method_handlers = {
'Predict': grpc.unary_unary_rpc_method_handler(
servicer.Predict,
request_deserializer=proto_dot_prediction__pb2.SeldonMessage.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'SendFeedback': grpc.unary_unary_rpc_method_handler(
servicer.SendFeedback,
request_deserializer=proto_dot_prediction__pb2.Feedback.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
),
'ModelMetadata': grpc.unary_unary_rpc_method_handler(
servicer.ModelMetadata,
request_deserializer=proto_dot_prediction__pb2.SeldonModelMetadataRequest.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonModelMetadata.SerializeToString,
),
'GraphMetadata': grpc.unary_unary_rpc_method_handler(
servicer.GraphMetadata,
request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
response_serializer=proto_dot_prediction__pb2.SeldonGraphMetadata.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'seldon.protos.Seldon', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class Seldon(object):
"""Missing associated documentation comment in .proto file."""
[docs] @staticmethod
def Predict(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Seldon/Predict',
proto_dot_prediction__pb2.SeldonMessage.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod
def SendFeedback(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/seldon.protos.Seldon/SendFeedback',
proto_dot_prediction__pb2.Feedback.SerializeToString,
proto_dot_prediction__pb2.SeldonMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)