Documentation
¶
Index ¶
- type Checksums
- func (c *Checksums) Add(name string, checksum string)
- func (c *Checksums) Copy(name string, src *Checksums)
- func (c *Checksums) HasChecksum(name string) bool
- func (c *Checksums) HasEqualChecksum(name string, checksum string) bool
- func (c *Checksums) Names() map[string]struct{}
- func (c *Checksums) Remove(name string, checksum string)
- func (c *Checksums) RemoveAll(name string)
- func (c *Checksums) Set(name string, checksum string)
- type KubeConfigManager
- func (kcm *KubeConfigManager) Init() error
- func (kcm *KubeConfigManager) IsModuleEnabled(moduleName string) bool
- func (kcm *KubeConfigManager) KubeConfigEventCh() chan config.KubeConfigEvent
- func (kcm *KubeConfigManager) SafeReadConfig(handler func(config *config.KubeConfig))
- func (kcm *KubeConfigManager) SaveConfigValues(key string, values utils.Values) error
- func (kcm *KubeConfigManager) Start()
- func (kcm *KubeConfigManager) Stop()
- func (kcm *KubeConfigManager) UpdateModuleConfig(moduleName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checksums ¶ added in v1.0.6
type Checksums struct {
// contains filtered or unexported fields
}
Checksums is a non thread-safe storage for KubeConfig sections checksums.
func NewChecksums ¶ added in v1.0.6
func NewChecksums() *Checksums
func (*Checksums) HasChecksum ¶ added in v1.0.6
HasChecksum returns true if there is at least one checksum for name.
func (*Checksums) HasEqualChecksum ¶ added in v1.0.6
HasEqualChecksum returns true if there is a checksum for name equal to the input checksum.
type KubeConfigManager ¶
type KubeConfigManager struct {
// contains filtered or unexported fields
}
KubeConfigManager watches for changes in ConfigMap/addon-operator and provides methods to change its content. It stores values parsed from ConfigMap data. OpenAPI validation of these config values is not a responsibility of this component.
func NewKubeConfigManager ¶
func NewKubeConfigManager(ctx context.Context, bk backend.ConfigHandler, runtimeConfig *runtimeConfig.Config) *KubeConfigManager
func (*KubeConfigManager) Init ¶
func (kcm *KubeConfigManager) Init() error
func (*KubeConfigManager) IsModuleEnabled ¶ added in v1.3.7
func (kcm *KubeConfigManager) IsModuleEnabled(moduleName string) bool
func (*KubeConfigManager) KubeConfigEventCh ¶ added in v1.0.6
func (kcm *KubeConfigManager) KubeConfigEventCh() chan config.KubeConfigEvent
KubeConfigEventCh return a channel that emits new KubeConfig on ConfigMap changes in global section or enabled modules.
func (*KubeConfigManager) SafeReadConfig ¶ added in v1.0.6
func (kcm *KubeConfigManager) SafeReadConfig(handler func(config *config.KubeConfig))
SafeReadConfig locks currentConfig to safely read from it in external services.
func (*KubeConfigManager) SaveConfigValues ¶ added in v1.3.0
func (kcm *KubeConfigManager) SaveConfigValues(key string, values utils.Values) error
SaveConfigValues updates `global` or `module` section in ConfigMap. It uses knownChecksums to prevent KubeConfigChanged event on self-update.
func (*KubeConfigManager) Start ¶
func (kcm *KubeConfigManager) Start()
func (*KubeConfigManager) Stop ¶
func (kcm *KubeConfigManager) Stop()
func (*KubeConfigManager) UpdateModuleConfig ¶ added in v1.3.7
func (kcm *KubeConfigManager) UpdateModuleConfig(moduleName string) error
UpdateModuleConfig updates a single module config
Source Files
Directories