providerdriver

package
v0.3.11-8 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Register 

func Register(driver ICollectDriver)

Types

type AliyunCollect 

type AliyunCollect struct {
	SCollectByMetricTypeDriver
}

func (*AliyunCollect) CollectAccountMetrics 

func (self *AliyunCollect) CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)

func (*AliyunCollect) GetDelayDuration 

func (self *AliyunCollect) GetDelayDuration() time.Duration

func (*AliyunCollect) GetProvider 

func (self *AliyunCollect) GetProvider() string

func (*AliyunCollect) IsSupportMetrics 

func (self *AliyunCollect) IsSupportMetrics() bool

type ApsaraCollect 

type ApsaraCollect struct {
	SCollectByMetricTypeDriver
}

func (*ApsaraCollect) CollectEipMetrics 

func (self *ApsaraCollect) CollectEipMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticipDetails, start, end time.Time) error

func (*ApsaraCollect) GetProvider 

func (self *ApsaraCollect) GetProvider() string

func (*ApsaraCollect) IsSupportMetrics 

func (self *ApsaraCollect) IsSupportMetrics() bool

type AwsCollect 

type AwsCollect struct {
	SCollectByResourceIdDriver
}

func (*AwsCollect) GetDelayDuration 

func (self *AwsCollect) GetDelayDuration() time.Duration

func (*AwsCollect) GetProvider 

func (self *AwsCollect) GetProvider() string

func (*AwsCollect) IsSupportMetrics 

func (self *AwsCollect) IsSupportMetrics() bool

type AzureCollect 

type AzureCollect struct {
	SCollectByResourceIdDriver
}

func (*AzureCollect) GetProvider 

func (self *AzureCollect) GetProvider() string

func (*AzureCollect) IsSupportMetrics 

func (self *AzureCollect) IsSupportMetrics() bool

type BingoCloudCollect 

type BingoCloudCollect struct {
	SCollectByResourceIdDriver
}

func (*BingoCloudCollect) GetProvider 

func (self *BingoCloudCollect) GetProvider() string

func (*BingoCloudCollect) IsSupportMetrics 

func (self *BingoCloudCollect) IsSupportMetrics() bool

type CephCollect 

type CephCollect struct {
	SBaseCollectDriver
}

func (*CephCollect) GetProvider 

func (self *CephCollect) GetProvider() string

type CloudpodsCollect 

type CloudpodsCollect struct {
	SCollectByMetricTypeDriver
}

func (*CloudpodsCollect) GetDelayDuration 

func (self *CloudpodsCollect) GetDelayDuration() time.Duration

func (*CloudpodsCollect) GetProvider 

func (self *CloudpodsCollect) GetProvider() string

func (*CloudpodsCollect) IsSupportMetrics 

func (collect *CloudpodsCollect) IsSupportMetrics() bool

type CtyunCollect 

type CtyunCollect struct {
	SBaseCollectDriver
}

func (*CtyunCollect) CollectServerMetrics 

func (self *CtyunCollect) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*CtyunCollect) GetProvider 

func (self *CtyunCollect) GetProvider() string

func (*CtyunCollect) IsSupportMetrics 

func (self *CtyunCollect) IsSupportMetrics() bool

type EcloudCollect 

type EcloudCollect struct {
	SBaseCollectDriver
}

func (*EcloudCollect) GetProvider 

func (self *EcloudCollect) GetProvider() string

func (*EcloudCollect) IsSupportMetrics 

func (self *EcloudCollect) IsSupportMetrics() bool

type EsxiCollect 

type EsxiCollect struct {
	SCollectByMetricTypeDriver
}

func (*EsxiCollect) CollectServerMetrics 

func (self *EsxiCollect) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*EsxiCollect) GetDelayDuration 

func (self *EsxiCollect) GetDelayDuration() time.Duration

func (*EsxiCollect) GetProvider 

func (self *EsxiCollect) GetProvider() string

func (*EsxiCollect) IsSupportMetrics 

func (self *EsxiCollect) IsSupportMetrics() bool

type GoogleCollect 

type GoogleCollect struct {
	SCollectByMetricTypeDriver
}

func (*GoogleCollect) GetDelayDuration 

func (self *GoogleCollect) GetDelayDuration() time.Duration

func (*GoogleCollect) GetProvider 

func (self *GoogleCollect) GetProvider() string

func (*GoogleCollect) IsSupportMetrics 

func (self *GoogleCollect) IsSupportMetrics() bool

type H3CCollect 

type H3CCollect struct {
	SBaseCollectDriver
}

func (*H3CCollect) CollectDBInstanceMetrics 

func (self *H3CCollect) CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error

func (*H3CCollect) CollectServerMetrics 

func (self *H3CCollect) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*H3CCollect) GetProvider 

func (self *H3CCollect) GetProvider() string

func (*H3CCollect) IsSupportMetrics 

func (self *H3CCollect) IsSupportMetrics() bool

type HcsCollect 

type HcsCollect struct {
	SCollectByResourceIdDriver
}

func (*HcsCollect) GetProvider 

func (self *HcsCollect) GetProvider() string

func (*HcsCollect) IsSupportMetrics 

func (self *HcsCollect) IsSupportMetrics() bool

type HcsOpCollect 

type HcsOpCollect struct {
	SCollectByResourceIdDriver
}

func (*HcsOpCollect) CollectStorageMetrics 

func (self *HcsOpCollect) CollectStorageMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.StorageDetails, start, end time.Time) error

func (*HcsOpCollect) CollectWireMetrics 

func (self *HcsOpCollect) CollectWireMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.WireDetails, start, end time.Time) error

func (*HcsOpCollect) GetProvider 

func (self *HcsOpCollect) GetProvider() string

func (*HcsOpCollect) IsSupportMetrics 

func (self *HcsOpCollect) IsSupportMetrics() bool

type HuaweiCollect 

type HuaweiCollect struct {
	SCollectByResourceIdDriver
}

func (*HuaweiCollect) CollectAccountMetrics 

func (self *HuaweiCollect) CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)

func (*HuaweiCollect) CollectModelartsPoolMetrics 

func (self *HuaweiCollect) CollectModelartsPoolMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ModelartsPoolDetails, start, end time.Time) error

func (*HuaweiCollect) GetProvider 

func (self *HuaweiCollect) GetProvider() string

func (*HuaweiCollect) IsSupportMetrics 

func (self *HuaweiCollect) IsSupportMetrics() bool

type HuaweiStackCollect 

type HuaweiStackCollect struct {
	SCollectByResourceIdDriver
}

func (*HuaweiStackCollect) CollectModelartsPoolMetrics 

func (self *HuaweiStackCollect) CollectModelartsPoolMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ModelartsPoolDetails, start, end time.Time) error

func (*HuaweiStackCollect) GetProvider 

func (self *HuaweiStackCollect) GetProvider() string

func (*HuaweiStackCollect) IsSupportMetrics 

func (self *HuaweiStackCollect) IsSupportMetrics() bool

type ICollectDriver 

type ICollectDriver interface {
	GetProvider() string
	GetDelayDuration() time.Duration
	IsSupportMetrics() bool
	CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)
	CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error
	CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error
	CollectHostMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.HostDetails, start, end time.Time) error
	CollectStorageMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.StorageDetails, start, end time.Time) error
	CollectRedisMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticcacheDetails, start, end time.Time) error
	CollectLoadbalancerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.LoadbalancerDetails, start, end time.Time) error
	CollectBucketMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.BucketDetails, start, end time.Time) error
	CollectK8sMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.KubeClusterDetails, start, end time.Time) error
	CollectModelartsPoolMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ModelartsPoolDetails, start, end time.Time) error
	CollectWireMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.WireDetails, start, end time.Time) error
	CollectEipMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticipDetails, start, end time.Time) error
}

func GetDriver 

func GetDriver(name string) (ICollectDriver, error)

type InCloudSphereCollect 

type InCloudSphereCollect struct {
	SBaseCollectDriver
}

func (*InCloudSphereCollect) GetProvider 

func (self *InCloudSphereCollect) GetProvider() string

type JdCloudCollect 

type JdCloudCollect struct {
	SBaseCollectDriver
}

func (*JdCloudCollect) GetProvider 

func (self *JdCloudCollect) GetProvider() string

func (*JdCloudCollect) IsSupportMetrics 

func (self *JdCloudCollect) IsSupportMetrics() bool

type NutanixCollect 

type NutanixCollect struct {
	SBaseCollectDriver
}

func (*NutanixCollect) GetProvider 

func (self *NutanixCollect) GetProvider() string

type OpenStackCollect 

type OpenStackCollect struct {
	SBaseCollectDriver
}

func (*OpenStackCollect) GetProvider 

func (self *OpenStackCollect) GetProvider() string

type OracleCollect 

type OracleCollect struct {
	SCollectByResourceIdDriver
}

func (*OracleCollect) GetProvider 

func (self *OracleCollect) GetProvider() string

func (*OracleCollect) IsSupportMetrics 

func (self *OracleCollect) IsSupportMetrics() bool

type QcloudCollect 

type QcloudCollect struct {
	SBaseCollectDriver
}

func (*QcloudCollect) CollectAccountMetrics 

func (self *QcloudCollect) CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)

func (*QcloudCollect) CollectDBInstanceMetrics 

func (self *QcloudCollect) CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error

func (*QcloudCollect) CollectK8sMetrics 

func (self *QcloudCollect) CollectK8sMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.KubeClusterDetails, start, end time.Time) error

func (*QcloudCollect) CollectRedisMetrics 

func (self *QcloudCollect) CollectRedisMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticcacheDetails, start, end time.Time) error

func (*QcloudCollect) CollectServerMetrics 

func (self *QcloudCollect) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*QcloudCollect) GetProvider 

func (self *QcloudCollect) GetProvider() string

func (*QcloudCollect) IsSupportMetrics 

func (self *QcloudCollect) IsSupportMetrics() bool

type RemoteFileCollect 

type RemoteFileCollect struct {
	SCollectByMetricTypeDriver
}

func (*RemoteFileCollect) GetDelayDuration 

func (self *RemoteFileCollect) GetDelayDuration() time.Duration

func (*RemoteFileCollect) GetProvider 

func (self *RemoteFileCollect) GetProvider() string

func (*RemoteFileCollect) IsSupportMetrics 

func (self *RemoteFileCollect) IsSupportMetrics() bool

type S3Collect 

type S3Collect struct {
	SBaseCollectDriver
}

func (*S3Collect) GetProvider 

func (self *S3Collect) GetProvider() string

type SBaseCollectDriver 

type SBaseCollectDriver struct {
}

func (*SBaseCollectDriver) CollectAccountMetrics 

func (self *SBaseCollectDriver) CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)

func (*SBaseCollectDriver) CollectBucketMetrics 

func (self *SBaseCollectDriver) CollectBucketMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.BucketDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectDBInstanceMetrics 

func (self *SBaseCollectDriver) CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectEipMetrics 

func (self *SBaseCollectDriver) CollectEipMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticipDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectHostMetrics 

func (self *SBaseCollectDriver) CollectHostMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.HostDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectK8sMetrics 

func (self *SBaseCollectDriver) CollectK8sMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.KubeClusterDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectLoadbalancerMetrics 

func (self *SBaseCollectDriver) CollectLoadbalancerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.LoadbalancerDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectModelartsPoolMetrics 

func (self *SBaseCollectDriver) CollectModelartsPoolMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ModelartsPoolDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectRedisMetrics 

func (self *SBaseCollectDriver) CollectRedisMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticcacheDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectServerMetrics 

func (self *SBaseCollectDriver) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectStorageMetrics 

func (self *SBaseCollectDriver) CollectStorageMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.StorageDetails, start, end time.Time) error

func (*SBaseCollectDriver) CollectWireMetrics 

func (self *SBaseCollectDriver) CollectWireMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.WireDetails, start, end time.Time) error

func (*SBaseCollectDriver) GetDelayDuration 

func (self *SBaseCollectDriver) GetDelayDuration() time.Duration

func (*SBaseCollectDriver) IsSupportMetrics 

func (self *SBaseCollectDriver) IsSupportMetrics() bool

type SCollectByMetricTypeDriver 

type SCollectByMetricTypeDriver struct {
	SBaseCollectDriver
}

func (*SCollectByMetricTypeDriver) CollectBucketMetrics 

func (self *SCollectByMetricTypeDriver) CollectBucketMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.BucketDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectDBInstanceMetrics 

func (self *SCollectByMetricTypeDriver) CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectHostMetrics 

func (self *SCollectByMetricTypeDriver) CollectHostMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.HostDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectK8sMetrics 

func (self *SCollectByMetricTypeDriver) CollectK8sMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.KubeClusterDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectLoadbalancerMetrics 

func (driver *SCollectByMetricTypeDriver) CollectLoadbalancerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.LoadbalancerDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectRedisMetrics 

func (self *SCollectByMetricTypeDriver) CollectRedisMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticcacheDetails, start, end time.Time) error

func (*SCollectByMetricTypeDriver) CollectServerMetrics 

func (self *SCollectByMetricTypeDriver) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

type SCollectByResourceIdDriver 

type SCollectByResourceIdDriver struct {
	SBaseCollectDriver
}

func (*SCollectByResourceIdDriver) CollectBucketMetrics 

func (self *SCollectByResourceIdDriver) CollectBucketMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.BucketDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectDBInstanceMetrics 

func (self *SCollectByResourceIdDriver) CollectDBInstanceMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.DBInstanceDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectHostMetrics 

func (self *SCollectByResourceIdDriver) CollectHostMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.HostDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectK8sMetrics 

func (self *SCollectByResourceIdDriver) CollectK8sMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.KubeClusterDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectLoadbalancerMetrics 

func (self *SCollectByResourceIdDriver) CollectLoadbalancerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.LoadbalancerDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectRedisMetrics 

func (self *SCollectByResourceIdDriver) CollectRedisMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ElasticcacheDetails, start, end time.Time) error

func (*SCollectByResourceIdDriver) CollectServerMetrics 

func (self *SCollectByResourceIdDriver) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

type UcloudCollect 

type UcloudCollect struct {
	SBaseCollectDriver
}

func (*UcloudCollect) GetProvider 

func (self *UcloudCollect) GetProvider() string

type VolcEngineCollect 

type VolcEngineCollect struct {
	SBaseCollectDriver
}

func (*VolcEngineCollect) CollectAccountMetrics 

func (self *VolcEngineCollect) CollectAccountMetrics(ctx context.Context, account api.CloudaccountDetail) (influxdb.SMetricData, error)

func (*VolcEngineCollect) CollectServerMetrics 

func (self *VolcEngineCollect) CollectServerMetrics(ctx context.Context, manager api.CloudproviderDetails, provider cloudprovider.ICloudProvider, res map[string]api.ServerDetails, start, end time.Time) error

func (*VolcEngineCollect) GetProvider 

func (self *VolcEngineCollect) GetProvider() string

func (*VolcEngineCollect) IsSupportMetrics 

func (self *VolcEngineCollect) IsSupportMetrics() bool

type XskyCollect 

type XskyCollect struct {
	SBaseCollectDriver
}

func (*XskyCollect) GetProvider 

func (self *XskyCollect) GetProvider() string

type ZStackCollect 

type ZStackCollect struct {
	SCollectByMetricTypeDriver
}

func (*ZStackCollect) GetProvider 

func (self *ZStackCollect) GetProvider() string

func (*ZStackCollect) IsSupportMetrics 

func (self *ZStackCollect) IsSupportMetrics() bool

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.