kube_config_manager

Documentation

Index

• type Checksums
  • func NewChecksums() *Checksums
  • func (c *Checksums) Add(name string, checksum string)
  • func (c *Checksums) Copy(name string, src *Checksums)
  • func (c *Checksums) Dump(moduleName string) map[string]struct{}
  • 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 NewKubeConfigManager(ctx context.Context, bk backend.ConfigHandler, ...) *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

Types

type Checksums

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

Checksums is a non thread-safe storage for KubeConfig sections checksums.

func NewChecksums

func NewChecksums() *Checksums

func (*Checksums) Add

func (c *Checksums) Add(name string, checksum string)

func (*Checksums) Copy

func (c *Checksums) Copy(name string, src *Checksums)

Copy copies all checksums for name from src.

func (*Checksums) Dump

func (c *Checksums) Dump(moduleName string) map[string]struct{}

func (*Checksums) HasChecksum

func (c *Checksums) HasChecksum(name string) bool

HasChecksum returns true if there is at least one checksum for name.

func (*Checksums) HasEqualChecksum

func (c *Checksums) HasEqualChecksum(name string, checksum string) bool

HasEqualChecksum returns true if there is a checksum for name equal to the input checksum.

func (*Checksums) Names

func (c *Checksums) Names() map[string]struct{}

func (*Checksums) Remove

func (c *Checksums) Remove(name string, checksum string)

func (*Checksums) RemoveAll

func (c *Checksums) RemoveAll(name string)

RemoveAll clears all checksums for the name.

func (*Checksums) Set

func (c *Checksums) Set(name string, checksum string)

Set saves only one checksum for the name.

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, logger *log.Logger) *KubeConfigManager

func (*KubeConfigManager) Init

func (kcm *KubeConfigManager) Init() error

func (*KubeConfigManager) IsModuleEnabled

func (kcm *KubeConfigManager) IsModuleEnabled(moduleName string) *bool

func (*KubeConfigManager) KubeConfigEventCh

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

func (kcm *KubeConfigManager) SafeReadConfig(handler func(config *config.KubeConfig))

SafeReadConfig locks currentConfig to safely read from it in external services.

func (*KubeConfigManager) SaveConfigValues

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

func (kcm *KubeConfigManager) UpdateModuleConfig(moduleName string) error

UpdateModuleConfig updates a single module config