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"
)

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"`
	Metrics               Metrics                `json:"metrics"`
	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