Interface StreamManager

  • All Superinterfaces:
    AutoCloseable
    All Known Implementing Classes:
    LogStreamManager

    public interface StreamManager
    extends AutoCloseable
    Gives access to StreamProcessor and appender for source provider.
    Since:
    11.1
    • Method Detail

      • register

        void register​(String processorName,
                      Topology topology,
                      Settings settings)
        Registers a processor and initializes the underlying streams, this is needed before creating a processor or appending record in source streams.
      • createStreamProcessor

        StreamProcessor createStreamProcessor​(String processorName)
        Creates a registered processor without starting it.
      • registerAndCreateProcessor

        default StreamProcessor registerAndCreateProcessor​(String processorName,
                                                           Topology topology,
                                                           Settings settings)
        Registers and creates a processor without starting it.
      • register

        void register​(List<String> streams,
                      Settings settings)
        Registers some source Streams without any processors.
        Since:
        11.4
      • append

        LogOffset append​(String stream,
                         Record record)
        Appends a record to a processor's source stream.
      • getProcessorNames

        Set<String> getProcessorNames()
        Gets a set of processor names.
        Since:
        2021.25
      • getProcessor

        StreamProcessor getProcessor​(String processorName)
        Gets a processor.
        Returns:
        null if the processor doesn't exist
        Since:
        2021.25