parameters

package
v1.2.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2026 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyParameters 

func ApplyParameters(item parametersv1alpha1.ConfigTemplateItemDetail,
	baseConfig *corev1.ConfigMap,
	configs []parametersv1alpha1.ComponentConfigDescription,
	paramsDefs []*parametersv1alpha1.ParametersDefinition) (*corev1.ConfigMap, error)

func BuildConfigDescriptionsFromParametersDefs 

func BuildConfigDescriptionsFromParametersDefs(paramsDefs []*parametersv1alpha1.ParametersDefinition) []parametersv1alpha1.ComponentConfigDescription

func ClassifyComponentParameters 

func ClassifyComponentParameters(parameters parametersv1alpha1.ComponentParameters,
	parametersDefs []*parametersv1alpha1.ParametersDefinition,
	templates []appsv1.ComponentFileTemplate,
	tpls map[string]*corev1.ConfigMap,
	configs []parametersv1alpha1.ComponentConfigDescription) (map[string]map[string]*parametersv1alpha1.ParametersInFile, error)

func ClassifyParamsFromConfigTemplate 

func ClassifyParamsFromConfigTemplate(params parametersv1alpha1.ComponentParameters,
	cmpd *appsv1.ComponentDefinition,
	paramsDefs []*parametersv1alpha1.ParametersDefinition,
	tpls map[string]*corev1.ConfigMap,
	configs []parametersv1alpha1.ComponentConfigDescription) ([]parametersv1alpha1.ConfigTemplateItemDetail, error)

func DecodeParameterOverlay 

func DecodeParameterOverlay(parameters map[string]*string) map[string]*string

func DerefMapValues 

func DerefMapValues(m map[string]*parametersv1alpha1.ParametersInFile) map[string]parametersv1alpha1.ParametersInFile

func DoMerge 

func DoMerge(baseData map[string]string,
	patch map[string]parametersv1alpha1.ParametersInFile,
	paramsDefs []*parametersv1alpha1.ParametersDefinition,
	configDescs []parametersv1alpha1.ComponentConfigDescription) (map[string]string, error)

func EncodeParameterOverlay 

func EncodeParameterOverlay(parameters map[string]*string) map[string]*string

func FindParameterSchema 

func FindParameterSchema[T any](parametersMap map[string]T, paramKey string) (T, bool)

func GetComponentConfigDescription 

func GetComponentConfigDescription(configs []parametersv1alpha1.ComponentConfigDescription, name string) *parametersv1alpha1.ComponentConfigDescription

func GetComponentConfigDescriptions 

func GetComponentConfigDescriptions(configs []parametersv1alpha1.ComponentConfigDescription, tpl string) []parametersv1alpha1.ComponentConfigDescription

func GetConfigTemplateItem 

func GetConfigTemplateItem(parameterSpec *parametersv1alpha1.ComponentParameterSpec, name string) *parametersv1alpha1.ConfigTemplateItemDetail

func GetItemStatus 

func GetItemStatus(status *parametersv1alpha1.ComponentParameterStatus, name string) *parametersv1alpha1.ConfigTemplateItemDetailStatus

func GetUpdatedParametersReconciledPhase 

func GetUpdatedParametersReconciledPhase(configMap *corev1.ConfigMap,
	item parametersv1alpha1.ConfigTemplateItemDetail,
	status *parametersv1alpha1.ConfigTemplateItemDetailStatus,
	compGeneration int64) parametersv1alpha1.ParameterPhase

GetUpdatedParametersReconciledPhase gets the configuration phase

func HasValidParameterTemplate 

func HasValidParameterTemplate(configs []parametersv1alpha1.ComponentConfigDescription) bool

func IsApplyUpdatedParameters 

func IsApplyUpdatedParameters(configMap *corev1.ConfigMap, item parametersv1alpha1.ConfigTemplateItemDetail, compGeneration int64) bool

IsApplyUpdatedParameters checks if the configuration is changed

func IsFailedPhase 

func IsFailedPhase(phase parametersv1alpha1.ParameterPhase) bool

func IsParameterFinished 

func IsParameterFinished(phase parametersv1alpha1.ParameterPhase) bool

func LegacyConfigManagerRequiredForCluster 

func LegacyConfigManagerRequiredForCluster(cluster *appsv1.Cluster) (bool, error)

func LegacyConfigManagerRequiredForParamsDefs 

func LegacyConfigManagerRequiredForParamsDefs(paramsDefs []*parametersv1alpha1.ParametersDefinition) bool

func MergeAndValidateConfigs 

func MergeAndValidateConfigs(baseConfigs map[string]string,
	updatedParams []core.ParamPairs,
	paramsDefs []*parametersv1alpha1.ParametersDefinition,
	configDescs []parametersv1alpha1.ComponentConfigDescription) (map[string]string, error)

MergeAndValidateConfigs merges and validates configuration files

func MergeComponentParameter 

func MergeComponentParameter(expected *parametersv1alpha1.ComponentParameter, existing *parametersv1alpha1.ComponentParameter, mutate MutateFunc) *parametersv1alpha1.ComponentParameter

func NeedDynamicReloadAction 

func NeedDynamicReloadAction(pd *parametersv1alpha1.ParametersDefinitionSpec) bool

func NewValueManager 

func NewValueManager(paramsDefs []*parametersv1alpha1.ParametersDefinition, configs []parametersv1alpha1.ComponentConfigDescription) *valueManager

func ParametersDefinitionTerminalPhases 

func ParametersDefinitionTerminalPhases(status parametersv1alpha1.ParametersDefinitionStatus, generation int64) bool

func ReloadStaticParameters 

func ReloadStaticParameters(pd *parametersv1alpha1.ParametersDefinitionSpec) bool

func RerenderParametersTemplate 

func RerenderParametersTemplate(reconcileCtx *render.ReconcileCtx,
	item parametersv1alpha1.ConfigTemplateItemDetail,
	configs []parametersv1alpha1.ComponentConfigDescription,
	parametersDefs []*parametersv1alpha1.ParametersDefinition) (*corev1.ConfigMap, error)

func ResolveCmpdParametersDefs 

func ResolveCmpdParametersDefs(ctx context.Context, reader client.Reader, cmpd *appsv1.ComponentDefinition) ([]parametersv1alpha1.ComponentConfigDescription, []*parametersv1alpha1.ParametersDefinition, error)

func ResolveComponentConfigRender 

func ResolveComponentConfigRender(ctx context.Context, reader client.Reader, cmpd *appsv1.ComponentDefinition) (*parametersv1alpha1.ParamConfigRenderer, error)

func ResolveComponentTemplate 

func ResolveComponentTemplate(ctx context.Context, reader client.Reader, cmpd *appsv1.ComponentDefinition) (map[string]*corev1.ConfigMap, error)

func ResolveConfigParameterSchema 

func ResolveConfigParameterSchema(paramDef *parametersv1alpha1.ParametersDefinition, configTemplate *appsv1.ComponentFileTemplate) map[string]*ParameterMeta

func ResolveParameterTemplate 

func ResolveParameterTemplate(cmpd appsv1.ComponentDefinitionSpec, configs []parametersv1alpha1.ComponentConfigDescription) []appsv1.ComponentFileTemplate

Types

type Fetcher 

type Fetcher struct {
	ResourceFetcher[Fetcher]
}

func NewResourceFetcher 

func NewResourceFetcher(resourceCtx *render.ResourceCtx) *Fetcher

type LegacyConfigManagerRequirementState 

type LegacyConfigManagerRequirementState string
const (
	LegacyConfigManagerRequirementUnknown LegacyConfigManagerRequirementState = "unknown"
	LegacyConfigManagerRequirementKeep    LegacyConfigManagerRequirementState = "keep"
	LegacyConfigManagerRequirementCleanup LegacyConfigManagerRequirementState = "cleanup"
)

func LegacyConfigManagerRequirementStateForCluster 

func LegacyConfigManagerRequirementStateForCluster(cluster *appsv1.Cluster) (LegacyConfigManagerRequirementState, error)

type MutateFunc 

type MutateFunc func(dest, expected *parametersv1alpha1.ConfigTemplateItemDetail)

type ParameterMeta 

type ParameterMeta struct {
	FileName           string
	ConfigTemplateName string
}

type ResourceFetcher 

type ResourceFetcher[T any] struct {
	*render.ResourceCtx

	ClusterObj, ClusterObjCopy *appsv1.Cluster
	ComponentObj               *appsv1.Component
	ComponentDefObj            *appsv1.ComponentDefinition
	ClusterComObj              *appsv1.ClusterComponentSpec

	ConfigMapObj          *corev1.ConfigMap
	ComponentParameterObj *parametersv1alpha1.ComponentParameter
	// contains filtered or unexported fields
}

func (*ResourceFetcher[T]) Cluster 

func (r *ResourceFetcher[T]) Cluster() *T

func (*ResourceFetcher[T]) Complete 

func (r *ResourceFetcher[T]) Complete() error

func (*ResourceFetcher[T]) ComponentAndComponentDef 

func (r *ResourceFetcher[T]) ComponentAndComponentDef() *T

func (*ResourceFetcher[T]) ComponentParameter 

func (r *ResourceFetcher[T]) ComponentParameter() *T

func (*ResourceFetcher[T]) ComponentSpec 

func (r *ResourceFetcher[T]) ComponentSpec() *T

func (*ResourceFetcher[T]) ConfigMap 

func (r *ResourceFetcher[T]) ConfigMap(configSpec string) *T

func (*ResourceFetcher[T]) Init 

func (r *ResourceFetcher[T]) Init(ctx *render.ResourceCtx, object *T) *T

func (*ResourceFetcher[T]) Wrap 

func (r *ResourceFetcher[T]) Wrap(fn func() error) (ret *T)

type Result 

type Result struct {
	Phase      parametersv1alpha1.ParameterPhase `json:"phase"`
	Revision   string                            `json:"revision"`
	Policy     string                            `json:"policy"`
	ExecResult string                            `json:"execResult"`

	SucceedCount  int32 `json:"succeedCount"`
	ExpectedCount int32 `json:"expectedCount"`

	Retry   bool   `json:"retry"`
	Failed  bool   `json:"failed"`
	Message string `json:"message"`
}

type TemplateMerger 

type TemplateMerger interface {
	// contains filtered or unexported methods
}

func NewTemplateMerger 

func NewTemplateMerger(template parametersv1alpha1.ConfigTemplateExtension,
	templateRender render.TemplateRender,
	configSpec appsv1.ComponentFileTemplate,
	paramsDefs []*parametersv1alpha1.ParametersDefinition,
	configs []parametersv1alpha1.ComponentConfigDescription,
) (TemplateMerger, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.