recorder

README

代码架构

cache

各类资源缓存数据，定时基于mysql刷新数据，达到自愈效果。

• diff_base
  • 所有资源的主要信息，用于与cloud数据比较差异，根据差异更新资源。
• tool_map
  • 资源的映射关联关系，用于刷新资源时，转换所需数据。

updater

比较cloud数据与cache的差异，根据结果进行db、cache、资源变更事件增删改操作。

db

提供对资源的增删改操作。

Documentation

Overview

永久删除MySQL中超过7天的软删除云平台资源数据

提供获取recorder内部数据的debug接口

Index

• Constants
• Variables
• type Cleaner
• type Cleaners
  • func GetCleaners() *Cleaners
  • func (c *Cleaners) Create(orgID int)
  • func (c *Cleaners) Delete(orgID int)
  • func (c *Cleaners) Init(ctx context.Context, cfg config.RecorderConfig)
  • func (c *Cleaners) NewCleanerIfNotExists(orgID int) (*Cleaner, error)
  • func (c *Cleaners) Start(sContext context.Context) error
  • func (c *Cleaners) Stop()
• type Recorder
  • func NewRecorder(ctx context.Context, cfg config.RecorderConfig, ...) *Recorder
  • func (r *Recorder) GetCache(domainLcuuid, subDomainLcuuid string) cache.Cache
  • func (r *Recorder) GetCacheDiffBase(domainLcuuid, subDomainLcuuid, resourceType, resourceLcuuid string) interface{}
  • func (r *Recorder) GetCacheDiffBaseDataSet(domainLcuuid, subDomainLcuuid, resourceType string) map[string]interface{}
  • func (r *Recorder) GetToolMap(domainLcuuid, subDomainLcuuid, field string) map[interface{}]interface{}
  • func (r *Recorder) Refresh(target string, cloudData cloudmodel.Resource) error
• type Resource
  • func GetResource() *Resource
  • func (r *Resource) Init(ctx context.Context, cfg config.RecorderConfig) *Resource

Constants

const (
	RefreshTargetDomain = "domain"
	// RefreshTargetDomainExcludeSubDomain
	RefreshTargetSubDomain = "sub_domain"
)

Variables

var DataMissingError = errors.New("some data is missing")

var DataNotVerifiedError = errors.New("data is not verified")

var RefreshConflictError = errors.New("another operation is in progress")

Types

type Cleaner

type Cleaner struct {
	// contains filtered or unexported fields
}

type Cleaners

type Cleaners struct {
	// contains filtered or unexported fields
}

func GetCleaners

func GetCleaners() *Cleaners

func (*Cleaners) Create

func (c *Cleaners) Create(orgID int)

func (*Cleaners) Delete

func (c *Cleaners) Delete(orgID int)

func (*Cleaners) Init

func (c *Cleaners) Init(ctx context.Context, cfg config.RecorderConfig)

func (*Cleaners) NewCleanerIfNotExists

func (c *Cleaners) NewCleanerIfNotExists(orgID int) (*Cleaner, error)

func (*Cleaners) Start

func (c *Cleaners) Start(sContext context.Context) error

func (*Cleaners) Stop

func (c *Cleaners) Stop()

type Recorder

type Recorder struct {
	// contains filtered or unexported fields
}

func NewRecorder

func NewRecorder(ctx context.Context, cfg config.RecorderConfig, eventQueue *queue.OverwriteQueue, orgID int, domainLcuuid string) *Recorder

func (*Recorder) GetCache

func (r *Recorder) GetCache(domainLcuuid, subDomainLcuuid string) cache.Cache

TODO remove

func (*Recorder) GetCacheDiffBase

func (r *Recorder) GetCacheDiffBase(domainLcuuid, subDomainLcuuid, resourceType, resourceLcuuid string) interface{}

func (*Recorder) GetCacheDiffBaseDataSet

func (r *Recorder) GetCacheDiffBaseDataSet(domainLcuuid, subDomainLcuuid, resourceType string) map[string]interface{}

func (*Recorder) GetToolMap

func (r *Recorder) GetToolMap(domainLcuuid, subDomainLcuuid, field string) map[interface{}]interface{}

func (*Recorder) Refresh

func (r *Recorder) Refresh(target string, cloudData cloudmodel.Resource) error

type Resource

type Resource struct {
	Cleaners   *Cleaners
	IDManagers *idmng.IDManagers
}

func GetResource

func GetResource() *Resource

func (*Resource) Init

func (r *Resource) Init(ctx context.Context, cfg config.RecorderConfig) *Resource