use Default instead of Impl

Signed-off-by: Johan Haals <johan.haals@gmail.com>
This commit is contained in:
Johan Haals
2021-04-20 10:56:47 +02:00
parent e7532b96ed
commit 6c4aaa8495
8 changed files with 17 additions and 17 deletions
@@ -27,7 +27,7 @@ import { Logger } from 'winston';
import { stringifyEntityRef } from '@backstage/catalog-model';
import { Stitcher } from './Stitcher';
export class CatalogProcessingEngineImpl implements CatalogProcessingEngine {
export class DefaultCatalogProcessingEngine implements CatalogProcessingEngine {
private subscriptions: Subscription[] = [];
private running: boolean = false;
@@ -82,7 +82,7 @@ function toAbsoluteUrl(
}
}
export class CatalogProcessingOrchestratorImpl
export class DefaultCatalogProcessingOrchestrator
implements CatalogProcessingOrchestrator {
constructor(
private readonly options: {
@@ -26,7 +26,7 @@ export type LocationMessage =
| { all: Location[] }
| { added: Location[]; removed: Location[] };
export class LocationStoreImpl implements LocationStore {
export class DefaultLocationStore implements LocationStore {
private subscribers = new Set<
ZenObservable.SubscriptionObserver<LocationMessage>
>();
@@ -22,7 +22,7 @@ import {
ProcessingStateManager,
} from './types';
export class ProcessingStateManagerImpl implements ProcessingStateManager {
export class DefaultProcessingStateManager implements ProcessingStateManager {
constructor(private readonly db: ProcessingDatabase) {}
async setProcessingItemResult(result: ProcessingItemResult) {
@@ -26,7 +26,7 @@ import {
CatalogProcessingOrchestrator,
} from './types';
export class LocationServiceImpl implements LocationService {
export class DefaultLocationService implements LocationService {
constructor(
private readonly store: LocationStore,
private readonly orchestrator: CatalogProcessingOrchestrator,
@@ -64,12 +64,12 @@ import {
} from '../ingestion/processors/PlaceholderProcessor';
import { defaultEntityDataParser } from '../ingestion/processors/util/parse';
import { LocationAnalyzer } from '../ingestion/types';
import { CatalogProcessingEngineImpl } from '../next/CatalogProcessingEngineImpl';
import { CatalogProcessingOrchestratorImpl } from '../next/CatalogProcessingOrchestratorImpl';
import { ProcessingDatabaseImpl } from '../next/database/ProcessingDatabaseImpl';
import { DefaultCatalogProcessingEngine } from './DefaultCatalogProcessingEngine';
import { DefaultCatalogProcessingOrchestrator } from './DefaultCatalogProcessingOrchestrator';
import { DefaultProcessingDatabase } from './database/DefaultProcessingDatabase';
import { DatabaseLocationProvider } from '../next/DatabaseLocationProvider';
import { LocationStoreImpl } from '../next/LocationStoreImpl';
import { ProcessingStateManagerImpl } from '../next/ProcessingStateManagerImpl';
import { DefaultLocationStore } from './DefaultLocationStore';
import { DefaultProcessingStateManager } from './DefaultProcessingStateManager';
import { CatalogProcessingEngine } from '../next/types';
import { NextEntitiesCatalog } from './NextEntitiesCatalog';
import { Stitcher } from './Stitcher';
@@ -259,10 +259,10 @@ export class NextCatalogBuilder {
});
const db = new CommonDatabase(dbClient, logger);
const processingDatabase = new ProcessingDatabaseImpl(dbClient, logger);
const stateManager = new ProcessingStateManagerImpl(processingDatabase);
const processingDatabase = new DefaultProcessingDatabase(dbClient, logger);
const stateManager = new DefaultProcessingStateManager(processingDatabase);
const integrations = ScmIntegrations.fromConfig(config);
const orchestrator = new CatalogProcessingOrchestratorImpl({
const orchestrator = new DefaultCatalogProcessingOrchestrator({
processors,
integrations,
logger,
@@ -271,10 +271,10 @@ export class NextCatalogBuilder {
});
const entitiesCatalog = new NextEntitiesCatalog(dbClient);
const locationStore = new LocationStoreImpl(db);
const locationStore = new DefaultLocationStore(db);
const dbLocationProvider = new DatabaseLocationProvider(locationStore);
const stitcher = new Stitcher(dbClient, logger);
const processingEngine = new CatalogProcessingEngineImpl(
const processingEngine = new DefaultCatalogProcessingEngine(
logger,
[dbLocationProvider], // entityproviders
stateManager,
+1 -1
View File
@@ -22,7 +22,7 @@ import {
DbRefreshStateReferences,
DbRefreshStateRow,
DbRelationsRow,
} from './database/ProcessingDatabaseImpl';
} from './database/DefaultProcessingDatabase';
import { Entity, parseEntityRef } from '@backstage/catalog-model';
import { createHash } from 'crypto';
import stableStringify from 'fast-json-stable-stringify';
@@ -59,7 +59,7 @@ export type DbRefreshStateReferences = {
// enough to get the speed benefits.
const BATCH_SIZE = 50;
export class ProcessingDatabaseImpl implements ProcessingDatabase {
export class DefaultProcessingDatabase implements ProcessingDatabase {
constructor(
private readonly database: Knex,
private readonly logger: Logger,