process

Documentation

Index

• Constants
• Variables
• type EventStream
• type Input
  • func (inp Input) Parse(specs *config.PublicCloudSpecs) (*edp.ConsumptionMetrics, error)
• type Process
  • func (p *Process) Start()

Constants

const (
	GiB = 1 << (10 * 3) //nolint:mnd // 1 GiB = 1024^3 bytes
)

Variables

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

Types

type EventStream

type EventStream struct {
	KubeConfig string
	Metric     edp.ConsumptionMetrics
}

type Input

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

func (Input) Parse

func (inp Input) Parse(specs *config.PublicCloudSpecs) (*edp.ConsumptionMetrics, error)

type Process

type Process struct {
	KEBClient         *keb.Client
	EDPClient         *edp.Client
	Queue             workqueue.TypedDelayingInterface[string]
	SecretCacheClient v1.CoreV1Interface
	Cache             *cache.Cache
	PublicCloudSpecs  *config.PublicCloudSpecs
	ScrapeInterval    time.Duration
	WorkersPoolSize   int
	NodeConfig        skrnode.ConfigInf
	PVCConfig         skrpvc.ConfigInf
	SvcConfig         skrsvc.ConfigInf
	RedisConfig       skrredis.ConfigInf
	Logger            *zap.SugaredLogger
}

func (*Process) Start

func (p *Process) Start()

Start runs the complete process of collection and sending metrics.