Method UnmarshalYAML

modules/overrides/config.go:317–370

(unmarshal func(interface{}) error)

}

func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error {
	// Note: this implementation relies on callers using yaml.UnmarshalStrict. In non-strict mode
	// unmarshal() will not return an error for legacy configuration and we return immediately.

	// Try to unmarshal it normally. Overrides.UnmarshalYAML calls processExtensions for c.Defaults.
	// If the error is an extensionError, the config is in the new format but misconfigured.
	type rawConfig Config
	err := unmarshal((*rawConfig)(c))
	if err == nil {
		c.ConfigType = ConfigTypeNew
		return nil
	}

	// Fail only on extension-specific errors, otherwise fallback to legacy mode
	if isExtensionError(err) || isExtensionKeyError(err) {
		return err
	}

	// Try to unmarshal inline limits
	type legacyConfig struct {
		DefaultOverrides LegacyOverrides `yaml:",inline"`

		PerTenantOverrideConfig string         `yaml:"per_tenant_override_config"`
		PerTenantOverridePeriod model.Duration `yaml:"per_tenant_override_period"`

		UserConfigurableOverridesConfig UserConfigurableOverridesConfig `yaml:"user_configurable_overrides"`

		EnableLegacyOverrides bool `yaml:"enable_legacy_overrides"`
	}
	var legacyCfg legacyConfig
	legacyCfg.DefaultOverrides = c.Defaults.toLegacy()
	legacyCfg.PerTenantOverrideConfig = c.PerTenantOverrideConfig
	legacyCfg.PerTenantOverridePeriod = c.PerTenantOverridePeriod
	legacyCfg.UserConfigurableOverridesConfig = c.UserConfigurableOverridesConfig
	legacyCfg.EnableLegacyOverrides = c.EnableLegacyOverrides

	if legacyErr := unmarshal(&legacyCfg); legacyErr != nil {
		return fmt.Errorf("failed to unmarshal config: %w; also failed in legacy format: %w", err, legacyErr)
	}

	// Ensure legacy extension flat keys are converted to typed instances before toNewLimits.
	// processLegacyExtensions may not be triggered automatically for inline struct fields.
	if err := processLegacyExtensions(&legacyCfg.DefaultOverrides); err != nil {
		return fmt.Errorf("defaults: %w", err)
	}

	c.Defaults = *legacyCfg.DefaultOverrides.toNewLimits()
	c.PerTenantOverrideConfig = legacyCfg.PerTenantOverrideConfig
	c.PerTenantOverridePeriod = legacyCfg.PerTenantOverridePeriod
	c.UserConfigurableOverridesConfig = legacyCfg.UserConfigurableOverridesConfig
	c.EnableLegacyOverrides = legacyCfg.EnableLegacyOverrides
	c.ConfigType = ConfigTypeLegacy
	return nil
}

// RegisterFlagsAndApplyDefaults adds the flags required to config this to the given FlagSet
func (c *Config) RegisterFlagsAndApplyDefaults(f *flag.FlagSet) {