instance

package
v0.0.0-...-f62340a Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2023 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewKafkaTcInstance 

func NewKafkaTcInstance(instanceId string, meta *sdk.Instance) (ins *kafkaTcInstance, err error)

Types

type BoundRsDetail 

type BoundRsDetail struct {
	RsId   string
	RsInfo string
}

type CMQTcInstance 

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

func NewCMQTcInstance 

func NewCMQTcInstance(instanceId string, meta *sdk.QueueSet) (ins *CMQTcInstance, err error)

func (*CMQTcInstance) GetFieldValueByName 

func (ins *CMQTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CMQTcInstance) GetFieldValuesByName 

func (ins *CMQTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CMQTcInstance) GetInstanceId 

func (ins *CMQTcInstance) GetInstanceId() string

func (*CMQTcInstance) GetMeta 

func (ins *CMQTcInstance) GetMeta() interface{}

func (*CMQTcInstance) GetMonitorQueryKey 

func (ins *CMQTcInstance) GetMonitorQueryKey() string

type CMQTcInstanceRepository 

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

func (*CMQTcInstanceRepository) Get 

func (repo *CMQTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CMQTcInstanceRepository) GetInstanceKey 

func (repo *CMQTcInstanceRepository) GetInstanceKey() string

func (*CMQTcInstanceRepository) ListByFilters 

func (repo *CMQTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CMQTcInstanceRepository) ListByIds 

func (repo *CMQTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CMQTopicTcInstance 

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

func NewCMQTopicTcInstance 

func NewCMQTopicTcInstance(instanceId string, meta *sdk.TopicSet) (ins *CMQTopicTcInstance, err error)

func (*CMQTopicTcInstance) GetFieldValueByName 

func (ins *CMQTopicTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CMQTopicTcInstance) GetFieldValuesByName 

func (ins *CMQTopicTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CMQTopicTcInstance) GetInstanceId 

func (ins *CMQTopicTcInstance) GetInstanceId() string

func (*CMQTopicTcInstance) GetMeta 

func (ins *CMQTopicTcInstance) GetMeta() interface{}

func (*CMQTopicTcInstance) GetMonitorQueryKey 

func (ins *CMQTopicTcInstance) GetMonitorQueryKey() string

type CMQTopicTcInstanceRepository 

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

func (*CMQTopicTcInstanceRepository) Get 

func (repo *CMQTopicTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CMQTopicTcInstanceRepository) GetInstanceKey 

func (repo *CMQTopicTcInstanceRepository) GetInstanceKey() string

func (*CMQTopicTcInstanceRepository) ListByFilters 

func (repo *CMQTopicTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CMQTopicTcInstanceRepository) ListByIds 

func (repo *CMQTopicTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CbsTcInstance 

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

func NewCbsTcInstance 

func NewCbsTcInstance(instanceId string, meta *sdk.Disk) (ins *CbsTcInstance, err error)

func (*CbsTcInstance) GetFieldValueByName 

func (ins *CbsTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CbsTcInstance) GetFieldValuesByName 

func (ins *CbsTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CbsTcInstance) GetInstanceId 

func (ins *CbsTcInstance) GetInstanceId() string

func (*CbsTcInstance) GetMeta 

func (ins *CbsTcInstance) GetMeta() interface{}

func (*CbsTcInstance) GetMonitorQueryKey 

func (ins *CbsTcInstance) GetMonitorQueryKey() string

type CbsTcInstanceInfosRepository 

type CbsTcInstanceInfosRepository interface {
	Get(id string) ([]string, error)
	GetInstanceInfosInfoByFilters([]string) (*cvm.DescribeInstancesResponse, error)
}

cvm instance

func NewCbsTcInstanceInfosRepository 

func NewCbsTcInstanceInfosRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (CbsTcInstanceInfosRepository, error)

type CbsTcInstanceInfosRepositoryImpl 

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

func (*CbsTcInstanceInfosRepositoryImpl) Get 

func (repo *CbsTcInstanceInfosRepositoryImpl) Get(id string) (instanceIds []string, err error)

func (*CbsTcInstanceInfosRepositoryImpl) GetInstanceInfosInfoByFilters 

func (repo *CbsTcInstanceInfosRepositoryImpl) GetInstanceInfosInfoByFilters(ids []string) (instances *cvm.DescribeInstancesResponse, err error)

type CbsTcInstanceRepository 

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

func (*CbsTcInstanceRepository) Get 

func (repo *CbsTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CbsTcInstanceRepository) GetInstanceKey 

func (repo *CbsTcInstanceRepository) GetInstanceKey() string

func (*CbsTcInstanceRepository) ListByFilters 

func (repo *CbsTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CbsTcInstanceRepository) ListByIds 

func (repo *CbsTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CdbTcInstance 

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

func NewCdbTcInstance 

func NewCdbTcInstance(instanceId string, meta *sdk.InstanceInfo) (ins *CdbTcInstance, err error)

func (*CdbTcInstance) GetFieldValueByName 

func (ins *CdbTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CdbTcInstance) GetFieldValuesByName 

func (ins *CdbTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CdbTcInstance) GetInstanceId 

func (ins *CdbTcInstance) GetInstanceId() string

func (*CdbTcInstance) GetMeta 

func (ins *CdbTcInstance) GetMeta() interface{}

func (*CdbTcInstance) GetMonitorQueryKey 

func (ins *CdbTcInstance) GetMonitorQueryKey() string

type CdbTcInstanceRepository 

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

func (*CdbTcInstanceRepository) Get 

func (repo *CdbTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CdbTcInstanceRepository) GetInstanceKey 

func (repo *CdbTcInstanceRepository) GetInstanceKey() string

func (*CdbTcInstanceRepository) ListByFilters 

func (repo *CdbTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CdbTcInstanceRepository) ListByIds 

func (repo *CdbTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CdnTcInstance 

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

func NewCdnTcInstance 

func NewCdnTcInstance(instanceId string, meta *sdk.BriefDomain) (ins *CdnTcInstance, err error)

func (*CdnTcInstance) GetFieldValueByName 

func (ins *CdnTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CdnTcInstance) GetFieldValuesByName 

func (ins *CdnTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CdnTcInstance) GetInstanceId 

func (ins *CdnTcInstance) GetInstanceId() string

func (*CdnTcInstance) GetMeta 

func (ins *CdnTcInstance) GetMeta() interface{}

func (*CdnTcInstance) GetMonitorQueryKey 

func (ins *CdnTcInstance) GetMonitorQueryKey() string

type CdnTcInstanceRepository 

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

func (*CdnTcInstanceRepository) Get 

func (repo *CdnTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CdnTcInstanceRepository) GetInstanceKey 

func (repo *CdnTcInstanceRepository) GetInstanceKey() string

func (*CdnTcInstanceRepository) ListByFilters 

func (repo *CdnTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CdnTcInstanceRepository) ListByIds 

func (repo *CdnTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CfsSnapshotsRepository 

type CfsSnapshotsRepository interface {
	GetCfsSnapshotsInfo(instanceId string) (*sdk.DescribeCfsSnapshotsResponse, error)
}

Replications

func NewCfsSnapshotsRepositoryRepository 

func NewCfsSnapshotsRepositoryRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (CfsSnapshotsRepository, error)

func NewCfsSnapshotsRepositoryRepositoryCache 

func NewCfsSnapshotsRepositoryRepositoryCache(repo CfsSnapshotsRepository, reloadInterval time.Duration, logger log.Logger) CfsSnapshotsRepository

type CfsSnapshotsRepositoryImpl 

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

func (*CfsSnapshotsRepositoryImpl) GetCfsSnapshotsInfo 

func (repo *CfsSnapshotsRepositoryImpl) GetCfsSnapshotsInfo(instanceId string) (*sdk.DescribeCfsSnapshotsResponse, error)

type CfsTcInstance 

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

func NewCfsTcInstance 

func NewCfsTcInstance(instanceId string, meta *sdk.FileSystemInfo) (ins *CfsTcInstance, err error)

func (*CfsTcInstance) GetFieldValueByName 

func (ins *CfsTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CfsTcInstance) GetFieldValuesByName 

func (ins *CfsTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CfsTcInstance) GetInstanceId 

func (ins *CfsTcInstance) GetInstanceId() string

func (*CfsTcInstance) GetMeta 

func (ins *CfsTcInstance) GetMeta() interface{}

func (*CfsTcInstance) GetMonitorQueryKey 

func (ins *CfsTcInstance) GetMonitorQueryKey() string

type CfsTcInstanceRepository 

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

func (*CfsTcInstanceRepository) Get 

func (repo *CfsTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CfsTcInstanceRepository) GetInstanceKey 

func (repo *CfsTcInstanceRepository) GetInstanceKey() string

func (*CfsTcInstanceRepository) ListByFilters 

func (repo *CfsTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CfsTcInstanceRepository) ListByIds 

func (repo *CfsTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type ClbInstance 

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

func NewClbTcInstance 

func NewClbTcInstance(instanceId string, meta *sdk.LoadBalancer) (ins *ClbInstance, err error)

func (*ClbInstance) GetFieldValueByName 

func (ins *ClbInstance) GetFieldValueByName(name string) (val string, err error)

func (*ClbInstance) GetFieldValuesByName 

func (ins *ClbInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*ClbInstance) GetInstanceId 

func (ins *ClbInstance) GetInstanceId() string

func (*ClbInstance) GetMeta 

func (ins *ClbInstance) GetMeta() interface{}

func (*ClbInstance) GetMonitorQueryKey 

func (ins *ClbInstance) GetMonitorQueryKey() string

type ClbPrivateInstance 

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

func NewClbPrivateTcInstance 

func NewClbPrivateTcInstance(instanceId string, meta *sdk.LoadBalancer) (ins *ClbPrivateInstance, err error)

func (*ClbPrivateInstance) GetFieldValueByName 

func (ins *ClbPrivateInstance) GetFieldValueByName(name string) (val string, err error)

func (*ClbPrivateInstance) GetFieldValuesByName 

func (ins *ClbPrivateInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*ClbPrivateInstance) GetInstanceId 

func (ins *ClbPrivateInstance) GetInstanceId() string

func (*ClbPrivateInstance) GetMeta 

func (ins *ClbPrivateInstance) GetMeta() interface{}

func (*ClbPrivateInstance) GetMonitorQueryKey 

func (ins *ClbPrivateInstance) GetMonitorQueryKey() string

type ClbPrivateTcInstanceRepository 

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

func (*ClbPrivateTcInstanceRepository) Get 

func (repo *ClbPrivateTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*ClbPrivateTcInstanceRepository) GetInstanceKey 

func (repo *ClbPrivateTcInstanceRepository) GetInstanceKey() string

func (*ClbPrivateTcInstanceRepository) ListByFilters 

func (repo *ClbPrivateTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*ClbPrivateTcInstanceRepository) ListByIds 

func (repo *ClbPrivateTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type ClbTcInstanceRepository 

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

func (*ClbTcInstanceRepository) Get 

func (repo *ClbTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*ClbTcInstanceRepository) GetInstanceKey 

func (repo *ClbTcInstanceRepository) GetInstanceKey() string

func (*ClbTcInstanceRepository) ListByFilters 

func (repo *ClbTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*ClbTcInstanceRepository) ListByIds 

func (repo *ClbTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CommonQaapTcInstanceRepository 

type CommonQaapTcInstanceRepository interface {
	GetCommonQaapProxyInstances(instanceId string) (ProxyInstancesRsp, error)
	GetCommonQaapNoneBgpIpList(instanceId string) (NoneBgpIpListRsp, error)
}

func NewCommonQaapTcInstanceRepository 

func NewCommonQaapTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (CommonQaapTcInstanceRepository, error)

func NewTcCommonGaapInstanceInfosCache 

func NewTcCommonGaapInstanceInfosCache(repo CommonQaapTcInstanceRepository, reloadInterval time.Duration, logger log.Logger) CommonQaapTcInstanceRepository

type CommonQaapTcInstanceRepositoryImpl 

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

func (*CommonQaapTcInstanceRepositoryImpl) GetCommonQaapNoneBgpIpList 

func (repo *CommonQaapTcInstanceRepositoryImpl) GetCommonQaapNoneBgpIpList(instanceId string) (NoneBgpIpListRsp, error)

func (*CommonQaapTcInstanceRepositoryImpl) GetCommonQaapProxyInstances 

func (repo *CommonQaapTcInstanceRepositoryImpl) GetCommonQaapProxyInstances(instanceId string) (ProxyInstancesRsp, error)

type CosTcInstance 

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

func NewCosTcInstance 

func NewCosTcInstance(instanceId string, meta *sdk.Bucket) (ins *CosTcInstance, err error)

func (*CosTcInstance) GetFieldValueByName 

func (ins *CosTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CosTcInstance) GetFieldValuesByName 

func (ins *CosTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CosTcInstance) GetInstanceId 

func (ins *CosTcInstance) GetInstanceId() string

func (*CosTcInstance) GetMeta 

func (ins *CosTcInstance) GetMeta() interface{}

func (*CosTcInstance) GetMonitorQueryKey 

func (ins *CosTcInstance) GetMonitorQueryKey() string

type CosTcInstanceRepository 

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

func (*CosTcInstanceRepository) Get 

func (repo *CosTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CosTcInstanceRepository) GetInstanceKey 

func (repo *CosTcInstanceRepository) GetInstanceKey() string

func (*CosTcInstanceRepository) ListByFilters 

func (repo *CosTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CosTcInstanceRepository) ListByIds 

func (repo *CosTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CvmTcInstance 

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

func NewCvmTcInstance 

func NewCvmTcInstance(instanceId string, meta *sdk.Instance) (ins *CvmTcInstance, err error)

func (*CvmTcInstance) GetFieldValueByName 

func (ins *CvmTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CvmTcInstance) GetFieldValuesByName 

func (ins *CvmTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CvmTcInstance) GetInstanceId 

func (ins *CvmTcInstance) GetInstanceId() string

func (*CvmTcInstance) GetMeta 

func (ins *CvmTcInstance) GetMeta() interface{}

func (*CvmTcInstance) GetMonitorQueryKey 

func (ins *CvmTcInstance) GetMonitorQueryKey() string

type CvmTcInstanceRepository 

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

func (*CvmTcInstanceRepository) Get 

func (repo *CvmTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CvmTcInstanceRepository) GetInstanceKey 

func (repo *CvmTcInstanceRepository) GetInstanceKey() string

func (*CvmTcInstanceRepository) ListByFilters 

func (repo *CvmTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CvmTcInstanceRepository) ListByIds 

func (repo *CvmTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type CynosdbTcInstance 

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

func NewCynosdbTcInstance 

func NewCynosdbTcInstance(instanceId string, meta *sdk.CynosdbInstance) (ins *CynosdbTcInstance, err error)

func (*CynosdbTcInstance) GetFieldValueByName 

func (ins *CynosdbTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*CynosdbTcInstance) GetFieldValuesByName 

func (ins *CynosdbTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*CynosdbTcInstance) GetInstanceId 

func (ins *CynosdbTcInstance) GetInstanceId() string

func (*CynosdbTcInstance) GetMeta 

func (ins *CynosdbTcInstance) GetMeta() interface{}

func (*CynosdbTcInstance) GetMonitorQueryKey 

func (ins *CynosdbTcInstance) GetMonitorQueryKey() string

type CynosdbTcInstanceRepository 

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

func (*CynosdbTcInstanceRepository) Get 

func (repo *CynosdbTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*CynosdbTcInstanceRepository) GetInstanceKey 

func (repo *CynosdbTcInstanceRepository) GetInstanceKey() string

func (*CynosdbTcInstanceRepository) ListByFilters 

func (repo *CynosdbTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*CynosdbTcInstanceRepository) ListByIds 

func (repo *CynosdbTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DTSTcInstanceRepository 

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

func (*DTSTcInstanceRepository) Get 

func (repo *DTSTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*DTSTcInstanceRepository) GetInstanceKey 

func (repo *DTSTcInstanceRepository) GetInstanceKey() string

func (*DTSTcInstanceRepository) ListByFilters 

func (repo *DTSTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*DTSTcInstanceRepository) ListByIds 

func (repo *DTSTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DcTcInstance 

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

func NewDcTcInstance 

func NewDcTcInstance(instanceId string, meta *sdk.DirectConnect) (ins *DcTcInstance, err error)

func (*DcTcInstance) GetFieldValueByName 

func (ins *DcTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*DcTcInstance) GetFieldValuesByName 

func (ins *DcTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*DcTcInstance) GetInstanceId 

func (ins *DcTcInstance) GetInstanceId() string

func (*DcTcInstance) GetMeta 

func (ins *DcTcInstance) GetMeta() interface{}

func (*DcTcInstance) GetMonitorQueryKey 

func (ins *DcTcInstance) GetMonitorQueryKey() string

type DcTcInstanceRepository 

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

func (*DcTcInstanceRepository) Get 

func (repo *DcTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*DcTcInstanceRepository) GetInstanceKey 

func (repo *DcTcInstanceRepository) GetInstanceKey() string

func (*DcTcInstanceRepository) ListByFilters 

func (repo *DcTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*DcTcInstanceRepository) ListByIds 

func (repo *DcTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DcdbTcInstance 

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

func NewDcdbTcInstance 

func NewDcdbTcInstance(instanceId string, meta *sdk.DCDBInstanceInfo) (ins *DcdbTcInstance, err error)

func (*DcdbTcInstance) GetFieldValueByName 

func (ins *DcdbTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*DcdbTcInstance) GetFieldValuesByName 

func (ins *DcdbTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*DcdbTcInstance) GetInstanceId 

func (ins *DcdbTcInstance) GetInstanceId() string

func (*DcdbTcInstance) GetMeta 

func (ins *DcdbTcInstance) GetMeta() interface{}

func (*DcdbTcInstance) GetMonitorQueryKey 

func (ins *DcdbTcInstance) GetMonitorQueryKey() string

type DcdbTcInstanceRepository 

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

func (*DcdbTcInstanceRepository) Get 

func (repo *DcdbTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*DcdbTcInstanceRepository) GetInstanceKey 

func (repo *DcdbTcInstanceRepository) GetInstanceKey() string

func (*DcdbTcInstanceRepository) ListByFilters 

func (repo *DcdbTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*DcdbTcInstanceRepository) ListByIds 

func (repo *DcdbTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DcgTcInstance 

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

func NewDcgTcInstance 

func NewDcgTcInstance(instanceId string, meta *sdk.DirectConnectGateway) (ins *DcgTcInstance, err error)

func (*DcgTcInstance) GetFieldValueByName 

func (ins *DcgTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*DcgTcInstance) GetFieldValuesByName 

func (ins *DcgTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*DcgTcInstance) GetInstanceId 

func (ins *DcgTcInstance) GetInstanceId() string

func (*DcgTcInstance) GetMeta 

func (ins *DcgTcInstance) GetMeta() interface{}

func (*DcgTcInstance) GetMonitorQueryKey 

func (ins *DcgTcInstance) GetMonitorQueryKey() string

type DcgTcInstanceRepository 

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

func (*DcgTcInstanceRepository) Get 

func (repo *DcgTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*DcgTcInstanceRepository) GetInstanceKey 

func (repo *DcgTcInstanceRepository) GetInstanceKey() string

func (*DcgTcInstanceRepository) ListByFilters 

func (repo *DcgTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*DcgTcInstanceRepository) ListByIds 

func (repo *DcgTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DcxTcInstance 

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

func NewDcxTcInstance 

func NewDcxTcInstance(instanceId string, meta *sdk.DirectConnectTunnel) (ins *DcxTcInstance, err error)

func (*DcxTcInstance) GetFieldValueByName 

func (ins *DcxTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*DcxTcInstance) GetFieldValuesByName 

func (ins *DcxTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*DcxTcInstance) GetInstanceId 

func (ins *DcxTcInstance) GetInstanceId() string

func (*DcxTcInstance) GetMeta 

func (ins *DcxTcInstance) GetMeta() interface{}

func (*DcxTcInstance) GetMonitorQueryKey 

func (ins *DcxTcInstance) GetMonitorQueryKey() string

type DcxTcInstanceRepository 

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

func (*DcxTcInstanceRepository) Get 

func (repo *DcxTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*DcxTcInstanceRepository) GetInstanceKey 

func (repo *DcxTcInstanceRepository) GetInstanceKey() string

func (*DcxTcInstanceRepository) ListByFilters 

func (repo *DcxTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*DcxTcInstanceRepository) ListByIds 

func (repo *DcxTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type DtsTcInstance 

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

func NewDtsTcInstance 

func NewDtsTcInstance(instanceId string, meta *sdk.SubscribeInfo) (ins *DtsTcInstance, err error)

func (*DtsTcInstance) GetFieldValueByName 

func (ins *DtsTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*DtsTcInstance) GetFieldValuesByName 

func (ins *DtsTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*DtsTcInstance) GetInstanceId 

func (ins *DtsTcInstance) GetInstanceId() string

func (*DtsTcInstance) GetMeta 

func (ins *DtsTcInstance) GetMeta() interface{}

func (*DtsTcInstance) GetMonitorQueryKey 

func (ins *DtsTcInstance) GetMonitorQueryKey() string

type DtsTcInstanceMigrateInfosRepository 

type DtsTcInstanceMigrateInfosRepository interface {
	GetMigrateInfos(instanceId string) (*sdk.DescribeMigrateJobsResponse, error)
}

MigrateInfos

func NewDtsTcInstanceMigrateInfosRepository 

func NewDtsTcInstanceMigrateInfosRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (DtsTcInstanceMigrateInfosRepository, error)

func NewTcDtsInstanceMigrateInfosCache 

func NewTcDtsInstanceMigrateInfosCache(repo DtsTcInstanceMigrateInfosRepository, reloadInterval time.Duration, logger log.Logger) DtsTcInstanceMigrateInfosRepository

type DtsTcInstanceMigrateInfosRepositoryImpl 

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

func (*DtsTcInstanceMigrateInfosRepositoryImpl) GetMigrateInfos 

func (repo *DtsTcInstanceMigrateInfosRepositoryImpl) GetMigrateInfos(instanceId string) (*sdk.DescribeMigrateJobsResponse, error)

type DtsTcInstanceReplicationsRepository 

type DtsTcInstanceReplicationsRepository interface {
	GetReplicationsInfo(instanceId string) (*dtsNew.DescribeSyncJobsResponse, error)
}

Replications

func NewDtsTcInstanceReplicationsRepository 

func NewDtsTcInstanceReplicationsRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (DtsTcInstanceReplicationsRepository, error)

func NewTcDtsInstanceReplicationsInfosCache 

func NewTcDtsInstanceReplicationsInfosCache(repo DtsTcInstanceReplicationsRepository, reloadInterval time.Duration, logger log.Logger) DtsTcInstanceReplicationsRepository

type DtsTcInstanceReplicationsRepositoryImpl 

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

func (*DtsTcInstanceReplicationsRepositoryImpl) GetReplicationsInfo 

func (repo *DtsTcInstanceReplicationsRepositoryImpl) GetReplicationsInfo(instanceId string) (*dtsNew.DescribeSyncJobsResponse, error)

type EIPInstance 

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

func NewEIPTcInstance 

func NewEIPTcInstance(instanceId string, meta *sdk.Address) (ins *EIPInstance, err error)

func (*EIPInstance) GetFieldValueByName 

func (ins *EIPInstance) GetFieldValueByName(name string) (val string, err error)

func (*EIPInstance) GetFieldValuesByName 

func (ins *EIPInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*EIPInstance) GetInstanceId 

func (ins *EIPInstance) GetInstanceId() string

func (*EIPInstance) GetMeta 

func (ins *EIPInstance) GetMeta() interface{}

func (*EIPInstance) GetMonitorQueryKey 

func (ins *EIPInstance) GetMonitorQueryKey() string

type EIPTcInstanceRepository 

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

func (*EIPTcInstanceRepository) Get 

func (repo *EIPTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*EIPTcInstanceRepository) GetInstanceKey 

func (repo *EIPTcInstanceRepository) GetInstanceKey() string

func (*EIPTcInstanceRepository) ListByFilters 

func (repo *EIPTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*EIPTcInstanceRepository) ListByIds 

func (repo *EIPTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type ESTcInstance 

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

func NewESTcInstance 

func NewESTcInstance(instanceId string, meta *sdk.InstanceInfo) (ins *ESTcInstance, err error)

func (*ESTcInstance) GetFieldValueByName 

func (ins *ESTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*ESTcInstance) GetFieldValuesByName 

func (ins *ESTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*ESTcInstance) GetInstanceId 

func (ins *ESTcInstance) GetInstanceId() string

func (*ESTcInstance) GetMeta 

func (ins *ESTcInstance) GetMeta() interface{}

func (*ESTcInstance) GetMonitorQueryKey 

func (ins *ESTcInstance) GetMonitorQueryKey() string

type ESTcInstanceRepository 

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

func (*ESTcInstanceRepository) Get 

func (repo *ESTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*ESTcInstanceRepository) GetInstanceKey 

func (repo *ESTcInstanceRepository) GetInstanceKey() string

func (*ESTcInstanceRepository) ListByFilters 

func (repo *ESTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*ESTcInstanceRepository) ListByIds 

func (repo *ESTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type InstanceDetail 

type InstanceDetail struct {
	IP      string
	Isp     string
	ProxyId string
	GroupId string
}

type KafkaTcInstanceRepository 

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

func (*KafkaTcInstanceRepository) Get 

func (repo *KafkaTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*KafkaTcInstanceRepository) GetInstanceKey 

func (repo *KafkaTcInstanceRepository) GetInstanceKey() string

func (*KafkaTcInstanceRepository) ListByFilters 

func (repo *KafkaTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*KafkaTcInstanceRepository) ListByIds 

func (repo *KafkaTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type L4ListenerDetail 

type L4ListenerDetail struct {
	ListenerId   string
	ListenerName string
	Protocol     string
	RsSet        []BoundRsDetail
}

type L7ListenerDetail 

type L7ListenerDetail struct {
	ListenerId      string
	ListenerName    string
	ForwardProtocol string
	RuleSet         []RuleDetail
}

type LighthouseTcInstance 

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

func NewLighthouseTcInstance 

func NewLighthouseTcInstance(instanceId string, meta *sdk.Instance) (ins *LighthouseTcInstance, err error)

func (*LighthouseTcInstance) GetFieldValueByName 

func (ins *LighthouseTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*LighthouseTcInstance) GetFieldValuesByName 

func (ins *LighthouseTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*LighthouseTcInstance) GetInstanceId 

func (ins *LighthouseTcInstance) GetInstanceId() string

func (*LighthouseTcInstance) GetMeta 

func (ins *LighthouseTcInstance) GetMeta() interface{}

func (*LighthouseTcInstance) GetMonitorQueryKey 

func (ins *LighthouseTcInstance) GetMonitorQueryKey() string

type LighthouseTcInstanceRepository 

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

func (*LighthouseTcInstanceRepository) Get 

func (repo *LighthouseTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*LighthouseTcInstanceRepository) GetInstanceKey 

func (repo *LighthouseTcInstanceRepository) GetInstanceKey() string

func (*LighthouseTcInstanceRepository) ListByFilters 

func (repo *LighthouseTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*LighthouseTcInstanceRepository) ListByIds 

func (repo *LighthouseTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type MariaDBTcInstance 

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

func NewMariaDBTcInstance 

func NewMariaDBTcInstance(instanceId string, meta *sdk.DBInstance) (ins *MariaDBTcInstance, err error)

func (*MariaDBTcInstance) GetFieldValueByName 

func (ins *MariaDBTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*MariaDBTcInstance) GetFieldValuesByName 

func (ins *MariaDBTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*MariaDBTcInstance) GetInstanceId 

func (ins *MariaDBTcInstance) GetInstanceId() string

func (*MariaDBTcInstance) GetMeta 

func (ins *MariaDBTcInstance) GetMeta() interface{}

func (*MariaDBTcInstance) GetMonitorQueryKey 

func (ins *MariaDBTcInstance) GetMonitorQueryKey() string

type MariaDBTcInstanceRepository 

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

func (*MariaDBTcInstanceRepository) Get 

func (repo *MariaDBTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*MariaDBTcInstanceRepository) GetInstanceKey 

func (repo *MariaDBTcInstanceRepository) GetInstanceKey() string

func (*MariaDBTcInstanceRepository) ListByFilters 

func (repo *MariaDBTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*MariaDBTcInstanceRepository) ListByIds 

func (repo *MariaDBTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type MemcachedTcInstance 

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

func NewMemcachedTcInstance 

func NewMemcachedTcInstance(instanceId string, meta *sdk.InstanceListInfo) (ins *MemcachedTcInstance, err error)

func (*MemcachedTcInstance) GetFieldValueByName 

func (ins *MemcachedTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*MemcachedTcInstance) GetFieldValuesByName 

func (ins *MemcachedTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*MemcachedTcInstance) GetInstanceId 

func (ins *MemcachedTcInstance) GetInstanceId() string

func (*MemcachedTcInstance) GetMeta 

func (ins *MemcachedTcInstance) GetMeta() interface{}

func (*MemcachedTcInstance) GetMonitorQueryKey 

func (ins *MemcachedTcInstance) GetMonitorQueryKey() string

type MemcachedTcInstanceRepository 

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

func (*MemcachedTcInstanceRepository) Get 

func (repo *MemcachedTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*MemcachedTcInstanceRepository) GetInstanceKey 

func (repo *MemcachedTcInstanceRepository) GetInstanceKey() string

func (*MemcachedTcInstanceRepository) ListByFilters 

func (repo *MemcachedTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*MemcachedTcInstanceRepository) ListByIds 

func (repo *MemcachedTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type MongoTcInstance 

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

func NewMongoTcInstance 

func NewMongoTcInstance(instanceId string, meta *sdk.InstanceDetail) (ins *MongoTcInstance, err error)

func (*MongoTcInstance) GetFieldValueByName 

func (ins *MongoTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*MongoTcInstance) GetFieldValuesByName 

func (ins *MongoTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*MongoTcInstance) GetInstanceId 

func (ins *MongoTcInstance) GetInstanceId() string

func (*MongoTcInstance) GetMeta 

func (ins *MongoTcInstance) GetMeta() interface{}

func (*MongoTcInstance) GetMonitorQueryKey 

func (ins *MongoTcInstance) GetMonitorQueryKey() string

type MongoTcInstanceRepository 

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

func (*MongoTcInstanceRepository) Get 

func (repo *MongoTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*MongoTcInstanceRepository) GetInstanceKey 

func (repo *MongoTcInstanceRepository) GetInstanceKey() string

func (*MongoTcInstanceRepository) ListByFilters 

func (repo *MongoTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*MongoTcInstanceRepository) ListByIds 

func (repo *MongoTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type NacosTcInstanceInterfaceRepository 

type NacosTcInstanceInterfaceRepository interface {
	GetNacosInterfaceInfo(instanceId string) (*sdk.DescribeNacosServerInterfacesResponse, error)
}

NacosInterface

func NewNacosTcInstanceInterfaceRepository 

func NewNacosTcInstanceInterfaceRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (NacosTcInstanceInterfaceRepository, error)

func NewTcNacosInstanceInterfaceCache 

func NewTcNacosInstanceInterfaceCache(repo NacosTcInstanceInterfaceRepository, reloadInterval time.Duration, logger log.Logger) NacosTcInstanceInterfaceRepository

type NacosTcInstanceInterfaceRepositoryImpl 

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

func (*NacosTcInstanceInterfaceRepositoryImpl) GetNacosInterfaceInfo 

func (repo *NacosTcInstanceInterfaceRepositoryImpl) GetNacosInterfaceInfo(instanceId string) (*sdk.DescribeNacosServerInterfacesResponse, error)

type NacosTcInstancePodRepository 

type NacosTcInstancePodRepository interface {
	GetNacosPodInfo(instanceId string) (*sdk.DescribeNacosReplicasResponse, error)
}

NacosPod

func NewNacosTcInstancePodRepository 

func NewNacosTcInstancePodRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (NacosTcInstancePodRepository, error)

func NewTcNacosInstancePodCache 

func NewTcNacosInstancePodCache(repo NacosTcInstancePodRepository, reloadInterval time.Duration, logger log.Logger) NacosTcInstancePodRepository

type NacosTcInstancePodRepositoryImpl 

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

func (*NacosTcInstancePodRepositoryImpl) GetNacosPodInfo 

func (repo *NacosTcInstancePodRepositoryImpl) GetNacosPodInfo(instanceId string) (*sdk.DescribeNacosReplicasResponse, error)

type NacosTcInstanceRepository 

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

func (*NacosTcInstanceRepository) Get 

func (repo *NacosTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*NacosTcInstanceRepository) GetInstanceKey 

func (repo *NacosTcInstanceRepository) GetInstanceKey() string

func (*NacosTcInstanceRepository) ListByFilters 

func (repo *NacosTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*NacosTcInstanceRepository) ListByIds 

func (repo *NacosTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type NatTcInstance 

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

func NewNatTcInstance 

func NewNatTcInstance(instanceId string, meta *sdk.NatGateway) (ins *NatTcInstance, err error)

func (*NatTcInstance) GetFieldValueByName 

func (ins *NatTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*NatTcInstance) GetFieldValuesByName 

func (ins *NatTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*NatTcInstance) GetInstanceId 

func (ins *NatTcInstance) GetInstanceId() string

func (*NatTcInstance) GetMeta 

func (ins *NatTcInstance) GetMeta() interface{}

func (*NatTcInstance) GetMonitorQueryKey 

func (ins *NatTcInstance) GetMonitorQueryKey() string

type NatTcInstanceRepository 

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

func (*NatTcInstanceRepository) Get 

func (repo *NatTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*NatTcInstanceRepository) GetInstanceKey 

func (repo *NatTcInstanceRepository) GetInstanceKey() string

func (*NatTcInstanceRepository) ListByFilters 

func (repo *NatTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*NatTcInstanceRepository) ListByIds 

func (repo *NatTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type NoneBgpIpListResponse 

type NoneBgpIpListResponse struct {
	TotalCount  int64
	InstanceSet []InstanceDetail
}

type NoneBgpIpListRsp 

type NoneBgpIpListRsp struct {
	Response NoneBgpIpListResponse
}

type PGTcInstance 

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

func NewPGTcInstance 

func NewPGTcInstance(instanceId string, meta *sdk.DBInstance) (ins *PGTcInstance, err error)

func (*PGTcInstance) GetFieldValueByName 

func (ins *PGTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*PGTcInstance) GetFieldValuesByName 

func (ins *PGTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*PGTcInstance) GetInstanceId 

func (ins *PGTcInstance) GetInstanceId() string

func (*PGTcInstance) GetMeta 

func (ins *PGTcInstance) GetMeta() interface{}

func (*PGTcInstance) GetMonitorQueryKey 

func (ins *PGTcInstance) GetMonitorQueryKey() string

type PGTcInstanceRepository 

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

func (*PGTcInstanceRepository) Get 

func (repo *PGTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*PGTcInstanceRepository) GetInstanceKey 

func (repo *PGTcInstanceRepository) GetInstanceKey() string

func (*PGTcInstanceRepository) ListByFilters 

func (repo *PGTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*PGTcInstanceRepository) ListByIds 

func (repo *PGTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type ProxyDetail 

type ProxyDetail struct {
	ProxyId       string
	ProxyName     string
	L4ListenerSet []L4ListenerDetail
	L7ListenerSet []L7ListenerDetail
}

type ProxyInstancesResponse 

type ProxyInstancesResponse struct {
	TotalCount int64
	ProxySet   []ProxyDetail
}

内部接口

type ProxyInstancesRsp 

type ProxyInstancesRsp struct {
	Response ProxyInstancesResponse
}

type QaapTcInstance 

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

func NewQaapTcInstance 

func NewQaapTcInstance(instanceId string, meta *sdk.ProxyInfo) (ins *QaapTcInstance, err error)

func (*QaapTcInstance) GetFieldValueByName 

func (ins *QaapTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*QaapTcInstance) GetFieldValuesByName 

func (ins *QaapTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*QaapTcInstance) GetInstanceId 

func (ins *QaapTcInstance) GetInstanceId() string

func (*QaapTcInstance) GetMeta 

func (ins *QaapTcInstance) GetMeta() interface{}

func (*QaapTcInstance) GetMonitorQueryKey 

func (ins *QaapTcInstance) GetMonitorQueryKey() string

type QaapTcInstanceInfoRepository 

type QaapTcInstanceInfoRepository interface {
	GetProxyGroupList(instanceId string) (*sdk.DescribeProxyGroupListResponse, error)
	GetUDPListenersInfo(instanceId string) (*sdk.DescribeUDPListenersResponse, error)
	GetTCPListenersInfo(instanceId string) (*sdk.DescribeTCPListenersResponse, error)
}

DescribeProxyGroupList

func NewQaapTcInstanceInfoRepository 

func NewQaapTcInstanceInfoRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (QaapTcInstanceInfoRepository, error)

func NewTcGaapInstanceInfosCache 

func NewTcGaapInstanceInfosCache(repo QaapTcInstanceInfoRepository, reloadInterval time.Duration, logger log.Logger) QaapTcInstanceInfoRepository

type QaapTcInstanceInfoRepositoryImpl 

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

func (*QaapTcInstanceInfoRepositoryImpl) GetProxyGroupList 

func (repo *QaapTcInstanceInfoRepositoryImpl) GetProxyGroupList(instanceId string) (*sdk.DescribeProxyGroupListResponse, error)

func (*QaapTcInstanceInfoRepositoryImpl) GetTCPListenersInfo 

func (repo *QaapTcInstanceInfoRepositoryImpl) GetTCPListenersInfo(instanceId string) (*sdk.DescribeTCPListenersResponse, error)

func (*QaapTcInstanceInfoRepositoryImpl) GetUDPListenersInfo 

func (repo *QaapTcInstanceInfoRepositoryImpl) GetUDPListenersInfo(instanceId string) (*sdk.DescribeUDPListenersResponse, error)

type QaapTcInstanceRepository 

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

func (*QaapTcInstanceRepository) Get 

func (repo *QaapTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*QaapTcInstanceRepository) GetInstanceKey 

func (repo *QaapTcInstanceRepository) GetInstanceKey() string

func (*QaapTcInstanceRepository) ListByFilters 

func (repo *QaapTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*QaapTcInstanceRepository) ListByIds 

func (repo *QaapTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type RedisTcInstance 

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

func NewRedisTcInstance 

func NewRedisTcInstance(instanceId string, meta *sdk.InstanceSet) (ins *RedisTcInstance, err error)

func (*RedisTcInstance) GetFieldValueByName 

func (ins *RedisTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*RedisTcInstance) GetFieldValuesByName 

func (ins *RedisTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*RedisTcInstance) GetInstanceId 

func (ins *RedisTcInstance) GetInstanceId() string

func (*RedisTcInstance) GetMeta 

func (ins *RedisTcInstance) GetMeta() interface{}

func (*RedisTcInstance) GetMonitorQueryKey 

func (ins *RedisTcInstance) GetMonitorQueryKey() string

type RedisTcInstanceNodeRepository 

type RedisTcInstanceNodeRepository interface {
	GetNodeInfo(instanceId string) (*sdk.DescribeInstanceNodeInfoResponse, error)
}

func NewRedisTcInstanceNodeRepository 

func NewRedisTcInstanceNodeRepository(cred mycommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (RedisTcInstanceNodeRepository, error)

func NewTcRedisInstanceNodeCache 

func NewTcRedisInstanceNodeCache(repo RedisTcInstanceNodeRepository, reloadInterval time.Duration, logger log.Logger) RedisTcInstanceNodeRepository

type RedisTcInstanceNodeRepositoryImpl 

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

func (*RedisTcInstanceNodeRepositoryImpl) GetNodeInfo 

func (repo *RedisTcInstanceNodeRepositoryImpl) GetNodeInfo(instanceId string) (*sdk.DescribeInstanceNodeInfoResponse, error)

type RedisTcInstanceRepository 

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

func (*RedisTcInstanceRepository) Get 

func (repo *RedisTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*RedisTcInstanceRepository) GetInstanceKey 

func (repo *RedisTcInstanceRepository) GetInstanceKey() string

func (*RedisTcInstanceRepository) ListByFilters 

func (repo *RedisTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*RedisTcInstanceRepository) ListByIds 

func (repo *RedisTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type RuleDetail 

type RuleDetail struct {
	RsSet  []BoundRsDetail
	RuleId string
}

type SqlServerTcInstance 

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

func NewSqlServerTcInstance 

func NewSqlServerTcInstance(instanceId string, meta *sdk.DBInstance) (ins *SqlServerTcInstance, err error)

func (*SqlServerTcInstance) GetFieldValueByName 

func (ins *SqlServerTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*SqlServerTcInstance) GetFieldValuesByName 

func (ins *SqlServerTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*SqlServerTcInstance) GetInstanceId 

func (ins *SqlServerTcInstance) GetInstanceId() string

func (*SqlServerTcInstance) GetMeta 

func (ins *SqlServerTcInstance) GetMeta() interface{}

func (*SqlServerTcInstance) GetMonitorQueryKey 

func (ins *SqlServerTcInstance) GetMonitorQueryKey() string

type SqlServerTcInstanceRepository 

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

func (*SqlServerTcInstanceRepository) Get 

func (repo *SqlServerTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*SqlServerTcInstanceRepository) GetInstanceKey 

func (repo *SqlServerTcInstanceRepository) GetInstanceKey() string

func (*SqlServerTcInstanceRepository) ListByFilters 

func (repo *SqlServerTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*SqlServerTcInstanceRepository) ListByIds 

func (repo *SqlServerTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type TcCfsInstanceSnapshotsCache 

type TcCfsInstanceSnapshotsCache struct {
	Raw CfsSnapshotsRepository
	// contains filtered or unexported fields
}

cfs

func (*TcCfsInstanceSnapshotsCache) GetCfsSnapshotsInfo 

func (c *TcCfsInstanceSnapshotsCache) GetCfsSnapshotsInfo(instanceId string) (*cfs.DescribeCfsSnapshotsResponse, error)

type TcCommonGaapInstanceInfosCache 

type TcCommonGaapInstanceInfosCache struct {
	Raw CommonQaapTcInstanceRepository
	// contains filtered or unexported fields
}

func (*TcCommonGaapInstanceInfosCache) GetCommonQaapNoneBgpIpList 

func (c *TcCommonGaapInstanceInfosCache) GetCommonQaapNoneBgpIpList(instanceId string) (NoneBgpIpListRsp, error)

func (*TcCommonGaapInstanceInfosCache) GetCommonQaapProxyInstances 

func (c *TcCommonGaapInstanceInfosCache) GetCommonQaapProxyInstances(instanceId string) (ProxyInstancesRsp, error)

type TcDtsInstanceMigrateInfosCache 

type TcDtsInstanceMigrateInfosCache struct {
	Raw DtsTcInstanceMigrateInfosRepository
	// contains filtered or unexported fields
}

dts

func (*TcDtsInstanceMigrateInfosCache) GetMigrateInfos 

func (c *TcDtsInstanceMigrateInfosCache) GetMigrateInfos(instanceId string) (*dts.DescribeMigrateJobsResponse, error)

type TcDtsInstanceReplicationCache 

type TcDtsInstanceReplicationCache struct {
	Raw DtsTcInstanceReplicationsRepository
	// contains filtered or unexported fields
}

func (*TcDtsInstanceReplicationCache) GetReplicationsInfo 

func (c *TcDtsInstanceReplicationCache) GetReplicationsInfo(instanceId string) (*dtsNew.DescribeSyncJobsResponse, error)

type TcGaapInstanceInfosCache 

type TcGaapInstanceInfosCache struct {
	Raw QaapTcInstanceInfoRepository
	// contains filtered or unexported fields
}

gaap

func (*TcGaapInstanceInfosCache) GetProxyGroupList 

func (c *TcGaapInstanceInfosCache) GetProxyGroupList(instanceId string) (*gaap.DescribeProxyGroupListResponse, error)

func (*TcGaapInstanceInfosCache) GetTCPListenersInfo 

func (c *TcGaapInstanceInfosCache) GetTCPListenersInfo(instanceId string) (*gaap.DescribeTCPListenersResponse, error)

func (*TcGaapInstanceInfosCache) GetUDPListenersInfo 

func (c *TcGaapInstanceInfosCache) GetUDPListenersInfo(instanceId string) (*gaap.DescribeUDPListenersResponse, error)

type TcInstance 

type TcInstance interface {
	// 获取实例的id
	GetInstanceId() string

	// 用于查询云监控数据的主键字段, 一般是实例id
	GetMonitorQueryKey() string

	// 根据字段名称获取该字段的值, 由各个产品接口具体实现
	GetFieldValueByName(string) (string, error)

	// 根据字段名称获取该字段的值, 由各个产品接口具体实现
	GetFieldValuesByName(string) (map[string][]string, error)

	// 获取实例raw元数据, 每个实例类型不一样
	GetMeta() interface{}
}

每个产品的实例对象, 可用于配置导出指标的额外label填充, 根据字段名获取值

type TcInstanceCache 

type TcInstanceCache struct {
	Raw TcInstanceRepository
	// contains filtered or unexported fields
}

可用于产品的实例的缓存, TcInstanceRepository

func (*TcInstanceCache) Get 

func (c *TcInstanceCache) Get(id string) (TcInstance, error)

func (*TcInstanceCache) GetInstanceKey 

func (c *TcInstanceCache) GetInstanceKey() string

func (*TcInstanceCache) ListByFilters 

func (c *TcInstanceCache) ListByFilters(filters map[string]string) (insList []TcInstance, err error)

func (*TcInstanceCache) ListByIds 

func (c *TcInstanceCache) ListByIds(ids []string) (insList []TcInstance, err error)

type TcInstanceRepository 

type TcInstanceRepository interface {
	// 获取实例id
	GetInstanceKey() string
	// 根据id, 获取实例对象
	Get(id string) (TcInstance, error)
	// 根据id列表, 获取所有的实例对象
	ListByIds(ids []string) ([]TcInstance, error)
	// 根据filters, 获取符合条件的所有实例对象
	ListByFilters(filters map[string]string) ([]TcInstance, error)
}

每个产品的实例对象的Repository

func NewCMQTcInstanceRepository 

func NewCMQTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCMQTopicTcInstanceRepository 

func NewCMQTopicTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCbsTcInstanceRepository 

func NewCbsTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCdbTcInstanceRepository 

func NewCdbTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCdnTcInstanceRepository 

func NewCdnTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCfsTcInstanceRepository 

func NewCfsTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewClbPrivateTcInstanceRepository 

func NewClbPrivateTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewClbTcInstanceRepository 

func NewClbTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCosTcInstanceRepository 

func NewCosTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCvmTcInstanceRepository 

func NewCvmTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewCynosdbTcInstanceRepository 

func NewCynosdbTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewDTSTcInstanceRepository 

func NewDTSTcInstanceRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewDcTcInstanceRepository 

func NewDcTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewDcdbTcInstanceRepository 

func NewDcdbTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewDcgTcInstanceRepository 

func NewDcgTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewDcxTcInstanceRepository 

func NewDcxTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewEIPTcInstanceRepository 

func NewEIPTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewESTcInstanceRepository 

func NewESTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewKafkaTcInstanceRepository 

func NewKafkaTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewLighthouseTcInstanceRepository 

func NewLighthouseTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewMariaDBTcInstanceRepository 

func NewMariaDBTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewMemcachedTcInstanceRepository 

func NewMemcachedTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewMongoTcInstanceRepository 

func NewMongoTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewNaocsTcInstanceRepository 

func NewNaocsTcInstanceRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewNatTcInstanceRepository 

func NewNatTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewPGTcInstanceRepository 

func NewPGTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewQaapTcInstanceRepository 

func NewQaapTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewRedisTcInstanceRepository 

func NewRedisTcInstanceRepository(cred mycommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewSqlServerTcInstanceRepository 

func NewSqlServerTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewTcInstanceCache 

func NewTcInstanceCache(repo TcInstanceRepository, reloadInterval time.Duration, logger log.Logger) TcInstanceRepository

func NewTcInstanceRepository 

func NewTcInstanceRepository(namespace string, cred common.CredentialIface, conf *config.TencentConfig, logger log.Logger) (TcInstanceRepository, error)

func NewTdmqTcInstanceRepository 

func NewTdmqTcInstanceRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewVbcTcInstanceRepository 

func NewVbcTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewVpngwTcInstanceRepository 

func NewVpngwTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewVpnxTcInstanceRepository 

func NewVpnxTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewWafTcInstanceRepository 

func NewWafTcInstanceRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

func NewZookeeperTcInstanceRepository 

func NewZookeeperTcInstanceRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (repo TcInstanceRepository, err error)

type TcNacosInstanceInterfaceCache 

type TcNacosInstanceInterfaceCache struct {
	Raw NacosTcInstanceInterfaceRepository
	// contains filtered or unexported fields
}

func (*TcNacosInstanceInterfaceCache) GetNacosInterfaceInfo 

func (c *TcNacosInstanceInterfaceCache) GetNacosInterfaceInfo(instanceId string) (*tse.DescribeNacosServerInterfacesResponse, error)

type TcNacosInstancePodCache 

type TcNacosInstancePodCache struct {
	Raw NacosTcInstancePodRepository
	// contains filtered or unexported fields
}

nacos

func (*TcNacosInstancePodCache) GetNacosPodInfo 

func (c *TcNacosInstancePodCache) GetNacosPodInfo(instanceId string) (*tse.DescribeNacosReplicasResponse, error)

type TcRedisInstanceNodeCache 

type TcRedisInstanceNodeCache struct {
	Raw RedisTcInstanceNodeRepository
	// contains filtered or unexported fields
}

func (*TcRedisInstanceNodeCache) GetNodeInfo 

func (c *TcRedisInstanceNodeCache) GetNodeInfo(instanceId string) (*sdk.DescribeInstanceNodeInfoResponse, error)

type TcTdmqInstanceNamespaceCache 

type TcTdmqInstanceNamespaceCache struct {
	Raw TdmqTcInstanceRocketMQNameSpacesRepository
	// contains filtered or unexported fields
}

tdmq

func (*TcTdmqInstanceNamespaceCache) GetRocketMQNamespacesInfo 

func (c *TcTdmqInstanceNamespaceCache) GetRocketMQNamespacesInfo(instanceId string) (*tdmq.DescribeRocketMQNamespacesResponse, error)

type TcTdmqInstanceTopicsCache 

type TcTdmqInstanceTopicsCache struct {
	Raw TdmqTcInstanceRocketMQTopicsRepository
	// contains filtered or unexported fields
}

func (*TcTdmqInstanceTopicsCache) GetRocketMQTopicsInfo 

func (c *TcTdmqInstanceTopicsCache) GetRocketMQTopicsInfo(instanceId string, namespaceId string) (*tdmq.DescribeRocketMQTopicsResponse, error)

type TcVbcInstanceDRegionCache 

type TcVbcInstanceDRegionCache struct {
	Raw VbcTcInstanceDRegionRepository
	// contains filtered or unexported fields
}

vbc

func (*TcVbcInstanceDRegionCache) GetVbcDRegionInfo 

func (c *TcVbcInstanceDRegionCache) GetVbcDRegionInfo(instanceId string) (*vbc.DescribeCcnRegionBandwidthLimitsResponse, error)

type TcZookeeperInstanceInterfaceCache 

type TcZookeeperInstanceInterfaceCache struct {
	Raw ZookeeperTcInstanceInterfaceRepository
	// contains filtered or unexported fields
}

func (*TcZookeeperInstanceInterfaceCache) GetZookeeperInterfaceInfo 

func (c *TcZookeeperInstanceInterfaceCache) GetZookeeperInterfaceInfo(instanceId string) (*tse.DescribeZookeeperServerInterfacesResponse, error)

type TcZookeeperInstancePodCache 

type TcZookeeperInstancePodCache struct {
	Raw ZookeeperTcInstancePodRepository
	// contains filtered or unexported fields
}

zookeeper

func (*TcZookeeperInstancePodCache) GetZookeeperPodInfo 

func (c *TcZookeeperInstancePodCache) GetZookeeperPodInfo(instanceId string) (*tse.DescribeZookeeperReplicasResponse, error)

type TdmqTcInstance 

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

func NewTdmqTcInstance 

func NewTdmqTcInstance(instanceId string, meta *sdk.RocketMQClusterDetail) (ins *TdmqTcInstance, err error)

func (*TdmqTcInstance) GetFieldValueByName 

func (ins *TdmqTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*TdmqTcInstance) GetFieldValuesByName 

func (ins *TdmqTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*TdmqTcInstance) GetInstanceId 

func (ins *TdmqTcInstance) GetInstanceId() string

func (*TdmqTcInstance) GetMeta 

func (ins *TdmqTcInstance) GetMeta() interface{}

func (*TdmqTcInstance) GetMonitorQueryKey 

func (ins *TdmqTcInstance) GetMonitorQueryKey() string

type TdmqTcInstanceRepository 

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

func (*TdmqTcInstanceRepository) Get 

func (repo *TdmqTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*TdmqTcInstanceRepository) GetInstanceKey 

func (repo *TdmqTcInstanceRepository) GetInstanceKey() string

func (*TdmqTcInstanceRepository) ListByFilters 

func (repo *TdmqTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*TdmqTcInstanceRepository) ListByIds 

func (repo *TdmqTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type TdmqTcInstanceRocketMQNameSpacesRepository 

type TdmqTcInstanceRocketMQNameSpacesRepository interface {
	GetRocketMQNamespacesInfo(instanceId string) (*sdk.DescribeRocketMQNamespacesResponse, error)
}

RocketMQNameSpaces

func NewTcTdmqInstanceNamespaceCache 

func NewTcTdmqInstanceNamespaceCache(repo TdmqTcInstanceRocketMQNameSpacesRepository, reloadInterval time.Duration, logger log.Logger) TdmqTcInstanceRocketMQNameSpacesRepository

func NewTdmqTcInstanceRocketMQNameSpacesRepository 

func NewTdmqTcInstanceRocketMQNameSpacesRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (TdmqTcInstanceRocketMQNameSpacesRepository, error)

type TdmqTcInstanceRocketMQNameSpacesRepositoryImpl 

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

func (*TdmqTcInstanceRocketMQNameSpacesRepositoryImpl) GetRocketMQNamespacesInfo 

func (repo *TdmqTcInstanceRocketMQNameSpacesRepositoryImpl) GetRocketMQNamespacesInfo(instanceId string) (*sdk.DescribeRocketMQNamespacesResponse, error)

type TdmqTcInstanceRocketMQTopicsRepository 

type TdmqTcInstanceRocketMQTopicsRepository interface {
	GetRocketMQTopicsInfo(instanceId string, namespaceId string) (*sdk.DescribeRocketMQTopicsResponse, error)
}

RocketMQTopics

func NewTcTdmqInstanceTopicsCache 

func NewTcTdmqInstanceTopicsCache(repo TdmqTcInstanceRocketMQTopicsRepository, reloadInterval time.Duration, logger log.Logger) TdmqTcInstanceRocketMQTopicsRepository

func NewTdmqTcInstanceRocketMQTopicsRepository 

func NewTdmqTcInstanceRocketMQTopicsRepository(cred selfcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (TdmqTcInstanceRocketMQTopicsRepository, error)

type TdmqTcInstanceRocketMQTopicsRepositoryImpl 

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

func (*TdmqTcInstanceRocketMQTopicsRepositoryImpl) GetRocketMQTopicsInfo 

func (repo *TdmqTcInstanceRocketMQTopicsRepositoryImpl) GetRocketMQTopicsInfo(instanceId string, namespaceId string) (*sdk.DescribeRocketMQTopicsResponse, error)

type TseTcInstance 

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

func NewTseTcInstance 

func NewTseTcInstance(instanceId string, meta *sdk.SREInstance) (ins *TseTcInstance, err error)

func (*TseTcInstance) GetFieldValueByName 

func (ins *TseTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*TseTcInstance) GetFieldValuesByName 

func (ins *TseTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*TseTcInstance) GetInstanceId 

func (ins *TseTcInstance) GetInstanceId() string

func (*TseTcInstance) GetMeta 

func (ins *TseTcInstance) GetMeta() interface{}

func (*TseTcInstance) GetMonitorQueryKey 

func (ins *TseTcInstance) GetMonitorQueryKey() string

type VbcTcInstance 

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

func NewVbcTcInstance 

func NewVbcTcInstance(instanceId string, meta *sdk.CCN) (ins *VbcTcInstance, err error)

func (*VbcTcInstance) GetFieldValueByName 

func (ins *VbcTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*VbcTcInstance) GetFieldValuesByName 

func (ins *VbcTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*VbcTcInstance) GetInstanceId 

func (ins *VbcTcInstance) GetInstanceId() string

func (*VbcTcInstance) GetMeta 

func (ins *VbcTcInstance) GetMeta() interface{}

func (*VbcTcInstance) GetMonitorQueryKey 

func (ins *VbcTcInstance) GetMonitorQueryKey() string

type VbcTcInstanceDRegionRepository 

type VbcTcInstanceDRegionRepository interface {
	GetVbcDRegionInfo(instanceId string) (*sdk.DescribeCcnRegionBandwidthLimitsResponse, error)
}

VbcDRegion

func NewVbcTcInstanceDRegionRepository 

func NewVbcTcInstanceDRegionRepository(cred common.CredentialIface, c *config.TencentConfig, logger log.Logger) (VbcTcInstanceDRegionRepository, error)

func NewVbcTcInstanceDRegionRepositoryCache 

func NewVbcTcInstanceDRegionRepositoryCache(repo VbcTcInstanceDRegionRepository, reloadInterval time.Duration, logger log.Logger) VbcTcInstanceDRegionRepository

type VbcTcInstanceDRegionRepositoryImpl 

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

func (*VbcTcInstanceDRegionRepositoryImpl) GetVbcDRegionInfo 

func (repo *VbcTcInstanceDRegionRepositoryImpl) GetVbcDRegionInfo(instanceId string) (*sdk.DescribeCcnRegionBandwidthLimitsResponse, error)

type VbcTcInstanceRepository 

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

func (*VbcTcInstanceRepository) Get 

func (repo *VbcTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*VbcTcInstanceRepository) GetInstanceKey 

func (repo *VbcTcInstanceRepository) GetInstanceKey() string

func (*VbcTcInstanceRepository) ListByFilters 

func (repo *VbcTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*VbcTcInstanceRepository) ListByIds 

func (repo *VbcTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type VpngwTcInstance 

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

func NewVpngwTcInstance 

func NewVpngwTcInstance(instanceId string, meta *sdk.VpnGateway) (ins *VpngwTcInstance, err error)

func (*VpngwTcInstance) GetFieldValueByName 

func (ins *VpngwTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*VpngwTcInstance) GetFieldValuesByName 

func (ins *VpngwTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*VpngwTcInstance) GetInstanceId 

func (ins *VpngwTcInstance) GetInstanceId() string

func (*VpngwTcInstance) GetMeta 

func (ins *VpngwTcInstance) GetMeta() interface{}

func (*VpngwTcInstance) GetMonitorQueryKey 

func (ins *VpngwTcInstance) GetMonitorQueryKey() string

type VpngwTcInstanceRepository 

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

func (*VpngwTcInstanceRepository) Get 

func (repo *VpngwTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*VpngwTcInstanceRepository) GetInstanceKey 

func (repo *VpngwTcInstanceRepository) GetInstanceKey() string

func (*VpngwTcInstanceRepository) ListByFilters 

func (repo *VpngwTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*VpngwTcInstanceRepository) ListByIds 

func (repo *VpngwTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type VpnxTcInstance 

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

func NewVpnxTcInstance 

func NewVpnxTcInstance(instanceId string, meta *sdk.VpnConnection) (ins *VpnxTcInstance, err error)

func (*VpnxTcInstance) GetFieldValueByName 

func (ins *VpnxTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*VpnxTcInstance) GetFieldValuesByName 

func (ins *VpnxTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*VpnxTcInstance) GetInstanceId 

func (ins *VpnxTcInstance) GetInstanceId() string

func (*VpnxTcInstance) GetMeta 

func (ins *VpnxTcInstance) GetMeta() interface{}

func (*VpnxTcInstance) GetMonitorQueryKey 

func (ins *VpnxTcInstance) GetMonitorQueryKey() string

type VpnxTcInstanceRepository 

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

func (*VpnxTcInstanceRepository) Get 

func (repo *VpnxTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*VpnxTcInstanceRepository) GetInstanceKey 

func (repo *VpnxTcInstanceRepository) GetInstanceKey() string

func (*VpnxTcInstanceRepository) ListByFilters 

func (repo *VpnxTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*VpnxTcInstanceRepository) ListByIds 

func (repo *VpnxTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type WafTcInstance 

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

func NewWafTcInstance 

func NewWafTcInstance(instanceId string, meta *sdk.DomainInfo) (ins *WafTcInstance, err error)

func (*WafTcInstance) GetFieldValueByName 

func (ins *WafTcInstance) GetFieldValueByName(name string) (val string, err error)

func (*WafTcInstance) GetFieldValuesByName 

func (ins *WafTcInstance) GetFieldValuesByName(name string) (val map[string][]string, err error)

func (*WafTcInstance) GetInstanceId 

func (ins *WafTcInstance) GetInstanceId() string

func (*WafTcInstance) GetMeta 

func (ins *WafTcInstance) GetMeta() interface{}

func (*WafTcInstance) GetMonitorQueryKey 

func (ins *WafTcInstance) GetMonitorQueryKey() string

type WafTcInstanceRepository 

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

func (*WafTcInstanceRepository) Get 

func (repo *WafTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*WafTcInstanceRepository) GetInstanceKey 

func (repo *WafTcInstanceRepository) GetInstanceKey() string

func (*WafTcInstanceRepository) ListByFilters 

func (repo *WafTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*WafTcInstanceRepository) ListByIds 

func (repo *WafTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

type ZookeeperTcInstanceInterfaceRepository 

type ZookeeperTcInstanceInterfaceRepository interface {
	GetZookeeperInterfaceInfo(instanceId string) (*sdk.DescribeZookeeperServerInterfacesResponse, error)
}

ZookeeperInterface

func NewTcZookeeperInstanceInterfaceCache 

func NewTcZookeeperInstanceInterfaceCache(repo ZookeeperTcInstanceInterfaceRepository, reloadInterval time.Duration, logger log.Logger) ZookeeperTcInstanceInterfaceRepository

func NewZookeeperTcInstanceInterfaceRepository 

func NewZookeeperTcInstanceInterfaceRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (ZookeeperTcInstanceInterfaceRepository, error)

type ZookeeperTcInstanceInterfaceRepositoryImpl 

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

func (*ZookeeperTcInstanceInterfaceRepositoryImpl) GetZookeeperInterfaceInfo 

func (repo *ZookeeperTcInstanceInterfaceRepositoryImpl) GetZookeeperInterfaceInfo(instanceId string) (*sdk.DescribeZookeeperServerInterfacesResponse, error)

type ZookeeperTcInstancePodRepository 

type ZookeeperTcInstancePodRepository interface {
	GetZookeeperPodInfo(instanceId string) (*sdk.DescribeZookeeperReplicasResponse, error)
}

ZookeeperPod

func NewTcZookeeperInstancePodCache 

func NewTcZookeeperInstancePodCache(repo ZookeeperTcInstancePodRepository, reloadInterval time.Duration, logger log.Logger) ZookeeperTcInstancePodRepository

func NewZookeeperTcInstancePodRepository 

func NewZookeeperTcInstancePodRepository(cred pkgcommon.CredentialIface, c *config.TencentConfig, logger log.Logger) (ZookeeperTcInstancePodRepository, error)

type ZookeeperTcInstancePodRepositoryImpl 

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

func (*ZookeeperTcInstancePodRepositoryImpl) GetZookeeperPodInfo 

func (repo *ZookeeperTcInstancePodRepositoryImpl) GetZookeeperPodInfo(instanceId string) (*sdk.DescribeZookeeperReplicasResponse, error)

type ZookeeperTcInstanceRepository 

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

func (*ZookeeperTcInstanceRepository) Get 

func (repo *ZookeeperTcInstanceRepository) Get(id string) (instance TcInstance, err error)

func (*ZookeeperTcInstanceRepository) GetInstanceKey 

func (repo *ZookeeperTcInstanceRepository) GetInstanceKey() string

func (*ZookeeperTcInstanceRepository) ListByFilters 

func (repo *ZookeeperTcInstanceRepository) ListByFilters(filters map[string]string) (instances []TcInstance, err error)

func (*ZookeeperTcInstanceRepository) ListByIds 

func (repo *ZookeeperTcInstanceRepository) ListByIds(id []string) (instances []TcInstance, err error)

Source Files

View all Source files

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.