Package ai.pipestream.common.service

Class ProcessingBufferManager

java.lang.Object
ai.pipestream.common.service.ProcessingBufferManager
@ApplicationScoped public class ProcessingBufferManager extends Object
CDI bean that provides convenient access to processing buffers managed by the interceptor. This follows the Quarkus pattern of using static methods on interceptors for data access. This manager acts as a CDI-injectable facade over the static methods, making it easier to use in tests and other CDI beans while following established Quarkus patterns.

  • Constructor Details

    • ProcessingBufferManager

      public ProcessingBufferManager()

  • Method Details

    • getBuffer

      public ProcessingBuffer<ai.pipestream.data.v1.PipeDoc> getBuffer(String methodKey)
      Gets the buffer for a specific method key.

    • getBuffer

      public ProcessingBuffer<ai.pipestream.data.v1.PipeDoc> getBuffer(String className, String methodName)
      Gets the buffer for a specific method.

    • getActiveBufferKeys

      public Set<String> getActiveBufferKeys()
      Gets all active buffer keys.

    • getTotalCapturedDocuments

      public int getTotalCapturedDocuments()
      Gets the total number of captured documents across all buffers.

    • getBufferStatistics

      public Map<String,Integer> getBufferStatistics()
      Gets buffer statistics for monitoring.

    • saveAllBuffers

      public void saveAllBuffers()
      Saves all buffers to disk.

    • saveBuffer

      public boolean saveBuffer(String methodKey)
      Saves a specific buffer to disk.

    • clearAllBuffers

      public void clearAllBuffers()
      Clears all buffers.