Method constructor

packages/db/src/buffers/event-buffer.ts:73–80

()

  private queueKey = 'event_buffer:queue';

  constructor() {
    super({
      name: 'event',
      onFlush: async () => {
        await this.processBuffer();
      },
    });
  }

  bulkAdd(events: IClickhouseEvent[]) {
    for (const event of events) {