ライフサイクルと統計

Processor はライフサイクル管理、キャッシュ制御、ヘルスモニタリング機能を完全に提供します。

ライフサイクル

Close

シグネチャ：func (p *Processor) Close() error

プロセッサを閉じてリソースを解放します。Processor の使用後はこのメソッドを呼び出す必要があります。

processor, _ := json.New(json.DefaultConfig())
defer processor.Close()

IsClosed

シグネチャ：func (p *Processor) IsClosed() bool

プロセッサが閉じられているかどうかを確認します。

if processor.IsClosed() {
    // プロセッサは閉じられており、使用不可
}

キャッシュ管理

ClearCache

シグネチャ：func (p *Processor) ClearCache()

プロセッサの内部キャッシュをクリアします。

processor.ClearCache()

用途：

データソースが変更された場合
メモリ使用量が高すぎる場合
強制リフレッシュが必要な場合

WarmupCache

シグネチャ：func (p *Processor) WarmupCache(jsonStr string, paths []string, cfg ...Config) (*WarmupResult, error)

キャッシュをウォームアップし、以降の操作のパフォーマンスを向上させます。

paths := []string{"user.name", "user.email", "items[*].id"}
result, err := processor.WarmupCache(data, paths)
if err != nil {
    panic(err)
}
fmt.Printf("%d 個のパスのウォームアップに成功\n", result.Successful)

WarmupResult 構造体：

type WarmupResult struct {
    TotalPaths  int      `json:"total_paths"`            // 総パス数
    Successful  int      `json:"successful"`             // ウォームアップ成功したパス数
    Failed      int      `json:"failed"`                 // 失敗したパス数
    SuccessRate float64  `json:"success_rate"`           // 成功率（パーセント）
    FailedPaths []string `json:"failed_paths,omitempty"` // 失敗したパスのリスト
}

フィールド	型	説明
`TotalPaths`	`int`	総パス数
`Successful`	`int`	ウォームアップ成功したパス数
`Failed`	`int`	失敗したパス数
`SuccessRate`	`float64`	成功率（0-100）
`FailedPaths`	`[]string`	失敗したパスのリスト

統計情報

GetStats

シグネチャ：func (p *Processor) GetStats() Stats

プロセッサの統計情報を取得します。

stats := processor.GetStats()
fmt.Printf("キャッシュヒット率：%.2f%%\n", stats.HitRatio * 100)
fmt.Printf("キャッシュサイズ：%d\n", stats.CacheSize)

Stats 構造体：

type Stats struct {
    CacheSize        int64         `json:"cache_size"`        // キャッシュエントリ数
    CacheMemory      int64         `json:"cache_memory"`      // キャッシュメモリ使用量（バイト）
    MaxCacheSize     int           `json:"max_cache_size"`    // 最大キャッシュサイズ
    HitCount         int64         `json:"hit_count"`         // キャッシュヒット回数
    MissCount        int64         `json:"miss_count"`        // キャッシュミス回数
    HitRatio         float64       `json:"hit_ratio"`         // キャッシュヒット率
    CacheTTL         time.Duration `json:"cache_ttl"`         // キャッシュ TTL
    CacheEnabled     bool          `json:"cache_enabled"`     // キャッシュが有効かどうか
    IsClosed         bool          `json:"is_closed"`         // プロセッサが閉じられているかどうか
    MemoryEfficiency float64       `json:"memory_efficiency"` // メモリ効率
    OperationCount   int64         `json:"operation_count"`   // 総操作回数
    ErrorCount       int64         `json:"error_count"`       // 総エラー回数
}

フィールド	型	説明
`CacheSize`	`int64`	現在のキャッシュエントリ数
`CacheMemory`	`int64`	キャッシュメモリ使用量（バイト）
`MaxCacheSize`	`int`	最大キャッシュサイズ制限
`HitCount`	`int64`	キャッシュヒット回数
`MissCount`	`int64`	キャッシュミス回数
`HitRatio`	`float64`	キャッシュヒット率（0-1）
`CacheTTL`	`time.Duration`	キャッシュ有効期限
`CacheEnabled`	`bool`	キャッシュが有効かどうか
`IsClosed`	`bool`	プロセッサが閉じられているかどうか
`MemoryEfficiency`	`float64`	メモリ効率
`OperationCount`	`int64`	総操作回数
`ErrorCount`	`int64`	総エラー回数

ヘルスチェック

GetHealthStatus

シグネチャ：func (p *Processor) GetHealthStatus() HealthStatus

プロセッサのヘルス状態を取得します。

status := processor.GetHealthStatus()
if status.Healthy {
    fmt.Println("プロセッサは正常です")
} else {
    for name, check := range status.Checks {
        if !check.Healthy {
            fmt.Printf("チェック %s 失敗: %s\n", name, check.Message)
        }
    }
}

HealthStatus 構造体：

type HealthStatus struct {
    Timestamp time.Time              `json:"timestamp"` // チェック時刻
    Healthy   bool                   `json:"healthy"`   // 全体的なヘルス状態
    Checks    map[string]CheckResult `json:"checks"`    // 各チェックの結果
}

type CheckResult struct {
    Healthy bool   `json:"healthy"` // 正常かどうか
    Message string `json:"message"` // ステータスメッセージ
}

フィールド	型	説明
`Timestamp`	`time.Time`	チェック時刻
`Healthy`	`bool`	全体的に正常かどうか
`Checks`	`map[string]CheckResult`	各チェックの詳細

拡張フック

AddHook

シグネチャ：func (p *Processor) AddHook(hook Hook)

操作フックをプロセッサに追加します。

processor.AddHook(&LoggingHook{})
processor.AddHook(json.TimingHook(&MetricsRecorder{}))

フックは各操作の前後に呼び出され、以下の用途に使用できます：

ログ記録
パフォーマンス監視
メトリクス収集
監査トレース

SetLogger

シグネチャ：func (p *Processor) SetLogger(logger *slog.Logger)

プロセッサのロガーを設定します。デバッグやランタイム診断に使用します。

processor, _ := json.New()
defer processor.Close()

processor.SetLogger(slog.Default().With("component", "json-processor"))

GetConfig

シグネチャ：func (p *Processor) GetConfig() Config

プロセッサの現在の設定コピーを取得します。返された設定は安全に変更でき、プロセッサには影響しません。

processor, _ := json.New()
defer processor.Close()

cfg := processor.GetConfig()
fmt.Printf("キャッシュ有効: %v\n", cfg.EnableCache)
fmt.Printf("最大 JSON サイズ：%d\n", cfg.MaxJSONSize)

使用のヒント

リソース管理

processor, _ := json.New()
defer processor.Close()  // リソースの解放を確実に

// processor を使用...

パフォーマンス最適化

// よく使用するパスをウォームアップ
processor.WarmupCache(data, []string{
    "user.name",
    "user.email",
    "items[*].id",
})

// 定期的に統計を確認
stats := processor.GetStats()
if stats.HitRatio < 0.5 {
    // ヒット率が低い場合、キャッシュ設定の調整を検討
}

監視の統合

// 定期的なヘルスチェック
go func() {
    ticker := time.NewTicker(30 * time.Second)
    for range ticker.C {
        status := processor.GetHealthStatus()
        if !status.Healthy {
            log.Printf("Processor unhealthy: %+v", status.Checks)
        }
    }
}()

ライフサイクルと統計 ​