service

type AsyncMetricCreator interface {
	AsyncInt64() asyncint64.InstrumentProvider
	AsyncFloat64() asyncfloat64.InstrumentProvider
}

type ClusterCapacityStatsMetrics struct {
	TotalCapacity     asyncfloat64.UpDownCounter
	RemainingCapacity asyncfloat64.UpDownCounter
	UsedPercentage    asyncfloat64.UpDownCounter
}

type ClusterCapacityStatsMetricsRecord struct {
	ClusterName       string
	TotalCapacity     float64
	RemainingCapacity float64
	UsedPercentage    float64
}

type ClusterMeta struct {
	ClusterName string
}

type ClusterPerformanceStatsMetrics struct {
	CPUPercentage           asyncfloat64.UpDownCounter
	DiskReadOperationsRate  asyncfloat64.UpDownCounter
	DiskWriteOperationsRate asyncfloat64.UpDownCounter
	DiskReadThroughputRate  asyncfloat64.UpDownCounter
	DiskWriteThroughputRate asyncfloat64.UpDownCounter
}

type ClusterPerformanceStatsMetricsRecord struct {
	ClusterName                       string
	CPUPercentage                     float64
	DiskReadOperationsRate            float64
	DiskWriteOperationsRate           float64
	DiskReadThroughputRate            float64
	DiskWriteThroughputRate           float64
	DirectoryTotalHardQuota           float64
	DirectoryTotalHardQuotaPercentage float64
}

type ClusterQuotaMetrics struct {
	TotalHardQuotaGigabytes asyncfloat64.UpDownCounter
	TotalHardQuotaPct       asyncfloat64.UpDownCounter
}

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

type LeaderElector interface {
	InitLeaderElection(string, string) error
	IsLeader() bool
}

type MetricsRecorder interface {
	RecordVolumeQuota(ctx context.Context, meta interface{}, metric *VolumeQuotaMetricsRecord) error
	RecordClusterQuota(ctx context.Context, meta interface{}, metric *ClusterQuotaRecord) error
	RecordClusterCapacityStatsMetrics(ctx context.Context, metric *ClusterCapacityStatsMetricsRecord) error
	RecordClusterPerformanceStatsMetrics(ctx context.Context, metric *ClusterPerformanceStatsMetricsRecord) error
}

type MetricsWrapper struct {
	Meter                          AsyncMetricCreator
	Labels                         sync.Map
	VolumeMetrics                  sync.Map
	ClusterCapacityStatsMetrics    sync.Map
	ClusterPerformanceStatsMetrics sync.Map
	VolumeQuotaMetrics             sync.Map
	ClusterQuotaMetrics            sync.Map
}

type PowerScaleClient interface {
	GetFloatStatistics(ctx context.Context, keys []string) (goisilon.FloatStats, error)
	GetAllQuotas(ctx context.Context) (goisilon.QuotaList, error)
}

type PowerScaleCluster struct {
	Endpoint                 string `yaml:"endpoint"`
	EndpointPort             string `yaml:"endpointPort"`
	ClusterName              string `yaml:"clusterName"`
	Username                 string `yaml:"username"`
	Password                 string `yaml:"password"`
	Insecure                 bool   `yaml:"skipCertificateValidation"`
	IsDefault                bool   `yaml:"isDefault"`
	IsiPath                  string `yaml:"isiPath"`
	IsiVolumePathPermissions string `yaml:"isiVolumePathPermissions"`
	ReplicationCertificateID string `yaml:"replicationCertificateID"`

	Verbose     uint
	IsiAuthType uint8

	MountEndpoint string `yaml:"mountEndpoint,omitempty"`
	Client        *goisilon.Client
	EndpointURL   string
	IP            string
}

type PowerScaleService struct {
	MetricsWrapper           MetricsRecorder
	MaxPowerScaleConnections int
	Logger                   *logrus.Logger
	PowerScaleClients        map[string]PowerScaleClient
	ClientIsiPaths           map[string]string
	DefaultPowerScaleCluster *PowerScaleCluster
	VolumeFinder             VolumeFinder
	StorageClassFinder       StorageClassFinder
}

type Service interface {
	ExportQuotaMetrics(context.Context)
	ExportClusterCapacityMetrics(context.Context)
	ExportClusterPerformanceMetrics(context.Context)
}

type StorageClassFinder interface {
	GetStorageClasses(context.Context) ([]v1.StorageClass, error)
}

type VolumeFinder interface {
	GetPersistentVolumes(context.Context) ([]k8s.VolumeInfo, error)
}

type VolumeMeta struct {
	ID                        string
	PersistentVolumeName      string
	ClusterName               string
	ExportID                  string
	AccessZone                string
	StorageClass              string
	Driver                    string
	IsiPath                   string
	PersistentVolumeClaimName string
	Namespace                 string
}

type VolumeQuotaMetrics struct {
	QuotaSubscribed       asyncfloat64.UpDownCounter
	HardQuotaRemaining    asyncfloat64.UpDownCounter
	QuotaSubscribedPct    asyncfloat64.UpDownCounter
	HardQuotaRemainingPct asyncfloat64.UpDownCounter
}

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