jina.proto.jina_pb2_grpc module#

Client and server classes corresponding to protobuf-defined services.

class jina.proto.jina_pb2_grpc.JinaControlRequestRPCStub(channel)[source]#

Bases: object

jina gRPC service for ControlRequests.

Constructor.

Args:

channel: A grpc.Channel.

class jina.proto.jina_pb2_grpc.JinaControlRequestRPCServicer[source]#

Bases: object

jina gRPC service for ControlRequests.

process_control(request, context)[source]#

Used for passing ControlRequests to the Executors

jina.proto.jina_pb2_grpc.add_JinaControlRequestRPCServicer_to_server(servicer, server)[source]#
class jina.proto.jina_pb2_grpc.JinaControlRequestRPC[source]#

Bases: object

jina gRPC service for ControlRequests.

static process_control(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
class jina.proto.jina_pb2_grpc.JinaDataRequestRPCStub(channel)[source]#

Bases: object

jina gRPC service for DataRequests.

Constructor.

Args:

channel: A grpc.Channel.

class jina.proto.jina_pb2_grpc.JinaDataRequestRPCServicer[source]#

Bases: object

jina gRPC service for DataRequests.

process_data(request, context)[source]#

Used for passing DataRequests to the Executors

jina.proto.jina_pb2_grpc.add_JinaDataRequestRPCServicer_to_server(servicer, server)[source]#
class jina.proto.jina_pb2_grpc.JinaDataRequestRPC[source]#

Bases: object

jina gRPC service for DataRequests.

static process_data(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
class jina.proto.jina_pb2_grpc.JinaSingleDataRequestRPCStub(channel)[source]#

Bases: object

jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed

Constructor.

Args:

channel: A grpc.Channel.

class jina.proto.jina_pb2_grpc.JinaSingleDataRequestRPCServicer[source]#

Bases: object

jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed

process_single_data(request, context)[source]#

Used for passing DataRequests to the Executors

jina.proto.jina_pb2_grpc.add_JinaSingleDataRequestRPCServicer_to_server(servicer, server)[source]#
class jina.proto.jina_pb2_grpc.JinaSingleDataRequestRPC[source]#

Bases: object

jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed

static process_single_data(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#
class jina.proto.jina_pb2_grpc.JinaRPCStub(channel)[source]#

Bases: object

jina Gateway gRPC service.

Constructor.

Args:

channel: A grpc.Channel.

class jina.proto.jina_pb2_grpc.JinaRPCServicer[source]#

Bases: object

jina Gateway gRPC service.

Call(request_iterator, context)[source]#

Pass in a Request and a filled Request with matches will be returned.

jina.proto.jina_pb2_grpc.add_JinaRPCServicer_to_server(servicer, server)[source]#
class jina.proto.jina_pb2_grpc.JinaRPC[source]#

Bases: object

jina Gateway gRPC service.

static Call(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]#