node

Documentation

Index

• type ControllerDiscovery
  • func (c *ControllerDiscovery) GetControllerData() *models.Controller
• type NodeInfo
  • func NewNodeInfo(db *gorm.DB, metaData *metadata.MetaData, cfg *config.Config, orgID int, ...) *NodeInfo
  • func (n *NodeInfo) AddTSDBCache(tsdb *models.Analyzer)
  • func (n *NodeInfo) DeleteTSDBCache(key string)
  • func (n *NodeInfo) GetControllerNatIP(ip string) string
  • func (n *NodeInfo) GetControllerPodIP(ip string) string
  • func (n *NodeInfo) GetLocalControllers() []*trident.DeepFlowServerInstanceInfo
  • func (n *NodeInfo) GetPcapDataRetention() uint32
  • func (n *NodeInfo) GetPlatformData() *metadata.PlatformData
  • func (n *NodeInfo) GetRegionIDByTSDBIP(tsdbIP string) uint32
  • func (n *NodeInfo) GetTSDBCache(key string) *TSDBCache
  • func (n *NodeInfo) GetTSDBID(ip string) uint32
  • func (n *NodeInfo) GetTSDBNatIP(ip string) string
  • func (n *NodeInfo) GetTSDBPodIP(ip string) string
  • func (n *NodeInfo) NotifyBasePlatformDataChanged()
  • func (n *NodeInfo) PutChNodeInfo()
  • func (n *NodeInfo) RegisteNotifyPlatformDataChanged(notify func())
  • func (n *NodeInfo) RegisterTSDB(request *trident.SyncRequest)
  • func (n *NodeInfo) TimedRefreshNodeCache()
• type TSDBCache
  • func (c *TSDBCache) GetArch() string
  • func (c *TSDBCache) GetKernelVersion() string
  • func (c *TSDBCache) GetKey() string
  • func (c *TSDBCache) GetName() string
  • func (c *TSDBCache) GetOS() string
  • func (c *TSDBCache) GetPcapDataMountPath() string
  • func (c *TSDBCache) GetPodIP() string
  • func (c *TSDBCache) GetPodName() string
  • func (c *TSDBCache) GetSyncedAt() *time.Time
  • func (c *TSDBCache) UpdateSyncedAt(syncedAt time.Time)
  • func (c *TSDBCache) UpdateSystemInfo(cpuNum int, memorySize int64, arch string, tsdbOS string, kernelVersion string, ...)
• type TSDBCacheMap
  • func (m *TSDBCacheMap) Add(tsdbCache *TSDBCache)
  • func (m *TSDBCacheMap) Delete(key string)
  • func (m *TSDBCacheMap) Get(key string) *TSDBCache
  • func (m *TSDBCacheMap) GetKeySet() mapset.Set
  • func (m *TSDBCacheMap) List() []string
• type TSDBDiscovery

Types

type ControllerDiscovery

type ControllerDiscovery struct {
	ORGID
	// contains filtered or unexported fields
}

func (*ControllerDiscovery) GetControllerData

func (c *ControllerDiscovery) GetControllerData() *models.Controller

type NodeInfo

type NodeInfo struct {
	ORGID
	// contains filtered or unexported fields
}

func NewNodeInfo

func NewNodeInfo(db *gorm.DB, metaData *metadata.MetaData, cfg *config.Config, orgID int, pctx context.Context) *NodeInfo

func (*NodeInfo) AddTSDBCache

func (n *NodeInfo) AddTSDBCache(tsdb *models.Analyzer)

func (*NodeInfo) DeleteTSDBCache

func (n *NodeInfo) DeleteTSDBCache(key string)

func (*NodeInfo) GetControllerNatIP

func (n *NodeInfo) GetControllerNatIP(ip string) string

func (*NodeInfo) GetControllerPodIP

func (n *NodeInfo) GetControllerPodIP(ip string) string

func (*NodeInfo) GetLocalControllers

func (n *NodeInfo) GetLocalControllers() []*trident.DeepFlowServerInstanceInfo

func (*NodeInfo) GetPcapDataRetention

func (n *NodeInfo) GetPcapDataRetention() uint32

func (*NodeInfo) GetPlatformData

func (n *NodeInfo) GetPlatformData() *metadata.PlatformData

func (*NodeInfo) GetRegionIDByTSDBIP

func (n *NodeInfo) GetRegionIDByTSDBIP(tsdbIP string) uint32

func (*NodeInfo) GetTSDBCache

func (n *NodeInfo) GetTSDBCache(key string) *TSDBCache

func (*NodeInfo) GetTSDBID

func (n *NodeInfo) GetTSDBID(ip string) uint32

func (*NodeInfo) GetTSDBNatIP

func (n *NodeInfo) GetTSDBNatIP(ip string) string

func (*NodeInfo) GetTSDBPodIP

func (n *NodeInfo) GetTSDBPodIP(ip string) string

func (*NodeInfo) NotifyBasePlatformDataChanged

func (n *NodeInfo) NotifyBasePlatformDataChanged()

func (*NodeInfo) PutChNodeInfo

func (n *NodeInfo) PutChNodeInfo()

func (*NodeInfo) RegisteNotifyPlatformDataChanged

func (n *NodeInfo) RegisteNotifyPlatformDataChanged(notify func())

func (*NodeInfo) RegisterTSDB

func (n *NodeInfo) RegisterTSDB(request *trident.SyncRequest)

func (*NodeInfo) TimedRefreshNodeCache

func (n *NodeInfo) TimedRefreshNodeCache()

type TSDBCache

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

func (*TSDBCache) GetArch

func (c *TSDBCache) GetArch() string

func (*TSDBCache) GetKernelVersion

func (c *TSDBCache) GetKernelVersion() string

func (*TSDBCache) GetKey

func (c *TSDBCache) GetKey() string

func (*TSDBCache) GetName

func (c *TSDBCache) GetName() string

func (*TSDBCache) GetOS

func (c *TSDBCache) GetOS() string

func (*TSDBCache) GetPcapDataMountPath

func (c *TSDBCache) GetPcapDataMountPath() string

func (*TSDBCache) GetPodIP

func (c *TSDBCache) GetPodIP() string

func (*TSDBCache) GetPodName

func (c *TSDBCache) GetPodName() string

func (*TSDBCache) GetSyncedAt

func (c *TSDBCache) GetSyncedAt() *time.Time

func (*TSDBCache) UpdateSyncedAt

func (c *TSDBCache) UpdateSyncedAt(syncedAt time.Time)

func (*TSDBCache) UpdateSystemInfo

func (c *TSDBCache) UpdateSystemInfo(cpuNum int, memorySize int64, arch string, tsdbOS string,
	kernelVersion string, pcapDataMountPath string, name string)

type TSDBCacheMap

type TSDBCacheMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*TSDBCacheMap) Add

func (m *TSDBCacheMap) Add(tsdbCache *TSDBCache)

func (*TSDBCacheMap) Delete

func (m *TSDBCacheMap) Delete(key string)

func (*TSDBCacheMap) Get

func (m *TSDBCacheMap) Get(key string) *TSDBCache

func (*TSDBCacheMap) GetKeySet

func (m *TSDBCacheMap) GetKeySet() mapset.Set

func (*TSDBCacheMap) List

func (m *TSDBCacheMap) List() []string

type TSDBDiscovery

type TSDBDiscovery struct {
	sync.Mutex
	// contains filtered or unexported fields
}