process

Documentation

Index

• Constants
• Variables
• type AWSMachines
• type AzureMachines
• type EventStream
• type Feature
• type GCPMachines
• type Input
  • func (inp Input) Parse(providers *Providers) (*edp.ConsumptionMetrics, error)
• type MachineInfo
• type OpenStackMachines
• type Process
  • func (p *Process) Start()
• type Providers
  • func LoadPublicCloudSpecs(cfg *env.Config) (*Providers, error)
  • func (p Providers) GetFeature(cloudProvider, vmType string) (f *Feature)

Constants

const (
	Azure = "azure"
	AWS   = "aws"
	GCP   = "gcp"
	CCEE  = "sapconvergedcloud"
)

Variables

var (
	ErrLoadingFailed = errors.New("could not load resource")
)

Types

type AWSMachines

type AWSMachines map[string]Feature

type AzureMachines

type AzureMachines map[string]Feature

type EventStream

type EventStream struct {
	KubeConfig string
	Metric     edp.ConsumptionMetrics
}

type Feature

type Feature struct {
	CpuCores int     `json:"cpu_cores"`
	Memory   float64 `json:"memory"`
	Storage  int     `json:"storage,omitempty"`
	MaxNICs  int     `json:"max_nics,omitempty"`
}

type GCPMachines

type GCPMachines map[string]Feature

type Input

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

func (Input) Parse

func (inp Input) Parse(providers *Providers) (*edp.ConsumptionMetrics, error)

type MachineInfo

type MachineInfo map[string]json.RawMessage

type OpenStackMachines

type OpenStackMachines map[string]Feature

type Process

type Process struct {
	KEBClient         *keb.Client
	EDPClient         *edp.Client
	Queue             workqueue.DelayingInterface
	SecretCacheClient v1.CoreV1Interface
	Cache             *cache.Cache
	Providers         *Providers
	ScrapeInterval    time.Duration
	WorkersPoolSize   int
	NodeConfig        skrnode.ConfigInf
	PVCConfig         skrpvc.ConfigInf
	SvcConfig         skrsvc.ConfigInf
	Logger            *zap.SugaredLogger
}

func (*Process) Start

func (p *Process) Start()

Start runs the complete process of collection and sending metrics.

type Providers

type Providers struct {
	Azure     AzureMachines
	AWS       AWSMachines
	GCP       GCPMachines
	OpenStack OpenStackMachines
}

func LoadPublicCloudSpecs

func LoadPublicCloudSpecs(cfg *env.Config) (*Providers, error)

LoadPublicCloudSpecs loads string data to Providers object from an env var

func (Providers) GetFeature

func (p Providers) GetFeature(cloudProvider, vmType string) (f *Feature)