Function NewTopicConfigEntry

backend/pkg/console/topic_config.go:51–100

NewTopicConfigEntry creates a new instance for a TopicConfigEntry. The function is in charge of computing additional properties based on existing other properties, as well as enriching the giving describe configs response with properties from our own config extensions.

(
	cfg kmsg.DescribeConfigsResponseResourceConfig,
	extension ConfigEntryExtension,
)

// properties, as well as enriching the giving describe configs response with
// properties from our own config extensions.
func NewTopicConfigEntry(
	cfg kmsg.DescribeConfigsResponseResourceConfig,
	extension ConfigEntryExtension,
) *TopicConfigEntry {
	isDefaultValue := false
	innerEntries := make([]TopicConfigSynonym, len(cfg.ConfigSynonyms))
	for j, innerCfg := range cfg.ConfigSynonyms {
		innerEntries[j] = TopicConfigSynonym{
			Name:   innerCfg.Name,
			Value:  innerCfg.Value,
			Source: innerCfg.Source.String(),
		}
		if innerCfg.Source == kmsg.ConfigSourceDefaultConfig {
			isDefaultValue = derefString(cfg.Value) == derefString(innerCfg.Value)
		}
	}

	var isExplicitlySet bool
	if cfg.Source == kmsg.ConfigSourceUnknown {
		// Kafka <v1.1 uses the IsDefault property. Since then, it's been replaced by ConfigSource and defaults
		// to false. Thus, we only consider it if cfg.Source is not set / unknown.
		isExplicitlySet = !cfg.IsDefault
	} else {
		isExplicitlySet = cfg.Source == kmsg.ConfigSourceDynamicTopicConfig
	}

	documentation := cfg.Documentation
	if documentation == nil {
		documentation = extension.Documentation
	}
	configType := cfg.ConfigType
	if configType == kmsg.ConfigTypeUnknown {
		configType = extension.Type
	}
	extension.FrontendFormat = FrontendFormatFromValueType(configType, extension.FrontendFormat)

	return &TopicConfigEntry{
		Name:                 cfg.Name,
		Value:                cfg.Value,
		Source:               cfg.Source.String(),
		Type:                 configType.String(),
		IsExplicitlySet:      isExplicitlySet,
		IsDefaultValue:       isDefaultValue,
		IsSensitive:          cfg.IsSensitive,
		IsReadOnly:           cfg.ReadOnly,
		Documentation:        documentation,
		Synonyms:             innerEntries,
		ConfigEntryExtension: extension,
	}
}

// TopicConfigSynonym is a synonym for a topic configuration.
type TopicConfigSynonym struct {