cache

Documentation

Index

• Variables
• func Init(ctx context.Context) error
• func NewHistory() *history
• type CollectRuleCache
  • func NewCollectRuleCache(cf *config.CollectRuleSection) *CollectRuleCache
  • func (p *CollectRuleCache) Clean()
  • func (p *CollectRuleCache) Get(id int64) (*models.CollectRule, bool)
  • func (p *CollectRuleCache) GetAll() []*models.CollectRule
  • func (p *CollectRuleCache) Set(id int64, rule *models.CollectRule)

Variables

var MetricHistory *history // history.go

Functions

func Init

func Init(ctx context.Context) error

func NewHistory

func NewHistory() *history

Types

type CollectRuleCache

type CollectRuleCache struct {
	sync.RWMutex
	*config.CollectRuleSection
	Data map[int64]*models.CollectRule
	TS   map[int64]int64
	C    chan time.Time
	// contains filtered or unexported fields
}

var CollectRule *CollectRuleCache // collectrule.go

func NewCollectRuleCache

func NewCollectRuleCache(cf *config.CollectRuleSection) *CollectRuleCache

func (*CollectRuleCache) Clean

func (p *CollectRuleCache) Clean()

func (*CollectRuleCache) Get

func (p *CollectRuleCache) Get(id int64) (*models.CollectRule, bool)

func (*CollectRuleCache) GetAll

func (p *CollectRuleCache) GetAll() []*models.CollectRule

func (*CollectRuleCache) Set

func (p *CollectRuleCache) Set(id int64, rule *models.CollectRule)