config

Documentation

Index

• type Config
  • func NewConfig(client client.Client, namespace, configMapName string) *Config
  • func NewConfigWithCache(client client.Client, namespace, configMapName string, ...) *Config
  • func (config *Config) GetBoolParam(key string, defaultValue bool) bool
  • func (config *Config) GetDefaultNodeResourceLimit() float64
  • func (config *Config) GetDefaultScheduler() []string
  • func (config *Config) GetDeleteGracePeriod() time.Duration
  • func (config *Config) GetDurationParam(key string, defaultValue time.Duration) time.Duration
  • func (config *Config) GetFloatParam(key string, defaultValue float64) float64
  • func (config *Config) GetInitialResourceBufferSize() int
  • func (config *Config) GetIntParam(key string, defaultValue int) int
  • func (config *Config) GetParameterMap() (map[string]string, error)
  • func (config *Config) GetPodEnvVars() map[string]string
  • func (config *Config) GetResourceBufferIncrementFactor() float64
  • func (config *Config) GetResourceLimitAnnotation() string
  • func (config *Config) GetStandaloneSourceLabel() string
  • func (config *Config) GetStringMapParam(key string, defaultValue map[string]string) map[string]string
  • func (config *Config) GetStringParam(key string, defaultValue string) string
  • func (config *Config) GetStringSliceParam(key string, defaultValue []string) []string
  • func (config *Config) GetValidationHeartbeat() time.Duration
  • func (config *Config) GetValidationPeriod() time.Duration
  • func (config *Config) Validate() error

Types

type Config

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

func NewConfig

func NewConfig(client client.Client, namespace, configMapName string) *Config

func NewConfigWithCache

func NewConfigWithCache(client client.Client, namespace, configMapName string, invalidatePeriod time.Duration) *Config

func (*Config) GetBoolParam

func (config *Config) GetBoolParam(key string, defaultValue bool) bool

func (*Config) GetDefaultNodeResourceLimit

func (config *Config) GetDefaultNodeResourceLimit() float64

func (*Config) GetDefaultScheduler

func (config *Config) GetDefaultScheduler() []string

func (*Config) GetDeleteGracePeriod

func (config *Config) GetDeleteGracePeriod() time.Duration

func (*Config) GetDurationParam

func (config *Config) GetDurationParam(key string, defaultValue time.Duration) time.Duration

func (*Config) GetFloatParam

func (config *Config) GetFloatParam(key string, defaultValue float64) float64

func (*Config) GetInitialResourceBufferSize

func (config *Config) GetInitialResourceBufferSize() int

func (*Config) GetIntParam

func (config *Config) GetIntParam(key string, defaultValue int) int

func (*Config) GetParameterMap

func (config *Config) GetParameterMap() (map[string]string, error)

func (*Config) GetPodEnvVars

func (config *Config) GetPodEnvVars() map[string]string

func (*Config) GetResourceBufferIncrementFactor

func (config *Config) GetResourceBufferIncrementFactor() float64

func (*Config) GetResourceLimitAnnotation

func (config *Config) GetResourceLimitAnnotation() string

func (*Config) GetStandaloneSourceLabel

func (config *Config) GetStandaloneSourceLabel() string

func (*Config) GetStringMapParam

func (config *Config) GetStringMapParam(key string, defaultValue map[string]string) map[string]string

func (*Config) GetStringParam

func (config *Config) GetStringParam(key string, defaultValue string) string

func (*Config) GetStringSliceParam

func (config *Config) GetStringSliceParam(key string, defaultValue []string) []string

func (*Config) GetValidationHeartbeat

func (config *Config) GetValidationHeartbeat() time.Duration

func (*Config) GetValidationPeriod

func (config *Config) GetValidationPeriod() time.Duration

func (*Config) Validate

func (config *Config) Validate() error