config

Documentation

Index

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

Constants

const AppName = "flinkK8sOperator"

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:"profilerPort" 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"`
	BaseBackoffDuration   config.Duration `json:"baseBackoffDuration" pflag:"\"100ms\",Determines the base backoff for exponential retries."`
	MaxBackoffDuration    config.Duration `json:"maxBackoffDuration" pflag:"\"30s\",Determines the max backoff for exponential retries."`
	MaxErrDuration        config.Duration `json:"maxErrDuration" pflag:"\"5m\",Determines the max time to wait on errors."`
}

func GetConfig

func GetConfig() *Config

func (Config) GetPFlagSet

func (cfg 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
}