refactor(core): Simplify naming of job buffer components & APIs

packages/admin-ui/src/lib/core/src/common/generated-types.ts

@@ -1673,7 +1673,7 @@ export type Job = Node & {
 
 export type JobBufferSize = {
   __typename?: 'JobBufferSize';
-  processorId: Scalars['String'];
+  bufferId: Scalars['String'];
   size: Scalars['Int'];
 };
 
@@ -2304,7 +2304,7 @@ export type Mutation = {
   removeProductsFromChannel: Array<Product>;
   /** Removes Promotions from the specified Channel */
   removePromotionsFromChannel: Array<Promotion>;
-  /** Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted. */
+  /** Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted. */
   removeSettledJobs: Scalars['Int'];
   requestCompleted: Scalars['Int'];
   requestStarted: Scalars['Int'];
@@ -2683,7 +2683,7 @@ export type MutationDeleteZoneArgs = {
 
 
 export type MutationFlushBufferedJobsArgs = {
-  processorIds?: Maybe<Array<Scalars['String']>>;
+  bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 
@@ -4051,7 +4051,7 @@ export type QueryJobArgs = {
 
 
 export type QueryJobBufferSizeArgs = {
-  processorIds?: Maybe<Array<Scalars['String']>>;
+  bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 

packages/asset-server-plugin/e2e/graphql/generated-e2e-asset-server-plugin-types.ts

@@ -1621,7 +1621,7 @@ export type Job = Node & {
 };
 
 export type JobBufferSize = {
-    processorId: Scalars['String'];
+    bufferId: Scalars['String'];
     size: Scalars['Int'];
 };
 
@@ -2192,7 +2192,7 @@ export type Mutation = {
     deleteFacetValues: Array<DeletionResponse>;
     updateGlobalSettings: UpdateGlobalSettingsResult;
     importProducts?: Maybe<ImportInfo>;
-    /** Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted. */
+    /** Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted. */
     removeSettledJobs: Scalars['Int'];
     cancelJob: Job;
     flushBufferedJobs: Success;
@@ -2504,7 +2504,7 @@ export type MutationCancelJobArgs = {
 };
 
 export type MutationFlushBufferedJobsArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type MutationSettlePaymentArgs = {
@@ -3793,7 +3793,7 @@ export type QueryJobsByIdArgs = {
 };
 
 export type QueryJobBufferSizeArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type QueryOrderArgs = {

packages/common/src/generated-types.ts

@@ -1665,7 +1665,7 @@ export type Job = Node & {
 
 export type JobBufferSize = {
   __typename?: 'JobBufferSize';
-  processorId: Scalars['String'];
+  bufferId: Scalars['String'];
   size: Scalars['Int'];
 };
 
@@ -2238,7 +2238,7 @@ export type Mutation = {
   deleteFacetValues: Array<DeletionResponse>;
   updateGlobalSettings: UpdateGlobalSettingsResult;
   importProducts?: Maybe<ImportInfo>;
-  /** Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted. */
+  /** Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted. */
   removeSettledJobs: Scalars['Int'];
   cancelJob: Job;
   flushBufferedJobs: Success;
@@ -2597,7 +2597,7 @@ export type MutationCancelJobArgs = {
 
 
 export type MutationFlushBufferedJobsArgs = {
-  processorIds?: Maybe<Array<Scalars['String']>>;
+  bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 
@@ -4005,7 +4005,7 @@ export type QueryJobsByIdArgs = {
 
 
 export type QueryJobBufferSizeArgs = {
-  processorIds?: Maybe<Array<Scalars['String']>>;
+  bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 

packages/core/e2e/graphql/generated-e2e-admin-types.ts

@@ -1621,7 +1621,7 @@ export type Job = Node & {
 };
 
 export type JobBufferSize = {
-    processorId: Scalars['String'];
+    bufferId: Scalars['String'];
     size: Scalars['Int'];
 };
 
@@ -2192,7 +2192,7 @@ export type Mutation = {
     deleteFacetValues: Array<DeletionResponse>;
     updateGlobalSettings: UpdateGlobalSettingsResult;
     importProducts?: Maybe<ImportInfo>;
-    /** Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted. */
+    /** Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted. */
     removeSettledJobs: Scalars['Int'];
     cancelJob: Job;
     flushBufferedJobs: Success;
@@ -2504,7 +2504,7 @@ export type MutationCancelJobArgs = {
 };
 
 export type MutationFlushBufferedJobsArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type MutationSettlePaymentArgs = {
@@ -3793,7 +3793,7 @@ export type QueryJobsByIdArgs = {
 };
 
 export type QueryJobBufferSizeArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type QueryOrderArgs = {

packages/core/src/api/resolvers/admin/job.resolver.ts

@@ -13,7 +13,7 @@ import {
 
 import { ConfigService, InspectableJobQueueStrategy, isInspectableJobQueueStrategy } from '../../../config';
 import { JobQueueService } from '../../../job-queue';
-import { JobBuffer } from '../../../job-queue/job-buffer/job-buffer';
+import { JobBufferService } from '../../../job-queue/job-buffer/job-buffer.service';
 import { Allow } from '../../decorators/allow.decorator';
 
 @Resolver()
@@ -21,7 +21,7 @@ export class JobResolver {
     constructor(
         private configService: ConfigService,
         private jobService: JobQueueService,
-        private jobBuffer: JobBuffer,
+        private jobBufferService: JobBufferService,
     ) {}
 
     @Query()
@@ -86,14 +86,14 @@ export class JobResolver {
     @Query()
     @Allow(Permission.ReadSettings, Permission.ReadSystem)
     async jobBufferSize(@Args() args: QueryJobBufferSizeArgs) {
-        const bufferSizes = await this.jobBuffer.bufferSize(args.processorIds);
+        const bufferSizes = await this.jobBufferService.bufferSize(args.bufferIds);
         return Object.entries(bufferSizes).map(([processorId, size]) => ({ processorId, size }));
     }
 
     @Mutation()
     @Allow(Permission.UpdateSettings, Permission.UpdateSystem)
     async flushBufferedJobs(@Args() args: MutationFlushBufferedJobsArgs) {
-        await this.jobBuffer.flush(args.processorIds);
+        await this.jobBufferService.flush(args.bufferIds);
         return { success: true };
     }
 

packages/core/src/api/schema/admin-api/job.api.graphql

@@ -3,18 +3,18 @@ type Query {
     jobs(options: JobListOptions): JobList!
     jobsById(jobIds: [ID!]!): [Job!]!
     jobQueues: [JobQueue!]!
-    jobBufferSize(processorIds: [String!]): [JobBufferSize!]!
+    jobBufferSize(bufferIds: [String!]): [JobBufferSize!]!
 }
 
 type Mutation {
-    "Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted."
+    "Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted."
     removeSettledJobs(queueNames: [String!], olderThan: DateTime): Int!
     cancelJob(jobId: ID!): Job!
-    flushBufferedJobs(processorIds: [String!]): Success!
+    flushBufferedJobs(bufferIds: [String!]): Success!
 }
 
 type JobBufferSize {
-    processorId: String!
+    bufferId: String!
     size: Int!
 }
 

packages/core/src/job-queue/index.ts

@@ -1,7 +1,7 @@
 export * from './injectable-job-queue-strategy';
 export * from './job-buffer/in-memory-job-buffer-storage-strategy';
 export * from './job-buffer/job-buffer';
-export * from './job-buffer/job-buffer-processor';
+export * from './job-buffer/job-buffer';
 export * from './job-buffer/job-buffer-storage-strategy';
 export * from './job-buffer/sql-job-buffer-storage-strategy';
 export * from './job';

packages/core/src/job-queue/job-buffer/job-buffer-processor.ts

@@ -1,8 +0,0 @@
-import { Job } from '../job';
-import { JobData } from '../types';
-
-export interface JobBufferProcessor<Data extends JobData<Data> = {}> {
-    readonly id: string;
-    collect(job: Job<Data>): boolean | Promise<boolean>;
-    reduce(collectedJobs: Array<Job<Data>>): Array<Job<Data>> | Promise<Array<Job<Data>>>;
-}

packages/core/src/job-queue/job-buffer/job-buffer-storage-strategy.ts

@@ -3,6 +3,6 @@ import { Job } from '../job';
 
 export interface JobBufferStorageStrategy extends InjectableStrategy {
     add(processorId: string, job: Job): Promise<Job>;
-    bufferSize(processorIds?: string[]): Promise<{ [processorId: string]: number }>;
-    flush(processorIds?: string[]): Promise<{ [processorId: string]: Job[] }>;
+    bufferSize(bufferIds?: string[]): Promise<{ [bufferId: string]: number }>;
+    flush(bufferIds?: string[]): Promise<{ [bufferId: string]: Job[] }>;
 }

packages/core/src/job-queue/job-buffer/job-buffer.service.ts

@@ -0,0 +1,76 @@
+import { Injectable } from '@nestjs/common';
+
+import { InternalServerError } from '../../common/error/errors';
+import { ConfigService } from '../../config/config.service';
+import { Logger } from '../../config/logger/vendure-logger';
+import { Job } from '../job';
+
+import { JobBuffer } from './job-buffer';
+import { JobBufferStorageStrategy } from './job-buffer-storage-strategy';
+
+@Injectable()
+export class JobBufferService {
+    private buffers = new Set<JobBuffer>();
+    private storageStrategy: JobBufferStorageStrategy;
+
+    constructor(private configService: ConfigService) {
+        this.storageStrategy = configService.jobQueueOptions.jobBufferStorageStrategy;
+    }
+
+    addBuffer(buffer: JobBuffer<any>) {
+        const idAlreadyExists = Array.from(this.buffers).find(p => p.id === buffer.id);
+        if (idAlreadyExists) {
+            throw new InternalServerError(
+                `There is already a JobBufferProcessor with the id "${buffer.id}". Ids must be unique`,
+            );
+        }
+        this.buffers.add(buffer);
+    }
+
+    removeBuffer(buffer: JobBuffer<any>) {
+        this.buffers.delete(buffer);
+    }
+
+    async add(job: Job): Promise<boolean> {
+        let collected = false;
+        for (const buffer of this.buffers) {
+            const shouldCollect = await buffer.collect(job);
+            if (shouldCollect) {
+                collected = true;
+                await this.storageStrategy.add(buffer.id, job);
+            }
+        }
+        return collected;
+    }
+
+    bufferSize(forBuffers?: Array<JobBuffer | string>): Promise<{ [bufferId: string]: number }> {
+        const buffer = forBuffers ?? Array.from(this.buffers);
+        return this.storageStrategy.bufferSize(buffer.map(p => (typeof p === 'string' ? p : p.id)));
+    }
+
+    async flush(forBuffers?: Array<JobBuffer | string>): Promise<void> {
+        const { jobQueueStrategy } = this.configService.jobQueueOptions;
+        const buffers = forBuffers ?? Array.from(this.buffers);
+        const flushResult = await this.storageStrategy.flush(
+            buffers.map(p => (typeof p === 'string' ? p : p.id)),
+        );
+        for (const buffer of this.buffers) {
+            const jobsForBuffer = flushResult[buffer.id];
+            if (jobsForBuffer?.length) {
+                let jobsToAdd = jobsForBuffer;
+                try {
+                    jobsToAdd = await buffer.reduce(jobsForBuffer);
+                } catch (e) {
+                    Logger.error(
+                        `Error encountered processing jobs in JobBuffer "${buffer.id}":\n${e.message}`,
+                        undefined,
+                        e.stack,
+                    );
+                }
+                for (const job of jobsToAdd) {
+                    await jobQueueStrategy.add(job);
+                }
+            }
+        }
+    }
+}

packages/core/src/job-queue/job-buffer/job-buffer.ts

@@ -1,78 +1,8 @@
-import { Injectable } from '@nestjs/common';
-
-import { InternalServerError } from '../../common/error/errors';
-import { ConfigService } from '../../config/config.service';
-import { Logger } from '../../config/logger/vendure-logger';
 import { Job } from '../job';
+import { JobData } from '../types';
 
-import { JobBufferProcessor } from './job-buffer-processor';
-import { JobBufferStorageStrategy } from './job-buffer-storage-strategy';
-
-@Injectable()
-export class JobBuffer {
-    private processors = new Set<JobBufferProcessor>();
-    private storageStrategy: JobBufferStorageStrategy;
-
-    constructor(private configService: ConfigService) {
-        this.storageStrategy = configService.jobQueueOptions.jobBufferStorageStrategy;
-    }
-
-    addProcessor(processor: JobBufferProcessor<any>) {
-        const idAlreadyExists = Array.from(this.processors).find(p => p.id === processor.id);
-        if (idAlreadyExists) {
-            throw new InternalServerError(
-                `There is already a JobBufferProcessor with the id "${processor.id}". Ids must be unique`,
-            );
-        }
-        this.processors.add(processor);
-    }
-
-    removeProcessor(processor: JobBufferProcessor<any>) {
-        this.processors.delete(processor);
-    }
-
-    async add(job: Job): Promise<boolean> {
-        let collected = false;
-        for (const processor of this.processors) {
-            const shouldCollect = await processor.collect(job);
-            if (shouldCollect) {
-                collected = true;
-                await this.storageStrategy.add(processor.id, job);
-            }
-        }
-        return collected;
-    }
-
-    bufferSize(
-        forProcessors?: Array<JobBufferProcessor | string>,
-    ): Promise<{ [processorId: string]: number }> {
-        const processors = forProcessors ?? Array.from(this.processors);
-        return this.storageStrategy.bufferSize(processors.map(p => (typeof p === 'string' ? p : p.id)));
-    }
-
-    async flush(forProcessors?: Array<JobBufferProcessor | string>): Promise<void> {
-        const { jobQueueStrategy } = this.configService.jobQueueOptions;
-        const processors = forProcessors ?? Array.from(this.processors);
-        const flushResult = await this.storageStrategy.flush(
-            processors.map(p => (typeof p === 'string' ? p : p.id)),
-        );
-        for (const processor of this.processors) {
-            const jobsForProcessor = flushResult[processor.id];
-            if (jobsForProcessor?.length) {
-                let jobsToAdd = jobsForProcessor;
-                try {
-                    jobsToAdd = await processor.reduce(jobsForProcessor);
-                } catch (e) {
-                    Logger.error(
-                        `Error encountered processing jobs in "${processor.id}:\n${e.message}"`,
-                        undefined,
-                        e.stack,
-                    );
-                }
-                for (const job of jobsToAdd) {
-                    await jobQueueStrategy.add(job);
-                }
-            }
-        }
-    }
+export interface JobBuffer<Data extends JobData<Data> = {}> {
+    readonly id: string;
+    collect(job: Job<Data>): boolean | Promise<boolean>;
+    reduce(collectedJobs: Array<Job<Data>>): Array<Job<Data>> | Promise<Array<Job<Data>>>;
 }

packages/core/src/job-queue/job-queue.module.ts

@@ -2,12 +2,12 @@ import { Module } from '@nestjs/common';
 
 import { ConfigModule } from '../config/config.module';
 
-import { JobBuffer } from './job-buffer/job-buffer';
+import { JobBufferService } from './job-buffer/job-buffer.service';
 import { JobQueueService } from './job-queue.service';
 
 @Module({
     imports: [ConfigModule],
-    providers: [JobQueueService, JobBuffer],
-    exports: [JobQueueService, JobBuffer],
+    providers: [JobQueueService, JobBufferService],
+    exports: [JobQueueService, JobBufferService],
 })
 export class JobQueueModule {}

packages/core/src/job-queue/job-queue.service.ts

@@ -5,6 +5,7 @@ import { ConfigService, JobQueueStrategy, Logger } from '../config';
 
 import { loggerCtx } from './constants';
 import { JobBuffer } from './job-buffer/job-buffer';
+import { JobBufferService } from './job-buffer/job-buffer.service';
 import { JobQueue } from './job-queue';
 import { CreateQueueOptions, JobData } from './types';
 
@@ -52,7 +53,7 @@ export class JobQueueService implements OnModuleDestroy {
         return this.configService.jobQueueOptions.jobQueueStrategy;
     }
 
-    constructor(private configService: ConfigService, private jobBuffer: JobBuffer) {}
+    constructor(private configService: ConfigService, private jobBufferService: JobBufferService) {}
 
     /** @internal */
     onModuleDestroy() {
@@ -67,7 +68,7 @@ export class JobQueueService implements OnModuleDestroy {
     async createQueue<Data extends JobData<Data>>(
         options: CreateQueueOptions<Data>,
     ): Promise<JobQueue<Data>> {
-        const queue = new JobQueue(options, this.jobQueueStrategy, this.jobBuffer);
+        const queue = new JobQueue(options, this.jobQueueStrategy, this.jobBufferService);
         if (this.hasStarted && this.shouldStartQueue(queue.name)) {
             await queue.start();
         }
@@ -85,6 +86,22 @@ export class JobQueueService implements OnModuleDestroy {
         }
     }
 
+    addBuffer(buffer: JobBuffer<any>) {
+        this.jobBufferService.addBuffer(buffer);
+    }
+
+    removeBuffer(buffer: JobBuffer<any>) {
+        this.jobBufferService.removeBuffer(buffer);
+    }
+
+    bufferSize(forBuffers?: Array<JobBuffer | string>): Promise<{ [bufferId: string]: number }> {
+        return this.jobBufferService.bufferSize(forBuffers);
+    }
+
+    flush(forBuffers?: Array<JobBuffer | string>): Promise<void> {
+        return this.jobBufferService.flush(forBuffers);
+    }
+
     /**
      * @description
      * Returns an array of `{ name: string; running: boolean; }` for each

packages/core/src/job-queue/job-queue.ts

@@ -6,7 +6,7 @@ import { JobQueueStrategy } from '../config';
 import { Logger } from '../config/logger/vendure-logger';
 
 import { Job } from './job';
-import { JobBuffer } from './job-buffer/job-buffer';
+import { JobBufferService } from './job-buffer/job-buffer.service';
 import { SubscribableJob } from './subscribable-job';
 import { CreateQueueOptions, JobConfig, JobData } from './types';
 
@@ -36,7 +36,7 @@ export class JobQueue<Data extends JobData<Data> = {}> {
     constructor(
         private options: CreateQueueOptions<Data>,
         private jobQueueStrategy: JobQueueStrategy,
-        private jobBuffer: JobBuffer,
+        private jobBufferService: JobBufferService,
     ) {}
 
     /** @internal */
@@ -97,7 +97,7 @@ export class JobQueue<Data extends JobData<Data> = {}> {
             retries: options?.retries ?? 0,
         });
 
-        const isBuffered = await this.jobBuffer.add(job);
+        const isBuffered = await this.jobBufferService.add(job);
         if (!isBuffered) {
             try {
                 const addedJob = await this.jobQueueStrategy.add(job);

packages/core/src/plugin/default-search-plugin/collection-job-buffer-processor.ts → packages/core/src/plugin/default-search-plugin/collection-job-buffer.ts

@@ -1,12 +1,12 @@
 import { ID } from '@vendure/common/lib/shared-types';
 import { unique } from '@vendure/common/lib/unique';
 
-import { Job, JobBufferProcessor } from '../../job-queue';
+import { Job, JobBuffer } from '../../job-queue';
 import { ApplyCollectionFiltersJobData } from '../../service/services/collection.service';
 
 import { UpdateIndexQueueJobData, UpdateVariantsByIdJobData, UpdateVariantsJobData } from './types';
 
-export class CollectionJobBufferProcessor implements JobBufferProcessor<ApplyCollectionFiltersJobData> {
+export class CollectionJobBuffer implements JobBuffer<ApplyCollectionFiltersJobData> {
     readonly id = 'search-plugin-apply-collection-filters';
 
     collect(job: Job): boolean {

packages/core/src/plugin/default-search-plugin/default-search-plugin.ts

@@ -12,17 +12,18 @@ import { ProductEvent } from '../../event-bus/events/product-event';
 import { ProductVariantChannelEvent } from '../../event-bus/events/product-variant-channel-event';
 import { ProductVariantEvent } from '../../event-bus/events/product-variant-event';
 import { TaxRateModificationEvent } from '../../event-bus/events/tax-rate-modification-event';
-import { JobBuffer } from '../../job-queue/job-buffer/job-buffer';
+import { JobBufferService } from '../../job-queue/job-buffer/job-buffer.service';
+import { JobQueueService } from '../../job-queue/job-queue.service';
 import { PluginCommonModule } from '../plugin-common.module';
 import { VendurePlugin } from '../vendure-plugin';
 
-import { CollectionJobBufferProcessor } from './collection-job-buffer-processor';
+import { CollectionJobBuffer } from './collection-job-buffer';
 import { AdminFulltextSearchResolver, ShopFulltextSearchResolver } from './fulltext-search.resolver';
 import { FulltextSearchService } from './fulltext-search.service';
 import { IndexerController } from './indexer/indexer.controller';
 import { SearchIndexService } from './indexer/search-index.service';
 import { SearchIndexItem } from './search-index-item.entity';
-import { SearchJobBufferProcessor } from './search-job-buffer-processor';
+import { SearchJobBuffer } from './search-job-buffer';
 
 export interface DefaultSearchReindexResponse extends SearchReindexResponse {
     timeTaken: number;
@@ -70,13 +71,13 @@ export class DefaultSearchPlugin implements OnApplicationBootstrap {
     constructor(
         private eventBus: EventBus,
         private searchIndexService: SearchIndexService,
-        private jobBuffer: JobBuffer,
+        private jobQueueService: JobQueueService,
     ) {}
 
     /** @internal */
     async onApplicationBootstrap() {
-        this.jobBuffer.addProcessor(new SearchJobBufferProcessor());
-        this.jobBuffer.addProcessor(new CollectionJobBufferProcessor());
+        this.jobQueueService.addBuffer(new SearchJobBuffer());
+        this.jobQueueService.addBuffer(new CollectionJobBuffer());
 
         this.eventBus.ofType(ProductEvent).subscribe(event => {
             if (event.type === 'deleted') {

packages/core/src/plugin/default-search-plugin/search-job-buffer-processor.ts → packages/core/src/plugin/default-search-plugin/search-job-buffer.ts

@@ -1,11 +1,11 @@
 import { ID } from '@vendure/common/lib/shared-types';
 import { unique } from '@vendure/common/lib/unique';
 
-import { Job, JobBufferProcessor } from '../../job-queue';
+import { Job, JobBuffer } from '../../job-queue';
 
 import { UpdateIndexQueueJobData, UpdateVariantsByIdJobData, UpdateVariantsJobData } from './types';
 
-export class SearchJobBufferProcessor implements JobBufferProcessor<UpdateIndexQueueJobData> {
+export class SearchJobBuffer implements JobBuffer<UpdateIndexQueueJobData> {
     readonly id = 'search-plugin-update-search-index';
 
     collect(job: Job<UpdateIndexQueueJobData>): boolean | Promise<boolean> {

packages/elasticsearch-plugin/e2e/graphql/generated-e2e-elasticsearch-plugin-types.ts

@@ -1621,7 +1621,7 @@ export type Job = Node & {
 };
 
 export type JobBufferSize = {
-    processorId: Scalars['String'];
+    bufferId: Scalars['String'];
     size: Scalars['Int'];
 };
 
@@ -2192,7 +2192,7 @@ export type Mutation = {
     deleteFacetValues: Array<DeletionResponse>;
     updateGlobalSettings: UpdateGlobalSettingsResult;
     importProducts?: Maybe<ImportInfo>;
-    /** Remove all settled jobs in the given queues olfer than the given date. Returns the number of jobs deleted. */
+    /** Remove all settled jobs in the given queues older than the given date. Returns the number of jobs deleted. */
     removeSettledJobs: Scalars['Int'];
     cancelJob: Job;
     flushBufferedJobs: Success;
@@ -2504,7 +2504,7 @@ export type MutationCancelJobArgs = {
 };
 
 export type MutationFlushBufferedJobsArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type MutationSettlePaymentArgs = {
@@ -3793,7 +3793,7 @@ export type QueryJobsByIdArgs = {
 };
 
 export type QueryJobBufferSizeArgs = {
-    processorIds?: Maybe<Array<Scalars['String']>>;
+    bufferIds?: Maybe<Array<Scalars['String']>>;
 };
 
 export type QueryOrderArgs = {