nvflare.app_common.streamers package

Submodules

• nvflare.app_common.streamers.container_retriever module
  • ContainerRetriever
    • ContainerRetriever.add_container()
    • ContainerRetriever.do_stream()
    • ContainerRetriever.get_result()
    • ContainerRetriever.register_stream_processing()
    • ContainerRetriever.retrieve_container()
    • ContainerRetriever.validate_request()
• nvflare.app_common.streamers.container_streamer module
  • ContainerStreamer
    • ContainerStreamer.get_result()
    • ContainerStreamer.register_stream_processing()
    • ContainerStreamer.stream_container()
• nvflare.app_common.streamers.file_retriever module
  • FileRetriever
    • FileRetriever.do_stream()
    • FileRetriever.get_result()
    • FileRetriever.register_stream_processing()
    • FileRetriever.retrieve_file()
    • FileRetriever.validate_request()
• nvflare.app_common.streamers.file_streamer module
  • FileStreamer
    • FileStreamer.get_file_location()
    • FileStreamer.get_file_name()
    • FileStreamer.get_file_size()
    • FileStreamer.register_stream_processing()
    • FileStreamer.stream_file()
• nvflare.app_common.streamers.log_streamer module
  • LogStreamer — live-tailing streamer for growing log files
    • Relationship between the two parameters
  • LogChunkConsumerFactory
    • LogChunkConsumerFactory.get_consumer()
  • LogStreamer
    • LogStreamer.get_file_name()
    • LogStreamer.register_stream_processing()
    • LogStreamer.stream_log()
  • dispatch_stream_done()
• nvflare.app_common.streamers.object_retriever module
  • ObjectRetriever
    • ObjectRetriever.do_stream()
    • ObjectRetriever.get_result()
    • ObjectRetriever.handle_event()
    • ObjectRetriever.register_stream_processing()
    • ObjectRetriever.retrieve()
    • ObjectRetriever.validate_request()
• nvflare.app_common.streamers.streamer_base module
  • BaseChunkConsumer
  • BaseChunkProducer
    • BaseChunkProducer.process_replies()
  • StreamerBase
    • StreamerBase.get_channel()
    • StreamerBase.get_rc()
    • StreamerBase.get_topic()

Module contents