config

Aug 8, 2023

Changes in this version

type Data

+ Item *DataItem

+ type DataItem struct

+ Checksum checksum.Checksum

+ Data map[string]TargetConfigData

Jun 13, 2023

Changes in this version

type ConfigurationManager

+ InitializeConfig func(ctx context.Context) error

+ type DummyConfigurationManager struct

+ func (d *DummyConfigurationManager) AddConfigWatcher(_ ...metav1.GroupVersionResource) error

+ func (d *DummyConfigurationManager) InitializeConfig(_ context.Context) error

+ func (d *DummyConfigurationManager) Run(_ context.Context)

type DynamicConfigManager

+ func (c *DynamicConfigManager) InitializeConfig(ctx context.Context) error

Feb 27, 2023

Changes in this version

+ type ConfigManagerCheckpoint interface

+ GetData func(kind string) (reflect.Value, metav1.Time)

+ SetData func(kind string, v reflect.Value, t metav1.Time)

+ func NewCheckpoint(configResponses map[string]TargetConfigData) ConfigManagerCheckpoint

+ type ConfigurationLoader interface

+ LoadConfig func(ctx context.Context, gvr metav1.GroupVersionResource, conf interface{}) error

+ func NewKatalystCustomConfigLoader(clientSet *client.GenericClientSet, ttl time.Duration, nodeName string) ConfigurationLoader

+ type ConfigurationManager interface

+ AddConfigWatcher func(gvrs ...metav1.GroupVersionResource) error

+ Register func(registers ...ConfigurationRegister)

+ Run func(ctx context.Context)

+ UpdateConfig func(ctx context.Context) error

+ func NewDynamicConfigManager(clientSet *client.GenericClientSet, emitter metrics.MetricEmitter, ...) (ConfigurationManager, error)

+ type ConfigurationRegister interface

+ ApplyConfig func(*pkgconfig.DynamicConfiguration)

+ type Data struct

+ Checksum checksum.Checksum

+ Data map[string]TargetConfigData

+ func (d *Data) GetData(kind string) (reflect.Value, metav1.Time)

+ func (d *Data) MarshalCheckpoint() ([]byte, error)

+ func (d *Data) SetData(kind string, val reflect.Value, t metav1.Time)

+ func (d *Data) UnmarshalCheckpoint(blob []byte) error

+ func (d *Data) VerifyChecksum() error

+ type DummyConfigurationRegister struct

+ func (d *DummyConfigurationRegister) ApplyConfig(*pkgconfig.DynamicConfiguration)

+ type DynamicConfigManager struct

+ func (c *DynamicConfigManager) AddConfigWatcher(gvrs ...metav1.GroupVersionResource) error

+ func (c *DynamicConfigManager) Register(register ...ConfigurationRegister)

+ func (c *DynamicConfigManager) Run(ctx context.Context)

+ func (c *DynamicConfigManager) UpdateConfig(ctx context.Context) error

+ type TargetConfigData struct

+ Timestamp metav1.Timestamp

+ Value *dynamic.DynamicConfigCRD