configuration

package
v1.0.0-beta.35 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2025 License: AGPL-3.0 Imports: 26 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyParameters added in v1.0.0 

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

func BuildConfigTemplateAnnotations added in v0.9.0 

func BuildConfigTemplateAnnotations(object client.Object, synthesizedComp *component.SynthesizedComponent)

BuildConfigTemplateAnnotations builds config template annotations for object

func BuildReloadActionContainer added in v1.0.0 

func BuildReloadActionContainer(resourceCtx *render.ResourceCtx, cluster *appsv1.Cluster, synthesizedComp *component.SynthesizedComponent, cmpd *appsv1.ComponentDefinition) error

BuildReloadActionContainer build the configmgr sidecar container and update it into PodSpec if configuration reload option is on

func ClassifyComponentParameters added in v1.0.0 

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

func ClassifyParamsFromConfigTemplate added in v1.0.0 

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

func DerefMapValues added in v1.0.0 

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 MergeComponentParameter added in v1.0.0 

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

func RerenderParametersTemplate added in v1.0.0 

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

func ResolveComponentTemplate added in v1.0.0 

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

func ResolveReloadServerGRPCPort added in v1.0.0 

func ResolveReloadServerGRPCPort(containers []corev1.Container) (int32, error)

func ResolveShardingReference added in v0.9.4 

func ResolveShardingReference(ctx context.Context, reader client.Reader, comp *appsv1.Component) (*appsv1.ClusterSharding, error)

func UpdateConfigPayload added in v0.9.0 

func UpdateConfigPayload(config *parametersv1alpha1.ComponentParameterSpec, component *appsv1.ComponentSpec, configRender *parametersv1alpha1.ParamConfigRendererSpec, sharding *appsv1.ClusterSharding) error

UpdateConfigPayload updates the configuration payload

Types

type Fetcher added in v0.8.2 

type Fetcher struct {
	ResourceFetcher[Fetcher]
}

func NewResourceFetcher added in v0.8.2 

func NewResourceFetcher(resourceCtx *render.ResourceCtx) *Fetcher

type MutateFunc added in v1.0.0 

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

type ResourceFetcher added in v0.8.2 

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

	ClusterObj      *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 added in v0.8.2 

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

func (*ResourceFetcher[T]) Complete added in v0.8.2 

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

func (*ResourceFetcher[T]) ComponentAndComponentDef added in v0.9.0 

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

func (*ResourceFetcher[T]) ComponentParameter added in v1.0.0 

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

func (*ResourceFetcher[T]) ComponentSpec added in v0.9.0 

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

func (*ResourceFetcher[T]) ConfigMap added in v0.8.2 

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

func (*ResourceFetcher[T]) Init added in v0.8.2 

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

func (*ResourceFetcher[T]) Wrap added in v0.8.2 

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

type TemplateMerger 

type TemplateMerger interface {

	// Merge merges the baseData with the data from the template.
	Merge(baseData map[string]string, updatedData map[string]string) (map[string]string, error)
	// contains filtered or unexported methods
}

func NewTemplateMerger 

func NewTemplateMerger(template parametersv1alpha1.ConfigTemplateExtension,
	templateRender render.TemplateRender,
	configSpec appsv1.ComponentTemplateSpec,
	paramsDefs []*parametersv1alpha1.ParametersDefinition,
	configRender *parametersv1alpha1.ParamConfigRenderer,
) (TemplateMerger, error)

Source Files

View all Source files

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.