機能フラグ

# config/shannon.yaml
features:
  # エンタープライズワークフロー機能
  ads_research: false              # 広告リサーチワークフロー（エンタープライズ）
  advanced_synthesis: false        # 高度な合成テンプレート

  # 実験的機能
  parallel_streaming: true         # マルチエージェントの並列ストリーミング
  enhanced_memory: false           # 拡張ベクトルメモリ

  # カスタム統合
  vendor_tools_enabled: false      # ベンダー固有のツールを有効にする

# .env
SHANNON_FEATURE_ADS_RESEARCH=true
SHANNON_FEATURE_PARALLEL_STREAMING=false

package main

import (
    "github.com/Kocoro-lab/Shannon/go/orchestrator/internal/config"
)

func routeWorkflow(ctx context.Context, req *pb.Request) error {
    cfg, _ := config.LoadShannon()

    // フィーチャーフラグをチェック
    if cfg.Features.AdsResearch {
        return routeToAdsResearchWorkflow(ctx, req)
    }

    return routeToStandardWorkflow(ctx, req)
}

from llm_service.config import load_shannon_config

config = load_shannon_config()

# フィーチャーフラグをチェック
if config.get("features", {}).get("vendor_tools_enabled"):
    from llm_service.tools.vendor import register_vendor_tools
    register_vendor_tools()

# roles/presets.py
_PRESETS = {
    "general": GENERAL_PRESET,
    "research": RESEARCH_PRESET,
}

# エンタープライズロールを条件付きで読み込む
if config.get("features", {}).get("ads_research"):
    try:
        from .enterprise.ads_analyst import ADS_ANALYST_PRESET
        _PRESETS["ads_analyst"] = ADS_ANALYST_PRESET
    except ImportError:
        pass  # Shannonはエンタープライズモジュールなしで動作します

# config/shannon.yaml
features:
  new_feature: false  # ✅ 安全なデフォルト

# config/overlays/shannon.production.yaml
features:
  ads_research: true
  parallel_streaming: true
  enhanced_memory: false  # まだテスト中

SHANNON_CONFIG_PATH=config/overlays/shannon.production.yaml

if config.features.vendor_tools_enabled:
    try:
        from .vendor import CustomVendorTool
    except ImportError:
        logger.warning("ベンダーツールが利用できないため、標準ツールを使用します")

features:
  # GA4_SERVICE_ACCOUNT_KEY環境変数が必要
  # ベンダーモジュール: llm_service/tools/vendor_adapters/ga4/
  ga4_integration: false

Shannon/
├── config/
│   ├── shannon.yaml                    # ベース設定（OSS）
│   └── overlays/
│       └── shannon.enterprise.yaml     # エンタープライズフラグ
├── go/orchestrator/
│   └── internal/workflows/
│       ├── standard_workflow.go        # OSSワークフロー
│       └── enterprise/                 # エンタープライズワークフロー
│           └── ads_research.go         # フラグで制限
└── python/llm-service/
    └── llm_service/
        ├── roles/
        │   ├── presets.py              # OSSロール + 条件付き読み込み
        │   └── enterprise/             # エンタープライズロール
        │       └── ads_analyst.py      # フラグで制限
        └── tools/
            └── vendor_adapters/        # ベンダーツール（制限付き）

// orchestrator/internal/workflows/router.go
func SelectWorkflow(ctx context.Context, cfg *config.Shannon, req *pb.Request) Workflow {
    // エンタープライズ機能フラグの確認
    if cfg.Features.AdsResearch && req.Context["workflow_type"] == "ads_research" {
        return NewAdsResearchWorkflow()
    }

    // OSSワークフローにフォールバック
    return NewStandardWorkflow()
}

func TestAdsResearchWorkflow(t *testing.T) {
    cfg := &config.Shannon{
        Features: config.FeatureFlagsConfig{
            AdsResearch: true,  // テスト用に有効化
        },
    }

    workflow := SelectWorkflow(context.Background(), cfg, testReq)
    assert.IsType(t, &AdsResearchWorkflow{}, workflow)
}

# 機能を有効にしてテストを実行
SHANNON_FEATURE_ADS_RESEARCH=true go test ./...

# 機能を無効にしてテストを実行（OSSモード）
SHANNON_FEATURE_ADS_RESEARCH=false go test ./...

func isFeatureEnabled(userID string, featureName string) bool {
    // ユーザー固有の機能フラグを確認（例：データベースから）
    if userHasAccess(userID, featureName) {
        return true
    }

    // グローバル設定にフォールバック
    return cfg.Features.Get(featureName)
}

if experimentGroup(userID) == "variant_a" && cfg.Features.EnhancedMemory {
    return useEnhancedMemory(ctx, req)
}
return useStandardMemory(ctx, req)

logger.Info("Feature flag check",
    zap.String("feature", "ads_research"),
    zap.Bool("enabled", cfg.Features.AdsResearch),
    zap.String("user_id", userID),
)

featureFlagGauge.WithLabelValues("ads_research").Set(
    boolToFloat64(cfg.Features.AdsResearch),
)