service

type ArrayConnectionData struct {
	SystemID                  string `json:"systemID"`
	Username                  string `json:"username"`
	Password                  string `json:"password"`
	Endpoint                  string `json:"endpoint"`
	Insecure                  bool   `json:"insecure,omitempty"`
	IsDefault                 bool   `json:"isDefault,omitempty"`
	SkipCertificateValidation bool   `json:"skipCertificateValidation,omitempty"`
}

type CapacityMetrics struct {
	TotalLogicalCapacity     asyncfloat64.UpDownCounter
	LogicalCapacityAvailable asyncfloat64.UpDownCounter
	LogicalCapacityInUse     asyncfloat64.UpDownCounter
	LogicalProvisioned       asyncfloat64.UpDownCounter
}

type ConfigurationReader struct{}

type Float64UpDownCounterCreater interface {
	AsyncFloat64() asyncfloat64.InstrumentProvider
}

type IDedPoolStatisticGetter struct {
	ID     string
	Getter StoragePoolStatisticsGetter
}

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

type MappedSDC struct {
	SdcID string `json:"sdcId"`
	SdcIP string `json:"sdcIp"`
}

type Metrics struct {
	ReadBW       asyncfloat64.UpDownCounter
	WriteBW      asyncfloat64.UpDownCounter
	ReadIOPS     asyncfloat64.UpDownCounter
	WriteIOPS    asyncfloat64.UpDownCounter
	ReadLatency  asyncfloat64.UpDownCounter
	WriteLatency asyncfloat64.UpDownCounter
}

type MetricsRecorder interface {
	Record(ctx context.Context, meta interface{},
		readBW, writeBW,
		readIOPS, writeIOPS,
		readLatency, writeLatency float64) error
	RecordCapacity(ctx context.Context, meta interface{},
		totalLogicalCapacity, logicalCapacityAvailable, logicalCapacityInUse, logicalProvisioned float64) error
}

type MetricsWrapper struct {
	Meter           Float64UpDownCounterCreater
	Metrics         sync.Map
	Labels          sync.Map
	CapacityMetrics sync.Map
}

type NodeFinder interface {
	GetNodes() ([]corev1.Node, error)
}

type PowerFlexClient interface {
	Authenticate(*sio.ConfigConnect) (sio.Cluster, error)
	GetInstance(string) ([]*types.System, error)
	FindSystem(string, string, string) (*sio.System, error)
	GetStoragePool(href string) ([]*types.StoragePool, error)
}

type PowerFlexService struct {
	MetricsWrapper          MetricsRecorder
	MaxPowerFlexConnections int
	Logger                  *logrus.Logger
}

type PowerFlexSystem interface {
	FindSdc(string, string) (*sio.Sdc, error)
}

type SDCFinder interface {
	GetSDCGuids() ([]string, error)
}

type SDCMeta struct {
	ID      string
	Name    string
	IP      string
	SdcGUID string
}

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

type Service interface {
	GetSDCs(context.Context, PowerFlexClient, SDCFinder) ([]StatisticsGetter, error)
	GetSDCStatistics(context.Context, []corev1.Node, []StatisticsGetter)
	GetVolumes(context.Context, []StatisticsGetter) ([]VolumeStatisticsGetter, error)
	ExportVolumeStatistics(context.Context, []VolumeStatisticsGetter, VolumeFinder)
	GetStorageClasses(ctx context.Context, client PowerFlexClient, storageClassFinder StorageClassFinder) ([]StorageClassMeta, error)
	GetStoragePoolStatistics(ctx context.Context, storageClassMetas []StorageClassMeta)
}

type StatisticsGetter interface {
	GetStatistics() (*types.SdcStatistics, error)
	GetVolume() ([]*types.Volume, error)
	FindVolumes() ([]*sio.Volume, error)
}

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

type StorageClassInfo struct {
	ID              string
	Name            string
	Driver          string
	StorageSystemID string
	StoragePools    []string
}

type StorageClassMeta struct {
	ID              string
	Name            string
	Driver          string
	StorageSystemID string
	StoragePools    map[string]StoragePoolStatisticsGetter
}

type StoragePoolStatisticsGetter interface {
	GetStatistics() (*types.Statistics, error)
}

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

type VolumeMeta struct {
	ID                        string
	Name                      string
	PersistentVolumeName      string
	PersistentVolumeClaimName string
	Namespace                 string
	StorageSystemID           string
	MappedSDCs                []MappedSDC
}

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

type VolumeStatisticsGetter interface {
	GetVolumeStatistics() (*types.VolumeStatistics, error)
}