types

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

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

type MetricsRecorder interface {
	RecordNumericMetrics(ctx context.Context, metric []NumericMetric) error
}

type NumericMetric struct {
	Labels []attribute.KeyValue
	Name   string
	Value  float64
}

type PowerMaxArray struct {
	Endpoint       string
	StorageArrayID string
	Username       string
	Password       string
	Insecure       bool
	IsPrimary      bool
	IsActive       bool
	Client         PowerMaxClient
}

type PowerMaxClient interface {
	Authenticate(ctx context.Context, configConnect *pmax.ConfigConnect) error
	GetStorageGroup(ctx context.Context, symID string, storageGroupID string) (*types.StorageGroup, error)
	GetVolumeByID(ctx context.Context, symID string, volumeID string) (*types.Volume, error)
	GetArrayPerfKeys(ctx context.Context) (*types.ArrayKeysResult, error)
	GetVolumesMetrics(ctx context.Context, symID string, storageGroups string, metricsQuery []string, firstAvailableTime,
		lastAvailableTime int64) (*types.VolumeMetricsIterator, error)
	GetStorageGroupPerfKeys(ctx context.Context, symID string) (*types.StorageGroupKeysResult, error)
	GetStorageGroupMetrics(ctx context.Context, symID string, storageGroupID string, metricsQuery []string,
		firstAvailableTime, lastAvailableTime int64) (*types.StorageGroupMetricsIterator, error)
}

type Service interface {
	GetLogger() *logrus.Logger
	GetPowerMaxClients() map[string][]PowerMaxArray
	GetMetricsRecorder() MetricsRecorder
	GetMaxPowerMaxConnections() int
	GetVolumeFinder() VolumeFinder
	ExportCapacityMetrics(ctx context.Context)
	ExportPerformanceMetrics(ctx context.Context)
}

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

type StorageGroupPerfMetricsRecord struct {
	ArrayID, StorageGroupID                                                                           string
	HostMBReads, HostMBWritten, ReadResponseTime, WriteResponseTime, HostReads, HostWrites, AvgIOSize float64
}

type VolumeCapacityMetricsRecord struct {
	ArrayID, VolumeID, SrpID, StorageGroupID                                                                 string
	StorageClass, Driver, PersistentVolumeName, PersistentVolumeStatus, PersistentVolumeClaimName, Namespace string
	Total, Used, UsedPercent                                                                                 float64
}

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

type VolumePerfMetricsRecord struct {
	ArrayID, VolumeID, StorageGroupID                                                string
	StorageClass, Driver, PersistentVolumeName, PersistentVolumeClaimName, Namespace string
	MBRead, MBWritten, ReadResponseTime, WriteResponseTime, Reads, Writes            float64
}