config

Documentation

Index

• Constants
• type Config
  • func Get(namespace string, cl client.Reader) (*Config, error)
  • func (cfg *Config) PodName(nodeName string, id string) string
• type Metric
• type Metrics
  • func (m *Metrics) NameFor(name string) string

Constants

const (
	// EnvHostname hostname env variable
	EnvHostname = "HOSTNAME"
	// EnvConfigMapName configmap name env variable
	EnvConfigMapName = "CONFIG_MAP_NAME"
	// PodTemplateName key of the pod template in the configmap
	PodTemplateName = "pod-template.yaml"
	// ConfigFileName key of the config yaml file in the configmap
	ConfigFileName = "config.yaml"

	// LabelVersion version label
	LabelVersion = "version"
	// LabelName name label
	LabelName = "name"
	// LabelPoolSize poolSize label
	LabelPoolSize = "poolSize"
	// LabelReportHistory reportHistory label
	LabelReportHistory = "reportHistory"
)

Types

type Config

type Config struct {
	Name                  string            `json:"name"`
	JobServiceAccount     string            `json:"jobServiceAccount"`
	JobNodeSelector       map[string]string `json:"jobNodeSelector"`
	RunOnUnscheduledNodes bool              `json:"runOnUnscheduledNodes"`
	CronExpression        string            `json:"cronExpression"`
	ReportDirectory       string            `json:"reportDirectory"`
	ReportHistory         int               `json:"reportHistory"`
	PodPoolSize           int               `json:"podPoolSize"`
	RunOnStartup          bool              `json:"runOnStartup"`
	StartupDelay          time.Duration     `json:"startupDelay"`
	Metrics               Metrics           `json:"metrics"`
	// LatestMetricsLabel if true, each result metric is also created with executionID=latest
	LatestMetricsLabel  bool                   `json:"latestMetricsLabel"`
	Custom              map[string]interface{} `json:"custom"`
	CallbackServiceName string                 `json:"callbackServiceName"`
	CallbackServicePort int                    `json:"callbackServicePort"`

	Namespace      string         `json:"-"`
	JobPodTemplate string         `json:"-"`
	Owner          runtime.Object `json:"-"`
}

Config struct

func Get

func Get(namespace string, cl client.Reader) (*Config, error)

Get read the config from the configmap

func (*Config) PodName

func (cfg *Config) PodName(nodeName string, id string) string

PodName get the name of the pod

type Metric

type Metric struct {
	Help   string   `json:"help"`
	Labels []string `json:"labels"`
}

Metric config

type Metrics

type Metrics struct {
	Prefix string            `json:"prefix"`
	Gauges map[string]Metric `json:"gauges"`
}

Metrics config

func (*Metrics) NameFor

func (m *Metrics) NameFor(name string) string

NameFor get the name of a metric