Class AutoBatchQueue

constructor

• new AutoBatchQueue(): AutoBatchQueue

  Returns AutoBatchQueue

items

sizeBytes

peek

• peek(): {
      action: "create"
      | "update";
      apiKey?: string;
      apiUrl?: string;
      itemPromise: Promise<void>;
      itemPromiseResolve: () => void;
      otelContext?: OTELContext;
      payload: RunCreate | RunUpdate;
      size: number;
  }

  Returns {
      action: "create" | "update";
      apiKey?: string;
      apiUrl?: string;
      itemPromise: Promise<void>;
      itemPromiseResolve: () => void;
      otelContext?: OTELContext;
      payload: RunCreate | RunUpdate;
      size: number;
  }

pop

• pop(
      __namedParameters: { upToSize: number; upToSizeBytes: number },
  ): [AutoBatchQueueItem[], () => void]

  Parameters

  • __namedParameters: { upToSize: number; upToSizeBytes: number }

  Returns [AutoBatchQueueItem[], () => void]

push

• push(item: AutoBatchQueueItem): Promise<void>

  Parameters

  • item: AutoBatchQueueItem

  Returns Promise<void>