billing

Documentation

Index

• type AzureBlobStorageConfig
• type BaseClientConfig
• type ClientsConfig
• type Config
• type HTTPClientConfig
• type MetricsCollector
  • func NewMetricsCollector(ctx context.Context, parentLogger *zap.Logger, conf *Config) (*MetricsCollector, error)
  • func (mc *MetricsCollector) Run(ctx context.Context, logger *zap.Logger, store VMStoreForNode, ...) error
• type PromMetrics
  • func NewPromMetrics() PromMetrics
  • func (m PromMetrics) MustRegister(reg *prometheus.Registry)
• type S3ClientConfig
• type VMNodeIndex
  • func NewVMNodeIndex(node string) *VMNodeIndex
  • func (i *VMNodeIndex) Add(vm *vmapi.VirtualMachine)
  • func (i *VMNodeIndex) Delete(vm *vmapi.VirtualMachine)
  • func (i *VMNodeIndex) List() []*vmapi.VirtualMachine
  • func (i *VMNodeIndex) Update(oldVM, newVM *vmapi.VirtualMachine)
• type VMStoreForNode

Types

type AzureBlobStorageConfig

type AzureBlobStorageConfig struct {
	BaseClientConfig
	billing.AzureBlobStorageClientConfig
}

type BaseClientConfig

type BaseClientConfig struct {
	PushEverySeconds          uint `json:"pushEverySeconds"`
	PushRequestTimeoutSeconds uint `json:"pushRequestTimeoutSeconds"`
	MaxBatchSize              uint `json:"maxBatchSize"`
}

type ClientsConfig

type ClientsConfig struct {
	AzureBlob *AzureBlobStorageConfig `json:"azureBlob"`
	HTTP      *HTTPClientConfig       `json:"http"`
	S3        *S3ClientConfig         `json:"s3"`
}

type Config

type Config struct {
	Clients                ClientsConfig `json:"clients"`
	CPUMetricName          string        `json:"cpuMetricName"`
	ActiveTimeMetricName   string        `json:"activeTimeMetricName"`
	CollectEverySeconds    uint          `json:"collectEverySeconds"`
	AccumulateEverySeconds uint          `json:"accumulateEverySeconds"`
}

type HTTPClientConfig

type HTTPClientConfig struct {
	BaseClientConfig
	URL string `json:"url"`
}

type MetricsCollector

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

func NewMetricsCollector

func NewMetricsCollector(
	ctx context.Context,
	parentLogger *zap.Logger,
	conf *Config,
) (*MetricsCollector, error)

func (*MetricsCollector) Run

func (mc *MetricsCollector) Run(
	ctx context.Context,
	logger *zap.Logger,
	store VMStoreForNode,
	metrics PromMetrics,
) error

type PromMetrics

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

func NewPromMetrics

func NewPromMetrics() PromMetrics

func (PromMetrics) MustRegister

func (m PromMetrics) MustRegister(reg *prometheus.Registry)

type S3ClientConfig

type S3ClientConfig struct {
	BaseClientConfig
	billing.S3ClientConfig
}

type VMNodeIndex

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

VMNodeIndex is a watch.Index that stores all of the VMs for a particular node

We have to implement this ourselves because K8s does not (as of 2023-04-04) support field selectors on CRDs, so we can't have the API server filter out VMs for us.

For more info, see: https://github.com/kubernetes/kubernetes/issues/53459 This comment in particular was particularly instructive: https://github.com/kubernetes/kubernetes/issues/53459#issuecomment-1146200268

func NewVMNodeIndex

func NewVMNodeIndex(node string) *VMNodeIndex

func (*VMNodeIndex) Add

func (i *VMNodeIndex) Add(vm *vmapi.VirtualMachine)

func (*VMNodeIndex) Delete

func (i *VMNodeIndex) Delete(vm *vmapi.VirtualMachine)

func (*VMNodeIndex) List

func (i *VMNodeIndex) List() []*vmapi.VirtualMachine

func (*VMNodeIndex) Update

func (i *VMNodeIndex) Update(oldVM, newVM *vmapi.VirtualMachine)

type VMStoreForNode

type VMStoreForNode = watch.IndexedStore[vmapi.VirtualMachine, *VMNodeIndex]