config

Documentation

Index

• Variables
• func SetConfig(c *Config) error
• type Config
  • func GetConfig() *Config
  • func (Config) GetPFlagSet(prefix string) *pflag.FlagSet
• type RuntimeConfig

Variables

var ConfigSection = config.MustRegisterSection(configSectionKey, &Config{})

Functions

func SetConfig

func SetConfig(c *Config) error

Types

type Config

type Config struct {
	ResyncPeriod                  config.Duration `json:"resyncPeriod" pflag:"\"30s\",Determines the resync period for all watchers."`
	LimitNamespace                string          `json:"limitNamespace" pflag:"\"\",Namespaces to watch for by flink operator"`
	MetricsPrefix                 string          `json:"metricsPrefix" pflag:"\"flinkk8soperator\",Prefix for metrics propagated to prometheus"`
	ProfilerPort                  config.Port     `json:"prof-port" pflag:"\"10254\",Profiler port"`
	FlinkIngressURLFormat         string          `json:"ingressUrlFormat"`
	UseProxy                      bool            `json:"useKubectlProxy"`
	ProxyPort                     config.Port     `json:"ProxyPort" pflag:"\"8001\",The port at which flink cluster runs locally"`
	ContainerNameFormat           string          `json:"containerNameFormat"`
	Workers                       int             `json:"workers" pflag:"4,Number of routines to process custom resource"`
	StatemachineStalenessDuration config.Duration `json:"statemachineStalenessDuration" pflag:"\"5m\",Duration for statemachine staleness."`
}

func GetConfig

func GetConfig() *Config

func (Config) GetPFlagSet

func (Config) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in Config and its nested types. The format of the flags is json-name.json-sub-name... etc.

type RuntimeConfig

type RuntimeConfig struct {
	MetricsScope promutils.Scope
}