Function NewCache

server/controller/recorder/cache/cache.go:98–112

(ctx context.Context, md *rcommon.Metadata, selfHealInterval time.Duration)

}

func NewCache(ctx context.Context, md *rcommon.Metadata, selfHealInterval time.Duration) *Cache {
	c := &Cache{
		ctx: ctx,

		metadata: md,

		SelfHealInterval: selfHealInterval + time.Duration(rand.Intn(60))*time.Minute, // add random interval to avoid all cache refresh at once
		RefreshSignal:    make(chan struct{}, 1),
		DiffBaseDataSet:  diffbase.NewDataSet(md), // 所有资源的主要信息，用于与cloud数据比较差异，根据差异更新资源
		ToolDataSet:      tool.NewDataSet(md),     // 各类资源的映射关系，用于按需进行数据转换
	}
	c.tagrecorderHealers = tagrecorderHealer.NewHealers(md.Platform)
	c.StartSelfHealing()
	return c
}

func (c *Cache) GetMetadata() *rcommon.Metadata {
	return c.metadata