service

package
v1.6.65 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IMAGE_MAX_COUNT = 20
)
View Source 
const VTAP_GROUP_SHORT_UUID_PREFIX = "g-"
View Source 
const (
	VTAP_LICENSE_CHECK_EXCEPTION = "采集器(%s)不支持修改为指定授权类型"
)

Variables

View Source 
var DEFAULT_DATA_SOURCE_DISPLAY_NAMES = []string{
	"网络-指标（秒级）", "网络-指标（分钟级）",
	"网络-流日志",
	"应用-指标（秒级）", "应用-指标（分钟级）",
	"应用-调用日志",
	"网络-TCP 时序数据",
	"网络-PCAP 数据",
	"租户侧监控数据",
	"管理侧监控数据",
	"外部指标数据",
	"Prometheus 数据",
	"事件-资源变更事件",
	"事件-IO 事件",
	"事件-告警事件",
	"应用-性能剖析",
	"网络-网络策略",
	"日志-日志数据",
}
View Source 
var DecapTypeData = map[int]string{
	0: "无",
	1: "VXLAN",
	2: "IPIP",
	3: "GRE",
}
View Source 
var DeprecatedTapSideID = []int{48, 49, 50}

Functions

func AgentCommandLock 

func AgentCommandLock()

func AgentCommandUnlock 

func AgentCommandUnlock()

func AllocORGID 

func AllocORGID() (map[string]int, error)

func AppendCommands 

func AppendCommands(key string, requestID uint64, data []*trident.RemoteCommand)

func AppendContent 

func AppendContent(key string, requestID uint64, data []byte)

func AppendErrorMessage 

func AppendErrorMessage(key string, requestID uint64, data *string)

func AppendNamespaces 

func AppendNamespaces(key string, requestID uint64, data []*trident.LinuxNamespace)

func ConvertStrToIntList 

func ConvertStrToIntList(convertStr string) ([]int, error)

func ConvertStrToIntListWithIgnore 

func ConvertStrToIntListWithIgnore(convertStr string, ignoreFields []int) ([]int, error)

func CreateMailServer 

func CreateMailServer(mailCreate model.MailServerCreate) (model.MailServer, error)

func CreateORGData 

func CreateORGData(dataCreate model.ORGDataCreate, mysqlCfg mysqlcfg.MySqlConfig) (string, error)

CreateORGData create database and backs up the controller and analyzer tables. Returns the database name and error.

func CreatePlugin 

func CreatePlugin(db *mysql.DB, pluginCreate *mysqlmodel.Plugin) (*model.Plugin, error)

func CreateVTapGroupAdvancedConfig 

func CreateVTapGroupAdvancedConfig(orgID int, createData *agent_config.AgentGroupConfig) (string, error)

func CreateVtapRepo 

func CreateVtapRepo(orgID int, vtapRepoCreate *mysqlmodel.VTapRepo) (*model.VtapRepo, error)

func DeleteAnalyzer 

func DeleteAnalyzer(orgID int, lcuuid string, m *monitor.AnalyzerCheck) (resp map[string]string, err error)

func DeleteController 

func DeleteController(orgID int, lcuuid string, m *monitor.ControllerCheck) (resp map[string]string, err error)

func DeleteMailServer 

func DeleteMailServer(lcuuid string) (map[string]string, error)

func DeleteORGData 

func DeleteORGData(orgID int, mysqlCfg mysqlcfg.MySqlConfig) (err error)

func DeleteORGDataNonRealTime 

func DeleteORGDataNonRealTime(orgIDs []int) error

func DeletePlugin 

func DeletePlugin(db *mysql.DB, name string) error

func DeleteVTapGroupConfigByFilter 

func DeleteVTapGroupConfigByFilter(orgID int, args map[string]string) (string, error)

func DeleteVtapRepo 

func DeleteVtapRepo(orgID int, name string) error

func GetAgentByUser 

func GetAgentByUser(userInfo *httpcommon.UserInfo, fpermitCfg *common.FPermit, vtaps []mysqlmodel.VTap) ([]mysqlmodel.VTap, error)

func GetAgentGroupByUser 

func GetAgentGroupByUser(userInfo *httpcommon.UserInfo, fpermitCfg *common.FPermit, vtapGroups []*mysqlmodel.VTapGroup) ([]*mysqlmodel.VTapGroup, error)

func GetAgentStats 

func GetAgentStats(g *genesis.Genesis, orgID, vtapID string) (grpc.TridentStats, error)

func GetAnalyzers 

func GetAnalyzers(orgID int, filter map[string]interface{}) (resp []model.Analyzer, err error)

func GetCMDAndNamespace 

func GetCMDAndNamespace(timeout, orgID, agentID int) (*model.RemoteExecResp, error)

func GetCloudBasicInfos 

func GetCloudBasicInfos(filter map[string]string, m *manager.Manager) (resp []cloudmodel.BasicInfo, err error)

func GetCloudResource 

func GetCloudResource(lcuuid string, m *manager.Manager) (resp cloudmodel.Resource, err error)

func GetCommands 

func GetCommands(key string, requestID uint64) []*trident.RemoteCommand

func GetCommandsWithoutLock 

func GetCommandsWithoutLock(key string, requestID uint64) []*trident.RemoteCommand

func GetContent 

func GetContent(key string, requestID uint64) string

func GetControllers 

func GetControllers(orgID int, filter map[string]string) (resp []model.Controller, err error)

func GetErrormessage 

func GetErrormessage(key string, requestID uint64) string

func GetGenesisAgentStorage 

func GetGenesisAgentStorage(vtapIDString string, orgDB *mysql.DB) (model.GenesisStorage, error)

func GetGenesisData 

func GetGenesisData(orgID int, g *genesis.Genesis) (gcommon.GenesisSyncDataResponse, error)

func GetGenesisKubernetesData 

func GetGenesisKubernetesData(g *genesis.Genesis, orgID int, clusterID string) (map[string][]string, error)

func GetGenesisSyncData 

func GetGenesisSyncData(orgID int, g *genesis.Genesis) (gcommon.GenesisSyncDataResponse, error)

func GetIcon 

func GetIcon(cfg *config.ControllerConfig) (*simplejson.Json, error)

func GetKubernetesGatherBasicInfos 

func GetKubernetesGatherBasicInfos(lcuuid string, m *manager.Manager) (resp []gathermodel.KubernetesGatherBasicInfo, err error)

func GetKubernetesGatherResource 

func GetKubernetesGatherResource(lcuuid, subDomainLcuuid string, m *manager.Manager) (resp gathermodel.KubernetesGatherResource, err error)

func GetLeaderInfo 

func GetLeaderInfo() (resp map[string]string, err error)

func GetMailServer 

func GetMailServer(filter map[string]interface{}) (resp []model.MailServer, err error)

func GetNamespaces 

func GetNamespaces(key string, requestID uint64) []*trident.LinuxNamespace

func GetNamespacesWithoutLock 

func GetNamespacesWithoutLock(key string, requestID uint64) []*trident.LinuxNamespace

func GetORGData 

func GetORGData(cfg *config.ControllerConfig) (*simplejson.Json, error)

func GetPlugin 

func GetPlugin(db *mysql.DB, filter map[string]interface{}) ([]model.Plugin, error)

func GetRecorderCacheDiffBaseDataSet 

func GetRecorderCacheDiffBaseDataSet(domainLcuuid, subDomainLcuuid string, m *manager.Manager) (resp diffbase.DataSet, err error)

func GetRecorderCacheToolDataSet 

func GetRecorderCacheToolDataSet(domainLcuuid, subDomainLcuuid string, m *manager.Manager) (resp tool.DataSet, err error)

func GetRecorderDiffBaseByResourceLcuuid 

func GetRecorderDiffBaseByResourceLcuuid(domainLcuuid, subDomainLcuuid, resourceType string, resourceLcuuid string, m *manager.Manager) (resp interface{}, err error)

func GetRecorderDiffBaseDataSetByResourceType 

func GetRecorderDiffBaseDataSetByResourceType(domainLcuuid, subDomainLcuuid, resourceType string, m *manager.Manager) (resp map[string]interface{}, err error)

func GetRecorderDomainCache 

func GetRecorderDomainCache(domainLcuuid, subDomainLcuuid string, m *manager.Manager) (resp cache.Cache, err error)

func GetRecorderToolMapByField 

func GetRecorderToolMapByField(domainLcuuid, subDomainLcuuid, field string, m *manager.Manager) (resp map[interface{}]interface{}, err error)

func GetRequestID 

func GetRequestID(key string) uint64

func GetSubDomainResource 

func GetSubDomainResource(lcuuid, subDomainLcuuid string, m *manager.Manager) (resp cloudmodel.SubDomainResource, err error)

func GetVTapGroupAdvancedConfig 

func GetVTapGroupAdvancedConfig(orgID int, lcuuid string) (string, error)

func GetVTapGroupAdvancedConfigs 

func GetVTapGroupAdvancedConfigs(orgID int) ([]string, error)

func GetVTapGroupConfigByFilter 

func GetVTapGroupConfigByFilter(orgID int, args map[string]string) (string, error)

func GetVTapGroupConfigs 

func GetVTapGroupConfigs(userInfo *httpcommon.UserInfo, fpermitCfg *common.FPermit, filter map[string]interface{}) ([]*agent_config.AgentGroupConfigResponse, error)

func GetVTapGroupDetailedConfig 

func GetVTapGroupDetailedConfig(orgID int, lcuuid string) (*model.DetailedConfig, error)

func GetVTapGroupExampleConfig 

func GetVTapGroupExampleConfig() (string, error)

func GetVTapPortsCount 

func GetVTapPortsCount() (int, error)

GetVTapPortsCount gets the number of virtual network cards covered by the deployed vtap, and virtual network type is VIF_DEVICE_TYPE_VM or VIF_DEVICE_TYPE_POD.

func GetVtapRepo 

func GetVtapRepo(orgID int, filter map[string]interface{}) ([]model.VtapRepo, error)

func InitCommands 

func InitCommands(key string, requestID uint64, data []*trident.RemoteCommand)

func InitNamespaces 

func InitNamespaces(key string, requestID uint64, data []*trident.LinuxNamespace)

func IsVtapGroupShortUUID 

func IsVtapGroupShortUUID(uuid string) bool

IsVtapGroupShortUUID checks uuid consists of numbers and English letters with g- prefix.

func PermitVerify 

func PermitVerify(url string, userInfo *httpcommon.UserInfo, teamID int) error

func RemoveAgentCMDResp 

func RemoveAgentCMDResp(key string, requestID uint64)

func RemoveAllFromCMDManager 

func RemoveAllFromCMDManager(key string)

func RemoveFromCMDManager 

func RemoveFromCMDManager(key string, requestID uint64)

func RunAgentCMD 

func RunAgentCMD(timeout, orgID, agentID int, req *trident.RemoteExecRequest, CMD string) (string, error)

func TriggerDomain 

func TriggerDomain(lcuuid string, m *manager.Manager) error

func TriggerKubernetesRefresh 

func TriggerKubernetesRefresh(domainLcuuid, subDomainLcuuid string, version int, m *manager.Manager) error

func UpdateAnalyzer 

func UpdateAnalyzer(
	orgID int, lcuuid string, analyzerUpdate map[string]interface{},
	m *monitor.AnalyzerCheck, cfg *config.ControllerConfig,
) (resp *model.Analyzer, err error)

func UpdateController 

func UpdateController(
	orgID int, lcuuid string, controllerUpdate map[string]interface{},
	m *monitor.ControllerCheck, cfg *config.ControllerConfig,
) (resp *model.Controller, err error)

func UpdateMailServer 

func UpdateMailServer(lcuuid string, mailServerUpdate map[string]interface{}) (model.MailServer, error)

func UpdateVTapGroupAdvancedConfig 

func UpdateVTapGroupAdvancedConfig(orgID int, lcuuid string, updateData *agent_config.AgentGroupConfig) (string, error)

func VTapRebalance 

func VTapRebalance(db *mysql.DB, args map[string]interface{}, cfg monitorconf.IngesterLoadBalancingStrategy) (interface{}, error)

Types

type AccessType 

type AccessType string
const (
	AccessAdd    AccessType = "add"
	AccessUpdate AccessType = "update"
	AccessDelete AccessType = "delete"
)

type Agent 

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

func NewAgent 

func NewAgent(userInfo *httpcommon.UserInfo, cfg *config.ControllerConfig) *Agent

func (*Agent) BatchDelete 

func (a *Agent) BatchDelete(deleteMap []map[string]string) (resp map[string][]string, err error)

func (*Agent) BatchUpdate 

func (a *Agent) BatchUpdate(updateMap []map[string]interface{}) (map[string][]string, error)

func (*Agent) BatchUpdateVtapLicenseType 

func (a *Agent) BatchUpdateVtapLicenseType(updateMap []map[string]interface{}) (resp map[string][]string, err error)

func (*Agent) Create 

func (a *Agent) Create(vtapCreate model.VtapCreate) (model.Vtap, error)

func (*Agent) Delete 

func (a *Agent) Delete(lcuuid string) (resp map[string]string, err error)

func (*Agent) Get 

func (a *Agent) Get(filter map[string]interface{}) (resp []model.Vtap, err error)

func (*Agent) Update 

func (a *Agent) Update(lcuuid, name string, vtapUpdate map[string]interface{}) (resp model.Vtap, err error)

func (*Agent) UpdateVtapLicenseType 

func (a *Agent) UpdateVtapLicenseType(lcuuid string, vtapUpdate map[string]interface{}) (resp model.Vtap, err error)

type AgentCMDManager 

type AgentCMDManager map[string]*CMDManager

type AgentGroup 

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

func NewAgentGroup 

func NewAgentGroup(userInfo *httpcommon.UserInfo, cfg *config.ControllerConfig) *AgentGroup

func (*AgentGroup) Create 

func (a *AgentGroup) Create(vtapGroupCreate model.VtapGroupCreate) (resp model.VtapGroup, err error)

func (*AgentGroup) Delete 

func (a *AgentGroup) Delete(lcuuid string) (resp map[string]string, err error)

func (*AgentGroup) Get 

func (a *AgentGroup) Get(filter map[string]interface{}) (resp []model.VtapGroup, err error)

func (*AgentGroup) Update 

func (a *AgentGroup) Update(lcuuid string, vtapGroupUpdate map[string]interface{}, cfg *config.ControllerConfig) (resp model.VtapGroup, err error)

type AgentGroupConfig 

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

func NewAgentGroupConfig 

func NewAgentGroupConfig(userInfo *httpcommon.UserInfo, cfg *config.ControllerConfig) *AgentGroupConfig

func (*AgentGroupConfig) CreateVTapGroupConfig 

func (a *AgentGroupConfig) CreateVTapGroupConfig(orgID int, createData *agent_config.AgentGroupConfig) (*agent_config.AgentGroupConfigModel, error)

func (*AgentGroupConfig) DeleteVTapGroupConfig 

func (a *AgentGroupConfig) DeleteVTapGroupConfig(orgID int, lcuuid string) (*agent_config.AgentGroupConfigModel, error)

func (*AgentGroupConfig) UpdateVTapGroupConfig 

func (a *AgentGroupConfig) UpdateVTapGroupConfig(orgID int, lcuuid string, updateData *agent_config.AgentGroupConfig) (*agent_config.AgentGroupConfigModel, error)

type CMDManager 

type CMDManager struct {
	ExecCH chan *trident.RemoteExecRequest
	// contains filtered or unexported fields
}

func AddToCMDManagerIfNotExist 

func AddToCMDManagerIfNotExist(key string, requestID uint64) *CMDManager

func GetAgentCMDManager 

func GetAgentCMDManager(key string) *CMDManager

func GetAgentCMDManagerWithoutLock 

func GetAgentCMDManagerWithoutLock(key string) *CMDManager

type CMDResp 

type CMDResp struct {
	ExecDoneCH           chan struct{}
	RemoteCMDDoneCH      chan struct{}
	LinuxNamespaceDoneCH chan struct{}
	// contains filtered or unexported fields
}

func GetAgentCMDResp 

func GetAgentCMDResp(key string, requestID uint64) *CMDResp

func GetAgentCMDRespWithoutLock 

func GetAgentCMDRespWithoutLock(key string, requestID uint64) *CMDResp

func NewAgentCMDResp 

func NewAgentCMDResp(key string) (uint64, *CMDResp)

type DataSource 

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

func NewDataSource 

func NewDataSource(userInfo *httpcommon.UserInfo, cfg *config.ControllerConfig) *DataSource

func NewDataSourceWithIngesterAPIConfig 

func NewDataSourceWithIngesterAPIConfig(userInfo *httpcommon.UserInfo, cfg common.IngesterApi) *DataSource

func (*DataSource) CallIngesterAPIAddRP 

func (d *DataSource) CallIngesterAPIAddRP(orgID int, ip string, dataSource, baseDataSource mysqlmodel.DataSource) error

func (*DataSource) CallIngesterAPIDelRP 

func (d *DataSource) CallIngesterAPIDelRP(orgID int, ip string, dataSource mysqlmodel.DataSource) error

func (*DataSource) CallIngesterAPIModRP 

func (d *DataSource) CallIngesterAPIModRP(orgID int, ip string, dataSource mysqlmodel.DataSource) error

func (*DataSource) ConfigAnalyzerDataSource 

func (d *DataSource) ConfigAnalyzerDataSource(orgID int, ip string) error

func (*DataSource) CreateDataSource 

func (d *DataSource) CreateDataSource(orgID int, dataSourceCreate *model.DataSourceCreate) (model.DataSource, error)

func (*DataSource) DeleteDataSource 

func (d *DataSource) DeleteDataSource(orgID int, lcuuid string) (map[string]string, error)

func (*DataSource) GetDataSources 

func (d *DataSource) GetDataSources(orgID int, filter map[string]interface{}, specCfg *config.Specification) (resp []model.DataSource, err error)

func (*DataSource) UpdateDataSource 

func (d *DataSource) UpdateDataSource(orgID int, lcuuid string, dataSourceUpdate model.DataSourceUpdate) (model.DataSource, error)

type DeletedORGChecker 

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

func GetDeletedORGChecker 

func GetDeletedORGChecker(ctx context.Context, fpermitCfg controllerCommon.FPermit) *DeletedORGChecker

func (*DeletedORGChecker) Start 

func (c *DeletedORGChecker) Start(sCtx context.Context)

func (*DeletedORGChecker) Stop 

func (c *DeletedORGChecker) Stop()

type ResourceAccess 

type ResourceAccess struct {
	Fpermit  common.FPermit
	UserInfo *httpcommon.UserInfo
}

func NewResourceAccess 

func NewResourceAccess(fpermit common.FPermit, userInfo *httpcommon.UserInfo) *ResourceAccess

func (*ResourceAccess) CanAddResource 

func (ra *ResourceAccess) CanAddResource(teamID int, resourceType, resourceUUID string) error

func (*ResourceAccess) CanAddSubDomainResource 

func (ra *ResourceAccess) CanAddSubDomainResource(domainTeamID, subDomainTeamID int, resourceUUID string) error

func (*ResourceAccess) CanDeleteResource 

func (ra *ResourceAccess) CanDeleteResource(teamID int, resourceType, resourceUUID string) error

func (*ResourceAccess) CanDeleteSubDomainResource 

func (ra *ResourceAccess) CanDeleteSubDomainResource(domainTeamID, subDomainTeamID int, resourceUUID string) error

func (*ResourceAccess) CanOperateDomainResource 

func (ra *ResourceAccess) CanOperateDomainResource(teamID int, domainUUID string) error

func (*ResourceAccess) CanUpdateResource 

func (ra *ResourceAccess) CanUpdateResource(teamID int, resourceType, resourceUUID string, resourceUp map[string]interface{}) error

func (*ResourceAccess) CanUpdateSubDomainResource 

func (ra *ResourceAccess) CanUpdateSubDomainResource(domainTeamID, subDomainTeamID int, resourceUUID string, resourceUp map[string]interface{}) error

Source Files

View all Source files

Directories

Path Synopsis
agentlicense module
mocks
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.