config

Documentation

Index

• func CloneWithSerialization[T NumaflowControllerDefinitionConfig | GlobalConfig](orig *T) (*T, error)
• type ConfigManager
  • func GetConfigManagerInstance() *ConfigManager
  • func (cm *ConfigManager) GetConfig() (GlobalConfig, error)
  • func (*ConfigManager) GetControllerDefinitionsMgr() *ControllerDefinitionsManager
  • func (cm *ConfigManager) LoadAllConfigs(onErrorReloading func(error), options ...Option) error
  • func (cm *ConfigManager) RegisterCallback(f func(config GlobalConfig))
• type ControllerDefinitionsManager
  • func (cm *ControllerDefinitionsManager) GetControllerDefinitionsConfig() map[string]string
  • func (cm *ControllerDefinitionsManager) RemoveControllerDefinitionConfig(config NumaflowControllerDefinitionConfig)
  • func (cm *ControllerDefinitionsManager) UpdateControllerDefinitionConfig(config NumaflowControllerDefinitionConfig)
• type GlobalConfig
• type NumaflowControllerDefinitionConfig
• type Option
  • func WithConfigFileName(configFileName string) Option
  • func WithConfigsPath(configsPath string) Option

Functions

func CloneWithSerialization

func CloneWithSerialization[T NumaflowControllerDefinitionConfig | GlobalConfig](orig *T) (*T, error)

Types

type ConfigManager

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

func GetConfigManagerInstance

func GetConfigManagerInstance() *ConfigManager

GetConfigManagerInstance returns a singleton config manager throughout the application

func (*ConfigManager) GetConfig

func (cm *ConfigManager) GetConfig() (GlobalConfig, error)

func (*ConfigManager) GetControllerDefinitionsMgr

func (*ConfigManager) GetControllerDefinitionsMgr() *ControllerDefinitionsManager

func (*ConfigManager) LoadAllConfigs

func (cm *ConfigManager) LoadAllConfigs(
	onErrorReloading func(error),
	options ...Option,
) error

func (*ConfigManager) RegisterCallback

func (cm *ConfigManager) RegisterCallback(f func(config GlobalConfig))

RegisterCallback adds a callback to be called when the config changes

type ControllerDefinitionsManager

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

func (*ControllerDefinitionsManager) GetControllerDefinitionsConfig

func (cm *ControllerDefinitionsManager) GetControllerDefinitionsConfig() map[string]string

func (*ControllerDefinitionsManager) RemoveControllerDefinitionConfig

func (cm *ControllerDefinitionsManager) RemoveControllerDefinitionConfig(config NumaflowControllerDefinitionConfig)

func (*ControllerDefinitionsManager) UpdateControllerDefinitionConfig

func (cm *ControllerDefinitionsManager) UpdateControllerDefinitionConfig(config NumaflowControllerDefinitionConfig)

type GlobalConfig

type GlobalConfig struct {
	LogLevel          int    `json:"logLevel" mapstructure:"logLevel"`
	IncludedResources string `json:"includedResources" mapstructure:"includedResources"`
}

GlobalConfig is the configuration for the controllers, it is supposed to be populated from the configmap attached to the controller manager.

type NumaflowControllerDefinitionConfig

type NumaflowControllerDefinitionConfig struct {
	ControllerDefinitions []apiv1.ControllerDefinitions `json:"controllerDefinitions" yaml:"controllerDefinitions"`
}

type Option

type Option func(*options)

func WithConfigFileName

func WithConfigFileName(configFileName string) Option

func WithConfigsPath

func WithConfigsPath(configsPath string) Option