jina.serve package

Subpackages

• jina.serve.executors package
  • Submodules
    • jina.serve.executors.decorators module
      • avoid_concurrent_lock_cls()
      • requests()
      • monitor()
    • jina.serve.executors.metas module
      • get_default_metas()
      • get_executor_taboo()
  • Module contents
    • BaseExecutor
      • BaseExecutor.close()
      • BaseExecutor.workspace
      • BaseExecutor.from_hub()
      • BaseExecutor.serve()
      • BaseExecutor.StandaloneExecutorType
      • BaseExecutor.to_kubernetes_yaml()
      • BaseExecutor.to_k8s_yaml()
      • BaseExecutor.to_docker_compose_yaml()
      • BaseExecutor.monitor()
      • BaseExecutor.is_valid_jaml()
      • BaseExecutor.load_config()
      • BaseExecutor.save_config()
• jina.serve.runtimes package
  • Subpackages
    • jina.serve.runtimes.gateway package
      • Subpackages
      • Submodules
      • Module contents
    • jina.serve.runtimes.head package
      • Module contents
    • jina.serve.runtimes.request_handlers package
      • Submodules
      • Module contents
    • jina.serve.runtimes.worker package
      • Module contents
  • Submodules
    • jina.serve.runtimes.asyncio module
      • AsyncNewLoopRuntime
    • jina.serve.runtimes.base module
      • BaseRuntime
    • jina.serve.runtimes.helper module
    • jina.serve.runtimes.monitoring module
      • MonitoringMixin
  • Module contents
    • list_all_runtimes()
    • get_runtime()
• jina.serve.stream package
  • Submodules
    • jina.serve.stream.helper module
      • AsyncRequestsIterator
  • Module contents
    • RequestStreamer
      • RequestStreamer.stream()
      • RequestStreamer.wait_floating_requests_end()

Submodules

• jina.serve.gateway module
  • BaseGateway
    • BaseGateway.set_streamer()
    • BaseGateway.setup_server()
    • BaseGateway.run_server()
    • BaseGateway.teardown()
    • BaseGateway.stop_server()
    • BaseGateway.should_exit
    • BaseGateway.is_valid_jaml()
    • BaseGateway.load_config()
    • BaseGateway.save_config()
• jina.serve.helper module
  • wrap_func()
  • store_init_kwargs()
• jina.serve.monitoring module
• jina.serve.networking module
  • ReplicaList
    • ReplicaList.reset_connection()
    • ReplicaList.add_connection()
    • ReplicaList.remove_connection()
    • ReplicaList.get_next_connection()
    • ReplicaList.get_all_connections()
    • ReplicaList.has_connection()
    • ReplicaList.has_connections()
    • ReplicaList.close()
  • GrpcConnectionPool
    • GrpcConnectionPool.K8S_PORT_USES_AFTER
    • GrpcConnectionPool.K8S_PORT_USES_BEFORE
    • GrpcConnectionPool.K8S_PORT
    • GrpcConnectionPool.K8S_PORT_MONITORING
    • GrpcConnectionPool.ConnectionStubs
      • GrpcConnectionPool.ConnectionStubs.STUB_MAPPING
      • GrpcConnectionPool.ConnectionStubs.send_discover_endpoint()
      • GrpcConnectionPool.ConnectionStubs.send_requests()
    • GrpcConnectionPool.send_request()
    • GrpcConnectionPool.send_requests()
    • GrpcConnectionPool.send_discover_endpoint()
    • GrpcConnectionPool.send_request_once()
    • GrpcConnectionPool.send_requests_once()
    • GrpcConnectionPool.add_connection()
    • GrpcConnectionPool.remove_connection()
    • GrpcConnectionPool.close()
    • GrpcConnectionPool.get_grpc_channel()
    • GrpcConnectionPool.send_request_sync()
    • GrpcConnectionPool.send_health_check_sync()
    • GrpcConnectionPool.send_requests_sync()
    • GrpcConnectionPool.get_default_grpc_options()
    • GrpcConnectionPool.send_request_async()
    • GrpcConnectionPool.create_async_channel_stub()
    • GrpcConnectionPool.get_available_services()
  • in_docker()
  • host_is_local()
• jina.serve.streamer module
  • GatewayStreamer
    • GatewayStreamer.stream()
    • GatewayStreamer.stream_docs()
    • GatewayStreamer.close()
    • GatewayStreamer.Call()

Module contents