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]