# 数据库配置
database:
  host: "localhost"
  port: 3306
  user: "root"
  password: "password"
  database: "test_db"
  server_id: 100  # 唯一标识，避免与主从复制冲突
  charset: "utf8mb4"  # 可选，默认 utf8mb4

# 日志配置
log:
  level: "info"  # debug, info, warn, error, fatal, panic
  format: "text" # text, json

# HTTP 服务器配置
server:
  enabled: true    # 是否启用健康检查服务器
  port: 8080       # 服务器端口
  path: "/health"  # 健康检查路径

# 分发器配置 (性能优化)
dispatcher:
  worker_count: 20         # 工作协程数量 (推荐: CPU核心数 * 2)
  queue_size: 1000         # 队列大小 (支持突发流量)
  timeout: 30s             # HTTP请求超时
  max_retries: 3           # 最大重试次数
  retry_base_delay: 5s     # 重试基础延迟 (最小3s)
  max_connections: 100     # 最大连接数

# 监控器配置
monitor:
  event_queue_size: 10000  # 事件队列大小 (高负载优化)
  event_queue_timeout: 2s  # 事件队列超时时间 (快速响应)

# 可选：回调主机地址（用于相对路径的回调URL）
callback_host: "http://localhost:3000"

tasks:
# 基础示例：监控用户表所有变更
- task_id: "user_monitor"
  name: "用户表变更监控"
  table_name: "users"
  events: ["insert", "update", "delete"]
  callback_url: "/webhook/user"  # 相对路径

# 高级示例：只监控订单表的插入和更新
- task_id: "order_monitor"
  name: "订单表变更监控"
  table_name: "orders"
  events: ["insert", "update"]  # 不监控删除事件
  callback_url: "https://api.example.com/webhook/order"  # 绝对路径

# 特殊表名示例：MySQL关键字表名
- task_id: "keyword_table_monitor"
  name: "关键字表名监控"
  table_name: "order"  # 'order' 是MySQL关键字，系统自动处理
  events: ["insert", "update", "delete"]
  callback_url: "/webhook/order"

# 复杂表名示例：特殊字符和数字开头
- task_id: "complex_table_monitor"
  name: "复杂表名监控"
  table_name: "2024_user-activity_log"  # 包含连字符和数字开头
  events: ["insert"]
  callback_url: "/webhook/activity"

# 生产环境示例：外部API回调
- task_id: "production_sync"
  name: "生产环境数据同步"
  table_name: "sync_data"
  events: ["update"]
  callback_url: "https://external-api.company.com/v1/sync"

log:
  level: "debug"
  format: "text"

dispatcher:
  worker_count: 2
  queue_size: 50

monitor:
  event_queue_size: 100

log:
  level: "warn"
  format: "json"

dispatcher:
  worker_count: 10
  queue_size: 500
  timeout: 60s
  max_retries: 5

monitor:
  event_queue_size: 2000

- task_id: "order_monitor"
  table_name: "order"  # 'order' 是MySQL关键字，系统自动处理

- task_id: "special_table_monitor"
  table_name: "my-table"  # 包含连字符，系统自动处理

- task_id: "numeric_table_monitor"
  table_name: "2024_orders"  # 以数字开头，系统自动处理

version: '3.8'

services:
  pikachu:
    image: pikachu:latest
    container_name: pikachu-prod
    restart: unless-stopped

    # 环境变量
    environment:
      - TZ=Asia/Shanghai

    # 端口映射
    ports:
      - "8080:8080"

    # 卷挂载
    volumes:
      - ./config.prod.yaml:/app/config.yaml:ro
      - ./tasks.yaml:/app/tasks.yaml:ro
      - /data/logs/pikachu:/app/logs
      - /etc/localtime:/etc/localtime:ro

    # 资源限制
    deploy:
      resources:
        limits:
          memory: 512M
          cpus: '0.5'
        reservations:
          memory: 128M
          cpus: '0.1'

    # 健康检查
    healthcheck:
      test: ["CMD", "wget", "--no-verbose", "--tries=1", "--spider", "http://localhost:8080/health"]
      interval: 30s
      timeout: 10s
      retries: 3
      start_period: 40s

    # 网络配置
    networks:
      - pikachu-network

    # 日志配置
    logging:
      driver: "json-file"
      options:
        max-size: "10m"
        max-file: "3"

networks:
  pikachu-network:
    driver: bridge

apiVersion: apps/v1
kind: Deployment
metadata:
  name: pikachu
  namespace: monitoring
  labels:
    app: pikachu
spec:
  replicas: 2
  selector:
    matchLabels:
      app: pikachu
  template:
    metadata:
      labels:
        app: pikachu
    spec:
      containers:
      - name: pikachu
        image: pikachu:latest
        ports:
        - containerPort: 8080
          name: http
        env:
        - name: TZ
          value: "Asia/Shanghai"
        volumeMounts:
        - name: config
          mountPath: /app/config.yaml
          subPath: config.yaml
          readOnly: true
        - name: config
          mountPath: /app/tasks.yaml
          subPath: tasks.yaml
          readOnly: true
        - name: logs
          mountPath: /app/logs
        resources:
          requests:
            memory: "128Mi"
            cpu: "100m"
          limits:
            memory: "512Mi"
            cpu: "500m"
        livenessProbe:
          httpGet:
            path: /health
            port: 8080
          initialDelaySeconds: 30
          periodSeconds: 10
        readinessProbe:
          httpGet:
            path: /health
            port: 8080
          initialDelaySeconds: 5
          periodSeconds: 5
      volumes:
      - name: config
        configMap:
          name: pikachu-config
      - name: logs
        emptyDir: {}

---
apiVersion: v1
kind: Service
metadata:
  name: pikachu-service
  namespace: monitoring
spec:
  selector:
    app: pikachu
  ports:
  - protocol: TCP
    port: 80
    targetPort: 8080
    name: http
  type: ClusterIP

log:
  level: "debug"
  format: "text"

dispatcher:
  worker_count: 2
  queue_size: 50
  timeout: 10s

monitor:
  event_queue_size: 100

log:
  level: "warn"
  format: "json"

dispatcher:
  worker_count: 10-20  # 根据 CPU 核心数调整
  queue_size: 500-1000  # 根据内存容量调整
  timeout: 60s
  max_retries: 5

monitor:
  event_queue_size: 2000-5000

# 高并发场景配置
dispatcher:
  worker_count: 50        # 更多工作协程
  queue_size: 2000       # 更大的队列
  timeout: 120s          # 更长的超时时间
  max_retries: 10        # 更多重试次数
  retry_base_delay: 30s  # 更长的重试间隔

monitor:
  event_queue_size: 10000  # 更大的事件队列

# 用户服务 -> 订单服务 数据同步
tasks:
- task_id: "user_sync_to_order"
  name: "用户信息同步到订单服务"
  table_name: "users"
  events: ["update"]  # 只同步用户信息变更
  callback_url: "https://order-service.internal/api/user-updates"

- task_id: "profile_sync_to_notification"
  name: "用户资料同步到通知服务"
  table_name: "user_profiles"
  events: ["insert", "update"]
  callback_url: "/api/sync/user-profile"  # 相对路径，使用 callback_host

# 商品表变更 -> Elasticsearch 索引更新
tasks:
- task_id: "product_index_update"
  name: "商品搜索引擎索引更新"
  table_name: "products"
  events: ["insert", "update", "delete"]
  callback_url: "https://search-service.internal/index/product"

- task_id: "category_index_update"
  name: "分类索引更新"
  table_name: "product_categories"
  events: ["insert", "update", "delete"]
  callback_url: "https://search-service.internal/index/category"

# 敏感操作审计日志
tasks:
- task_id: "financial_audit"
  name: "财务操作审计"
  table_name: "financial_transactions"
  events: ["insert", "update", "delete"]
  callback_url: "https://audit-service.internal/log/financial"

- task_id: "user_action_audit"
  name: "用户操作审计"
  table_name: "user_action_logs"
  events: ["insert"]
  callback_url: "https://audit-service.internal/log/user-actions"

# 数据变更 -> Redis 缓存失效
tasks:
- task_id: "cache_invalidation"
  name: "缓存失效通知"
  table_name: "user_preferences"
  events: ["update", "delete"]
  callback_url: "https://cache-service.internal/invalidate/user"

- task_id: "product_cache_invalidation"
  name: "商品缓存失效"
  table_name: "products"
  events: ["update", "delete"]
  callback_url: "https://cache-service.internal/invalidate/product"

# 实时通知 -> WebSocket 服务
tasks:
- task_id: "realtime_notification"
  name: "实时数据推送"
  table_name: "notifications"
  events: ["insert"]
  callback_url: "https://websocket-service.internal/push/notification"

- task_id: "order_status_update"
  name: "订单状态实时推送"
  table_name: "order_status_history"
  events: ["insert"]
  callback_url: "https://websocket-service.internal/push/order-status"

# OLTP -> OLAP 数据同步
tasks:
- task_id: "data_warehouse_sync"
  name: "数据仓库同步"
  table_name: "sales_transactions"
  events: ["insert", "update"]
  callback_url: "https://data-warehouse.internal/api/sync/sales"

- task_id: "analytics_sync"
  name: "分析数据同步"
  table_name: "user_behavior_events"
  events: ["insert"]
  callback_url: "https://analytics-service.internal/api/events"

# 业务流程自动化触发
tasks:
- task_id: "order_workflow"
  name: "订单工作流触发"
  table_name: "orders"
  events: ["insert", "update"]
  callback_url: "https://workflow-service.internal/trigger/order-process"

- task_id: "inventory_restock"
  name: "库存补货触发"
  table_name: "inventory"
  events: ["update"]
  callback_url: "https://inventory-service.internal/trigger/restock"