trisolaris

Documentation

Index

• func GetBillingMethod() string
• func GetConfig() *config.Config
• func GetDB() *gorm.DB
• func GetGKubernetesInfo(teamID string) *kubernetes.KubernetesInfo
• func GetGNodeInfo() *node.NodeInfo
• func GetGVTapInfo(orgID int) *vtap.VTapInfo
• func GetGrpcPort() int
• func GetIngesterGroupProtoStr() []byte
• func GetIngesterGroupProtoVersion() uint64
• func GetIngesterPlatformDataStr() []byte
• func GetIngesterPlatformDataVersion() uint64
• func GetIngesterPodIPs() []*trident.PodIp
• func GetIngesterPolicyStr() []byte
• func GetIngesterPolicyVersion() uint64
• func GetIngesterPort() int
• func GetIngesterUniversalTagNames() *trident.UniversalTagNameMapsResponse
• func GetIngesterVTapIPs() []*trident.VtapIp
• func GetIsRefused() bool
• func GetMetaData() *metadata.MetaData
• func GetOrgIDByTeamID(teamID string) int
• func GetOrgInfoByTeamID(teamIDStr string) (orgID int, teamID int)
• func IsTheDataReady() bool
• func MerageData(first *trident.UniversalTagNameMapsResponse, ...)
• func PutFlowACL(orgID int)
• func PutGroup(orgID int)
• func PutNodeInfo(orgID int)
• func PutPlatformData(orgID int)
• func PutTapType(orgID int)
• func PutVTapCache(orgID int)
• type Trisolaris
  • func GetTrisolaris(orgID int) *Trisolaris
  • func NewTrisolaris(cfg *config.Config, mDB *mysql.DB, pctx context.Context, startTime int64) *Trisolaris
  • func TeamIDToTrisolaris(teamID string) *Trisolaris
  • func (t *Trisolaris) Start()
  • func (t *Trisolaris) Stop()
• type TrisolarisManager
  • func NewTrisolarisManager(cfg *config.Config, db *gorm.DB) *TrisolarisManager
  • func (m *TrisolarisManager) GetOrgIDByTeamID(teamID string) int
  • func (m *TrisolarisManager) GetOrgInfoByTeamID(teamID string) (int, int)
  • func (m *TrisolarisManager) GetVTapCache(orgID int, key string) *vtap.VTapCache
  • func (m *TrisolarisManager) GetVTapInfo(orgID int) *vtap.VTapInfo
  • func (m *TrisolarisManager) NotifyGroupDataChanged()
  • func (m *TrisolarisManager) NotifyPlatformDataChanged()
  • func (m *TrisolarisManager) NotifyPolicyDataChanged()
  • func (m *TrisolarisManager) PutVTapCacheRefresh(orgID int)
  • func (m *TrisolarisManager) RegisterIngesterDataChangedNotify(trisolaris *Trisolaris)
  • func (m *TrisolarisManager) Start() error
  • func (m *TrisolarisManager) TeamIDLcuuidToInt(teamID string) int
  • func (m *TrisolarisManager) TimedCheckORG()
  • func (m *TrisolarisManager) TimedGenerateTSDBData()

Functions

func GetBillingMethod

func GetBillingMethod() string

func GetConfig

func GetConfig() *config.Config

func GetDB

func GetDB() *gorm.DB

func GetGKubernetesInfo

func GetGKubernetesInfo(teamID string) *kubernetes.KubernetesInfo

func GetGNodeInfo

func GetGNodeInfo() *node.NodeInfo

func GetGVTapInfo

func GetGVTapInfo(orgID int) *vtap.VTapInfo

func GetGrpcPort

func GetGrpcPort() int

func GetIngesterGroupProtoStr

func GetIngesterGroupProtoStr() []byte

func GetIngesterGroupProtoVersion

func GetIngesterGroupProtoVersion() uint64

func GetIngesterPlatformDataStr

func GetIngesterPlatformDataStr() []byte

func GetIngesterPlatformDataVersion

func GetIngesterPlatformDataVersion() uint64

func GetIngesterPodIPs

func GetIngesterPodIPs() []*trident.PodIp

func GetIngesterPolicyStr

func GetIngesterPolicyStr() []byte

func GetIngesterPolicyVersion

func GetIngesterPolicyVersion() uint64

func GetIngesterPort

func GetIngesterPort() int

func GetIngesterUniversalTagNames

func GetIngesterUniversalTagNames() *trident.UniversalTagNameMapsResponse

func GetIngesterVTapIPs

func GetIngesterVTapIPs() []*trident.VtapIp

func GetIsRefused

func GetIsRefused() bool

func GetMetaData

func GetMetaData() *metadata.MetaData

func GetOrgIDByTeamID

func GetOrgIDByTeamID(teamID string) int

func GetOrgInfoByTeamID

func GetOrgInfoByTeamID(teamIDStr string) (orgID int, teamID int)

func IsTheDataReady

func IsTheDataReady() bool

func MerageData

func MerageData(first *trident.UniversalTagNameMapsResponse, other *trident.UniversalTagNameMapsResponse)

func PutFlowACL

func PutFlowACL(orgID int)

func PutGroup

func PutGroup(orgID int)

func PutNodeInfo

func PutNodeInfo(orgID int)

func PutPlatformData

func PutPlatformData(orgID int)

func PutTapType

func PutTapType(orgID int)

func PutVTapCache

func PutVTapCache(orgID int)

Types

type Trisolaris

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

func GetTrisolaris

func GetTrisolaris(orgID int) *Trisolaris

func NewTrisolaris

func NewTrisolaris(cfg *config.Config, mDB *mysql.DB, pctx context.Context, startTime int64) *Trisolaris

func TeamIDToTrisolaris

func TeamIDToTrisolaris(teamID string) *Trisolaris

func (*Trisolaris) Start

func (t *Trisolaris) Start()

func (*Trisolaris) Stop

func (t *Trisolaris) Stop()

type TrisolarisManager

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

func NewTrisolarisManager

func NewTrisolarisManager(cfg *config.Config, db *gorm.DB) *TrisolarisManager

func (*TrisolarisManager) GetOrgIDByTeamID

func (m *TrisolarisManager) GetOrgIDByTeamID(teamID string) int

func (*TrisolarisManager) GetOrgInfoByTeamID

func (m *TrisolarisManager) GetOrgInfoByTeamID(teamID string) (int, int)

func (*TrisolarisManager) GetVTapCache

func (m *TrisolarisManager) GetVTapCache(orgID int, key string) *vtap.VTapCache

func (*TrisolarisManager) GetVTapInfo

func (m *TrisolarisManager) GetVTapInfo(orgID int) *vtap.VTapInfo

func (*TrisolarisManager) NotifyGroupDataChanged

func (m *TrisolarisManager) NotifyGroupDataChanged()

func (*TrisolarisManager) NotifyPlatformDataChanged

func (m *TrisolarisManager) NotifyPlatformDataChanged()

func (*TrisolarisManager) NotifyPolicyDataChanged

func (m *TrisolarisManager) NotifyPolicyDataChanged()

func (*TrisolarisManager) PutVTapCacheRefresh

func (m *TrisolarisManager) PutVTapCacheRefresh(orgID int)

func (*TrisolarisManager) RegisterIngesterDataChangedNotify

func (m *TrisolarisManager) RegisterIngesterDataChangedNotify(trisolaris *Trisolaris)

func (*TrisolarisManager) Start

func (m *TrisolarisManager) Start() error

func (*TrisolarisManager) TeamIDLcuuidToInt

func (m *TrisolarisManager) TeamIDLcuuidToInt(teamID string) int

func (*TrisolarisManager) TimedCheckORG

func (m *TrisolarisManager) TimedCheckORG()

func (*TrisolarisManager) TimedGenerateTSDBData

func (m *TrisolarisManager) TimedGenerateTSDBData()