Method constructor

packages/db/src/buffers/base-buffer.ts:101–111

(options: {
    name: string;
    onFlush: () => Promise<void>;
    enableParallelProcessing?: boolean;
  })

  public addObserver: AddObserver | null = null;

  constructor(options: {
    name: string;
    onFlush: () => Promise<void>;
    enableParallelProcessing?: boolean;
  }) {
    this.logger = createLogger({ name: options.name });
    this.name = options.name;
    this.lockKey = `lock:${this.name}`;
    this.onFlush = options.onFlush;
    this.enableParallelProcessing = options.enableParallelProcessing ?? false;
  }

  /**
   * Returns the Redis key of the buffer's main list (the queue of pending