my-platform/
├── services/           # Your microservices
│   ├── orders/
│   └── notifications/
├── packages/
│   └── contracts/      # Event contracts (single source of truth)
├── infra/
│   └── services/       # Auto-generated Pulumi configs
└── .env.local          # Auto-generated from infra

关键见解是: 服务定义了它们的端口,env vars,以及一次活动订阅. 其他一切皆从所出.

{
  "pf": {
    "registry": "my-org/my-platform",
    "commands": {
      "deploy": {
        "cwd": "infra",
        "command": "pulumi up --yes",
        "description": "Deploy infrastructure to production"
      }
    },
    "paths": {
      "services": { "path": "services", "watch": true },
      "contracts": { "path": "packages/contracts" }
    }
  }
}

// infra/services/orders.ts
import { ports, type K8sServiceConfig } from '@crossdelta/infrastructure'

const config: K8sServiceConfig = {
  name: 'orders',
  ports: ports().http(4001).build(),
  replicas: 1,
  healthCheck: { httpPath: '/health' },
  resources: {
    requests: { cpu: '50m', memory: '64Mi' },
    limits: { cpu: '150m', memory: '128Mi' },
  },
}

export default config

见 @ crossdelta/ 基础设施 完全选择.

合同 住在这里 packages/contracts/ 作为真理的唯一来源:

// packages/contracts/src/events/orders/created.ts
import { createContract } from '@crossdelta/cloudevents'
import { z } from 'zod'

export const OrderCreatedSchema = z.object({
  orderId: z.string(),
  total: z.number(),
})

export type OrderCreatedData = z.infer<typeof OrderCreatedSchema>

export const OrdersCreatedContract = createContract({
  type: 'order.created',
  channel: { stream: 'ORDERS' },
  schema: OrderCreatedSchema,
})

处理器 进口合同和授权使用案件:

// services/notifications/src/events/order-created.handler.ts
import { handleEvent } from '@crossdelta/cloudevents'
import { OrdersCreatedContract } from '@my-platform/contracts'
import { sendOrderNotification } from '../use-cases/send-notification.use-case'

export default handleEvent(OrdersCreatedContract, async (data) => {
  await sendOrderNotification(data)
})

掌柜是自动发现的 无人工订阅.

见 @ crossdelta/ clodevents (英语) (原始内容存档于2018-10-21). For full event API.

本地NATS 开始于 pf dev 发展基础设施. 生产流是通过合同中的Pulumi实现的.

每个工作空间包括预配置的有JetStream用于开发的NATS:

发展:

• 自动启动 pf dev (以多克为主,以麻黄为主
• 端口 : 4222 (客户), 8222 (监测)
• 健康检查: curl http://localhost:8222/healthz
• 流: 由 : pf dev (备忘录,保留1小时)

生产:

• 通过普鲁米部署(infra/(中文(简体) )
• 采用保留政策的合同的流程
• 有明确限制的持久储存(基于文件)

服务从不创建流. 在德夫语中, pf dev 自动创建合同。 在prod中,普鲁米实现.