service

package
v0.0.0-...-9634a1a Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2023 License: Apache-2.0 Imports: 30 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_NAMES = []string{"1s", "1m", "flow_log.l4", "flow_log.l7"}
View Source 
var DecapTypeData = map[int]string{
	0: "无",
	1: "VXLAN",
	2: "IPIP",
	3: "GRE",
}

Functions

func BatchDeleteVtap 

func BatchDeleteVtap(deleteMap []map[string]string) (resp map[string][]string, err error)

func BatchUpdateVtap 

func BatchUpdateVtap(updateMap []map[string]interface{}) (resp map[string][]string, err error)

func BatchUpdateVtapLicenseType 

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

func BatchUpdateVtapTapMode 

func BatchUpdateVtapTapMode(vtapUpdate *model.VtapUpdateTapMode) (interface{}, error)

func CallRozeAPIAddRP 

func CallRozeAPIAddRP(ip string, dataSource, baseDataSource mysql.DataSource, rozePort int) error

func CallRozeAPIDelRP 

func CallRozeAPIDelRP(ip string, dataSource mysql.DataSource, rozePort int) error

func CallRozeAPIModRP 

func CallRozeAPIModRP(ip string, dataSource mysql.DataSource, rozePort int) error

func ConfigAnalyzerDataSource 

func ConfigAnalyzerDataSource(ip string) error

func CreateDataSource 

func CreateDataSource(dataSourceCreate model.DataSourceCreate, cfg *config.ControllerConfig) (model.DataSource, error)

func CreateVTapGroupAdvancedConfig 

func CreateVTapGroupAdvancedConfig(createData *model.VTapGroupConfiguration) (string, error)

func CreateVTapGroupConfig 

func CreateVTapGroupConfig(createData *model.VTapGroupConfiguration) (*mysql.VTapGroupConfiguration, error)

func CreateVtap 

func CreateVtap(vtapCreate model.VtapCreate) (model.Vtap, error)

func CreateVtapGroup 

func CreateVtapGroup(vtapGroupCreate model.VtapGroupCreate, cfg *config.ControllerConfig) (resp model.VtapGroup, err error)

func CreateVtapRepo 

func CreateVtapRepo(vtapRepoCreate *mysql.VTapRepo) (*model.VtapRepo, error)

func DeleteAnalyzer 

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

func DeleteController 

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

func DeleteDataSource 

func DeleteDataSource(lcuuid string, cfg *config.ControllerConfig) (map[string]string, error)

func DeleteVTapGroupConfig 

func DeleteVTapGroupConfig(lcuuid string) (*mysql.VTapGroupConfiguration, error)

func DeleteVTapGroupConfigByFilter 

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

func DeleteVtap 

func DeleteVtap(lcuuid string) (resp map[string]string, err error)

func DeleteVtapGroup 

func DeleteVtapGroup(lcuuid string) (resp map[string]string, err error)

func DeleteVtapRepo 

func DeleteVtapRepo(name string) error

func GetAgentStats 

func GetAgentStats(g *genesis.Genesis, ip string) ([]genesis.TridentStats, error)

func GetAnalyzers 

func GetAnalyzers(filter map[string]interface{}) (resp []model.Analyzer, err 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 GetControllers 

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

func GetDataSources 

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

func GetGenesisData 

func GetGenesisData(g *genesis.Genesis) (genesis.GenesisSyncData, error)

func GetGenesisKubernetesData 

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

func GetGenesisSyncData 

func GetGenesisSyncData(g *genesis.Genesis) (genesis.GenesisSyncData, error)

func GetKubernetesGatherBasicInfos 

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

func GetKubernetesGatherResources 

func GetKubernetesGatherResources(lcuuid string, m *manager.Manager) (resp []kubernetes_gather_model.KubernetesGatherResource, err error)

func GetLeaderInfo 

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

func GetRecorderCacheDiffBaseDataSet 

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

func GetRecorderCacheToolDataSet 

func GetRecorderCacheToolDataSet(domainLcuuid, subDomainLcuuid string, m *manager.Manager) (resp cache.ToolDataSet, 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 GetVTapGroupAdvancedConfig 

func GetVTapGroupAdvancedConfig(lcuuid string) (string, error)

func GetVTapGroupAdvancedConfigs 

func GetVTapGroupAdvancedConfigs() ([]string, error)

func GetVTapGroupConfigByFilter 

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

func GetVTapGroupConfigs 

func GetVTapGroupConfigs(filter map[string]interface{}) ([]*model.VTapGroupConfigurationResponse, error)

func GetVTapGroupDetailedConfig 

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

func GetVTapGroupExampleConfig 

func GetVTapGroupExampleConfig() (string, error)

func GetVTapInterfaces 

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

func GetVtapGroups 

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

func GetVtapRepo 

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

func GetVtaps 

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

func UpdateAnalyzer 

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

func UpdateController 

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

func UpdateDataSource 

func UpdateDataSource(lcuuid string, dataSourceUpdate model.DataSourceUpdate, cfg *config.ControllerConfig) (model.DataSource, error)

func UpdateVTapGroupAdvancedConfig 

func UpdateVTapGroupAdvancedConfig(lcuuid string, updateData *model.VTapGroupConfiguration) (string, error)

func UpdateVTapGroupConfig 

func UpdateVTapGroupConfig(lcuuid string, updateData *model.VTapGroupConfiguration) (*mysql.VTapGroupConfiguration, error)

func UpdateVtap 

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

func UpdateVtapGroup 

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

func UpdateVtapLicenseType 

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

func VTapRebalance 

func VTapRebalance(args map[string]interface{}) (*model.VTapRebalanceResult, error)

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

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.