summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-03-24 16:43:42 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-03-24 16:43:42 +0900
commite4380911135b1aff7c85770d6dabb3e72e9874e7 (patch)
tree30e1f4ec68d407708e55e612456676c33c048a97 /packages/backend/src/queue
parentMerge branch 'develop' of https://github.com/misskey-dev/misskey into develop (diff)
downloadsharkey-e4380911135b1aff7c85770d6dabb3e72e9874e7.tar.gz
sharkey-e4380911135b1aff7c85770d6dabb3e72e9874e7.tar.bz2
sharkey-e4380911135b1aff7c85770d6dabb3e72e9874e7.zip
refactor(backend): rename cache class
Diffstat (limited to 'packages/backend/src/queue')
-rw-r--r--packages/backend/src/queue/processors/DeliverProcessorService.ts6
1 files changed, 3 insertions, 3 deletions
diff --git a/packages/backend/src/queue/processors/DeliverProcessorService.ts b/packages/backend/src/queue/processors/DeliverProcessorService.ts
index 43a92bb267..34e1ddfc84 100644
--- a/packages/backend/src/queue/processors/DeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeliverProcessorService.ts
@@ -7,7 +7,7 @@ import { MetaService } from '@/core/MetaService.js';
import { ApRequestService } from '@/core/activitypub/ApRequestService.js';
import { FederatedInstanceService } from '@/core/FederatedInstanceService.js';
import { FetchInstanceMetadataService } from '@/core/FetchInstanceMetadataService.js';
-import { Cache } from '@/misc/cache.js';
+import { KVCache } from '@/misc/cache.js';
import type { Instance } from '@/models/entities/Instance.js';
import InstanceChart from '@/core/chart/charts/instance.js';
import ApRequestChart from '@/core/chart/charts/ap-request.js';
@@ -22,7 +22,7 @@ import type { DeliverJobData } from '../types.js';
@Injectable()
export class DeliverProcessorService {
private logger: Logger;
- private suspendedHostsCache: Cache<Instance[]>;
+ private suspendedHostsCache: KVCache<Instance[]>;
private latest: string | null;
constructor(
@@ -46,7 +46,7 @@ export class DeliverProcessorService {
private queueLoggerService: QueueLoggerService,
) {
this.logger = this.queueLoggerService.logger.createSubLogger('deliver');
- this.suspendedHostsCache = new Cache<Instance[]>(1000 * 60 * 60);
+ this.suspendedHostsCache = new KVCache<Instance[]>(1000 * 60 * 60);
}
@bindThis