import { setup } from '@backtest-kit/pg';
setup({
  CC_POSTGRES_CONNECTION_STRING: 'postgres://backtest:secret@postgres:5432/mydb',
  CC_REDIS_HOST: 'redis', CC_REDIS_PORT: 6379, CC_REDIS_PASSWORD: 'secret',
});

转至的值 setup() 编号 : setConfig() 永远优于地狱之地 在CLI内部,放 setup() 内 config/setup.config.ts ——当存在时, CLI 跳过其默认的文件适应器注册和您的配置本身的持久性.

• 蜡烛是永恒的 ——先写胜;后写同 (exchangeName, symbol, interval, timestamp) 被默默忽略 通过一个不开放 DO UPDATE 从未触及过 OHLCV 列(历史的 OHLCV 从未改变).
• 其他人都会用 DO UPDATE SET payload = EXCLUDED.payload ——每个写入取代了以前的值.
• 度量/ 中间/ 内存软删除 —— 说 removeMeasureData 编号 : removeIntervalData 编号 : removeMemoryData 设定 removed = true 而不是删除; 在 removed = false保持完整的审计线索.

每个域有两层:a 服务 (后SQL)和a 缓存服务 (瑞地语). 上下文密钥的读取状态 id 首先,一个命中是两个 O(1) 行动,一个错落到一个索引 findOne 和回填雷迪斯.

read signal for (BTCUSDT, my_strategy, binance)
  ├─ Redis GET → hit  → Postgres findByFilter({ id })   ← O(1) + O(1)
  └─ Redis GET → miss → Postgres findByFilter(filter) → Redis SET → return

在每次写完Redis条目后,都会在同一通电话中刷新,所以写到时读总是会点击缓存.

反测试- kit 需要一次 write*Data() 返回,下一个 read*Data() 看到了新的价值。 每个字都是一个 INSERT … ON CONFLICT … RETURNING 圆通:

const { raw } = await repo
  .createQueryBuilder()
  .insert()
  .values({ symbol, strategyName, exchangeName, payload })
  .orUpdate(["payload"], ["symbol", "strategyName", "exchangeName"])
  .returning("*")
  .execute();
await signalCacheService.setSignalId(raw[0]);

冲突目标匹配独特的复合索引,所以PostgreSQL序列化了存储引擎上任何同时插入的重复——输家取下 DO UPDATE 分支而不是抛出;返回的行被直接写到Redis上,使得下一个读取了O(1)的新数据.

数据影响决策的适配器(风险、部分、断层、最近、状态、预算、会话、记忆、间隔)存储 when: bigint 模拟时间戳以毫秒表示——与有效载荷并列,因此,反测试-基特可以验证没有读取返回数据 未来 模拟时间. 措施豁免 因为它缓存了 LLM / 外部- API 响应, 其中的外观- ahead 偏差没有意义 .

公众表面 —— 说 functions/setup.ts (单位:千美元)setup编号 :install编号 :setLogger, (中文(简体) ), config/params.ts (单位:千美元)setConfig编号 :getConfig, (中文(简体) ), index.ts 再出口+ getPostgres编号 :getRedis。 。 。 .

适配类 (单位:千美元)classes/Persist*Instance.ts,17)——各执行一回试-吻 IPersist*Instance dbService: 合同和代表 PersistCandleInstance, (中文(简体) ), PersistSignalInstance, (中文(简体) ), PersistStrategyInstance, (中文(简体) ), PersistScheduleInstance, (中文(简体) ), PersistRiskInstance, (中文(简体) ), PersistPartialInstance, (中文(简体) ), PersistBreakevenInstance, (中文(简体) ), PersistStorageInstance, (中文(简体) ), PersistNotificationInstance, (中文(简体) ), PersistLogInstance, (中文(简体) ), PersistMeasureInstance, (中文(简体) ), PersistIntervalInstance, (中文(简体) ), PersistMemoryInstance, (中文(简体) ), PersistRecentInstance, (中文(简体) ), PersistStateInstance, (中文(简体) ), PersistBudgetInstance, (中文(简体) ), PersistSessionInstance。 。 。 .

服务层 (单位:千美元)lib/services/:

• base/ —— 说 PostgresService (懒惰型ORM) DataSource, (中文(简体) ), RedisService (懒驴), LoggerService。 。 。 .
• db/ 一个 *DbService 每个域:TypeORM实体计划、独特的化合物指数和 INSERT … ON CONFLICT … RETURNING 上调逻辑.
• cache/ 一个 *CacheService 每个领域(CandleCacheService, (中文(简体) ), SignalCacheService, (中文(简体) ), BreakevenCacheService, (中文(简体) ), IntervalCacheService, (中文(简体) ), LogCacheService, (中文(简体) ), MeasureCacheService, (中文(简体) ), MemoryCacheService, (中文(简体) ), NotificationCacheService, (中文(简体) ), PartialCacheService, (中文(简体) ), RecentCacheService,...):雷迪丝 id o(1)取景图.

共享原始物 (单位:千美元)lib/common/(b) —— BaseCRUD (每一次DbService再利用的上升/读取/删除模式)和 BaseMap (Redis键映射模式每一次缓存服务回用).

DI 配置 —— 说 lib/core/{di,provide,types}.ts (IoC集装箱接线Db/Cache/基地服务), lib/index.ts (集装箱靴子), config/{postgres,redis,params}.ts (连接建设者+合并参数), interfaces/Logger.interface.ts。 。 。 .