"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"typeRoots": ["./node_modules/@types", "./@types"],
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"typeRoots": ["./node_modules/@types", "./@types"],
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
"outDir": "./dist",
"esModuleInterop": true,
"forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true,
"strict": true,
"skipLibCheck": true
}
}
/** @inheritDoc */
- protected checkAndEmitDynamicWorkerCreationEvents (): void {
+ protected override checkAndEmitDynamicWorkerCreationEvents (): void {
if (this.emitter != null) {
if (!this.fullEventEmitted && this.full) {
this.emitter.emit(PoolEvents.full, this.info)
}
/** @inheritDoc */
- protected checkAndEmitDynamicWorkerDestructionEvents (): void {
+ protected override checkAndEmitDynamicWorkerDestructionEvents (): void {
if (this.emitter != null) {
if (this.fullEventEmitted && !this.full) {
this.emitter.emit(PoolEvents.fullEnd, this.info)
}
/** @inheritDoc */
- protected shallCreateDynamicWorker (): boolean {
+ protected override shallCreateDynamicWorker (): boolean {
return (!this.full && this.internalBusy()) || this.empty
}
/** @inheritDoc */
- protected get backPressure (): boolean {
+ protected override get backPressure (): boolean {
return this.full && this.internalBackPressure()
}
/** @inheritDoc */
- protected get busy (): boolean {
+ protected override get busy (): boolean {
return this.full && this.internalBusy()
}
}
/** @inheritDoc */
- protected get type (): PoolType {
+ protected override get type (): PoolType {
return PoolTypes.dynamic
}
}
}
/** @inheritDoc */
- protected setupHook (): void {
+ protected override setupHook (): void {
cluster.setupPrimary({ ...this.opts.settings, exec: this.filePath })
}
extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
implements IWorkerChoiceStrategy {
/** @inheritDoc */
- public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
- elu: {
- aggregate: true,
- average: true,
- median: false,
- },
- runTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- waitTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- }
+ public override readonly taskStatisticsRequirements: TaskStatisticsRequirements =
+ {
+ elu: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ runTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ waitTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ }
/** @inheritDoc */
public constructor (
*/
private workerNodeVirtualTaskExecutionTime = 0
/** @inheritDoc */
- public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
- elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
- runTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- waitTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- }
+ public override readonly taskStatisticsRequirements: TaskStatisticsRequirements =
+ {
+ elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+ runTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ waitTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ }
/** @inheritDoc */
public constructor (
}
/** @inheritDoc */
- public setOptions (opts: undefined | WorkerChoiceStrategyOptions): void {
+ public override setOptions (
+ opts: undefined | WorkerChoiceStrategyOptions
+ ): void {
super.setOptions(opts)
this.roundWeights = this.getRoundWeights()
}
extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
implements IWorkerChoiceStrategy {
/** @inheritDoc */
- public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
- elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
- runTime: {
- aggregate: true,
- average: false,
- median: false,
- },
- waitTime: {
- aggregate: true,
- average: false,
- median: false,
- },
- }
+ public override readonly taskStatisticsRequirements: TaskStatisticsRequirements =
+ {
+ elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+ runTime: {
+ aggregate: true,
+ average: false,
+ median: false,
+ },
+ waitTime: {
+ aggregate: true,
+ average: false,
+ median: false,
+ },
+ }
/** @inheritDoc */
public constructor (
extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
implements IWorkerChoiceStrategy {
/** @inheritDoc */
- public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
- elu: {
- aggregate: true,
- average: false,
- median: false,
- },
- runTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
- waitTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
- }
+ public override readonly taskStatisticsRequirements: TaskStatisticsRequirements =
+ {
+ elu: {
+ aggregate: true,
+ average: false,
+ median: false,
+ },
+ runTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+ waitTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+ }
/** @inheritDoc */
public constructor (
private workerNodeVirtualTaskExecutionTime = 0
/** @inheritDoc */
- public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
- elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
- runTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- waitTime: {
- aggregate: true,
- average: true,
- median: false,
- },
- }
+ public override readonly taskStatisticsRequirements: TaskStatisticsRequirements =
+ {
+ elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+ runTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ waitTime: {
+ aggregate: true,
+ average: true,
+ median: false,
+ },
+ }
/** @inheritDoc */
public constructor (
}
/** @inheritDoc */
- protected checkAndEmitDynamicWorkerCreationEvents (): void {
+ protected override checkAndEmitDynamicWorkerCreationEvents (): void {
if (this.emitter != null) {
if (!this.fullEventEmitted && this.full) {
this.emitter.emit(PoolEvents.full, this.info)
}
/** @inheritDoc */
- protected checkAndEmitDynamicWorkerDestructionEvents (): void {
+ protected override checkAndEmitDynamicWorkerDestructionEvents (): void {
if (this.emitter != null) {
if (this.fullEventEmitted && !this.full) {
this.emitter.emit(PoolEvents.fullEnd, this.info)
}
/** @inheritDoc */
- protected shallCreateDynamicWorker (): boolean {
+ protected override shallCreateDynamicWorker (): boolean {
return (!this.full && this.internalBusy()) || this.empty
}
/** @inheritDoc */
- protected get backPressure (): boolean {
+ protected override get backPressure (): boolean {
return this.full && this.internalBackPressure()
}
/** @inheritDoc */
- protected get busy (): boolean {
+ protected override get busy (): boolean {
return this.full && this.internalBusy()
}
}
/** @inheritDoc */
- protected get type (): PoolType {
+ protected override get type (): PoolType {
return PoolTypes.dynamic
}
}
/**
* @inheritDoc
*/
- protected handleError (error: Error | string): string {
+ protected override handleError (error: Error | string): string {
return error as string
}
/** @inheritDoc */
- protected handleKillMessage (message: MessageValue<Data>): void {
+ protected override handleKillMessage (message: MessageValue<Data>): void {
super.handleKillMessage(message)
this.port?.unref()
this.port?.close()
"declarationDir": "./lib/dts",
"strict": true,
"verbatimModuleSyntax": true,
- "forceConsistentCasingInFileNames": true
+ "forceConsistentCasingInFileNames": true,
+ "noImplicitOverride": true
},
"include": ["**/*.ts"],
"exclude": ["node_modules", "lib"]