tasks

Documentation

Index

• Constants
• Variables
• type CacheTaskManager
  • func NewCacheTaskManager() *CacheTaskManager
  • func (this *CacheTaskManager) Get(key string) (value interface{}, ok bool)
  • func (this *CacheTaskManager) GetCluster(key string, clusterId int64, category string) (value interface{}, ok bool)
  • func (this *CacheTaskManager) GetGlobalTopDomains() (value interface{}, ok bool)
  • func (this *CacheTaskManager) GetNode(key string, clusterId int64, nodeId int64, category string) (value interface{}, ok bool)
  • func (this *CacheTaskManager) GetServer(key string, clusterId int64, serverId int64, category string) (value interface{}, ok bool)
  • func (this *CacheTaskManager) Loop() error
  • func (this *CacheTaskManager) Start()

Constants

const (
	CacheKeyFindAllMetricDataCharts = "findAllMetricDataCharts"
	CacheKeyFindGlobalTopDomains    = "globalFindTopDomains"

	CacheKeyFindNodeClusterMetricDataCharts = "findNodeClusterMetricDataCharts"

	CacheKeyFindNodeMetricDataCharts = "findNodeMetricDataCharts"

	CacheKeyFindServerMetricDataCharts = "findServerMetricDataCharts"
)

Variables

var SharedCacheTaskManager = NewCacheTaskManager()

Types

type CacheTaskManager

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

func NewCacheTaskManager

func NewCacheTaskManager() *CacheTaskManager

func (*CacheTaskManager) Get

func (this *CacheTaskManager) Get(key string) (value interface{}, ok bool)

func (*CacheTaskManager) GetCluster

func (this *CacheTaskManager) GetCluster(key string, clusterId int64, category string) (value interface{}, ok bool)

func (*CacheTaskManager) GetGlobalTopDomains

func (this *CacheTaskManager) GetGlobalTopDomains() (value interface{}, ok bool)

func (*CacheTaskManager) GetNode

func (this *CacheTaskManager) GetNode(key string, clusterId int64, nodeId int64, category string) (value interface{}, ok bool)

func (*CacheTaskManager) GetServer

func (this *CacheTaskManager) GetServer(key string, clusterId int64, serverId int64, category string) (value interface{}, ok bool)

func (*CacheTaskManager) Loop

func (this *CacheTaskManager) Loop() error

func (*CacheTaskManager) Start

func (this *CacheTaskManager) Start()