exporter

Documentation

Overview

MIT License Copyright (c) Microsoft Corporation.

MIT License Copyright (c) Microsoft Corporation.

MIT License Copyright (c) Microsoft Corporation.

Index

• Constants
• type Exporter
  • func New(clusterClient clientset.Interface, apiClient *client.APIClient, ...) (*Exporter, error)
  • func (e *Exporter) CreateConfigMapFromEmissionForecast(ctx context.Context, configMapName string, ...) error
  • func (e *Exporter) CreateConfigMapFromProperties(ctx context.Context, configMapName string, data map[string]string, ...) error
  • func (e *Exporter) DeleteConfigMap(ctx context.Context, configMapName string) error
  • func (e *Exporter) GetConfigMap(ctx context.Context, configMapName string) (*corev1.ConfigMap, error)
  • func (e *Exporter) RefreshData(ctx context.Context, configMapName string, region string) error
  • func (e *Exporter) Run(ctx context.Context, configMapName, region string, ...)
  • func (e *Exporter) UseCurrentConfigMap(ctx context.Context, message string, currentConfigMap *corev1.ConfigMap) error

Constants

const (
	ConfigMapLastHeartbeatTime = "lastHeartbeatTime"
	ConfigMapMessage           = "message"
	ConfigMapNumOfRecords      = "numOfRecords"
	ConfigMapForecastDateTime  = "forecastDateTime"
	ConfigMapMinForecast       = "minForecast"
	ConfigMapMaxForecast       = "maxForecast"

	BinaryData = "data"
)

Types

type Exporter

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

func New

func New(clusterClient clientset.Interface, apiClient *client.APIClient, recorder record.EventRecorder) (*Exporter, error)

func (*Exporter) CreateConfigMapFromEmissionForecast

func (e *Exporter) CreateConfigMapFromEmissionForecast(ctx context.Context, configMapName string, emissionForecast []client.EmissionsForecastDto) error

func (*Exporter) CreateConfigMapFromProperties

func (e *Exporter) CreateConfigMapFromProperties(ctx context.Context, configMapName string, data map[string]string, binaryData []byte) error

func (*Exporter) DeleteConfigMap

func (e *Exporter) DeleteConfigMap(ctx context.Context, configMapName string) error

func (*Exporter) GetConfigMap

func (e *Exporter) GetConfigMap(ctx context.Context, configMapName string) (*corev1.ConfigMap, error)

func (*Exporter) RefreshData

func (e *Exporter) RefreshData(ctx context.Context, configMapName string, region string) error

func (*Exporter) Run

func (e *Exporter) Run(ctx context.Context, configMapName, region string, patrolInterval time.Duration, stopChan <-chan struct{})

func (*Exporter) UseCurrentConfigMap

func (e *Exporter) UseCurrentConfigMap(ctx context.Context, message string, currentConfigMap *corev1.ConfigMap) error