configuration

Documentation

Index

• func BuiltInCustomFunctions(c *configTemplateBuilder, component *component.SynthesizedComponent, ...) *gotemplate.BuiltInObjectsFunc
• func CheckAndUpdateItemStatus(updated *appsv1alpha1.Configuration, item appsv1alpha1.ConfigurationItemDetail, ...)
• func CheckEnvFrom(container *corev1.Container, cmName string) bool
• func DoMerge(baseData map[string]string, patch map[string]appsv1alpha1.ConfigParams, ...) (map[string]string, error)
• func NewConfigReconcileTask(resourceCtx *intctrlutil.ResourceCtx, cluster *appsv1alpha1.Cluster, ...) *configOperator
• func NewCreatePipeline(ctx ReconcileCtx) *pipeline
• func NewReconcilePipeline(ctx ReconcileCtx, item appsv1alpha1.ConfigurationItemDetail, ...) *updatePipeline
• func SyncEnvConfigmap(configSpec appsv1alpha1.ComponentConfigSpec, cmObj *corev1.ConfigMap, ...) error
• func UpdateCMConfigSpecLabels(cm *corev1.ConfigMap, configSpec appsv1alpha1.ComponentConfigSpec)
• type ReconcileCtx
• type ResourceDefinition
• type TemplateMerger
  • func NewTemplateMerger(template appsv1alpha1.ConfigTemplateExtension, ctx context.Context, ...) (TemplateMerger, error)

Functions

func BuiltInCustomFunctions

func BuiltInCustomFunctions(c *configTemplateBuilder, component *component.SynthesizedComponent, localObjs []client.Object) *gotemplate.BuiltInObjectsFunc

BuiltInCustomFunctions builds a map of customized functions for KubeBlocks

func CheckAndUpdateItemStatus

func CheckAndUpdateItemStatus(updated *appsv1alpha1.Configuration, item appsv1alpha1.ConfigurationItemDetail, reversion string)

func CheckEnvFrom

func CheckEnvFrom(container *corev1.Container, cmName string) bool

func DoMerge

func DoMerge(baseData map[string]string, patch map[string]appsv1alpha1.ConfigParams, cc *appsv1alpha1.ConfigConstraint, configSpec appsv1alpha1.ComponentConfigSpec) (map[string]string, error)

func NewConfigReconcileTask

func NewConfigReconcileTask(resourceCtx *intctrlutil.ResourceCtx,
	cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent,
	podSpec *corev1.PodSpec,
	localObjs []client.Object,
) *configOperator

func NewCreatePipeline

func NewCreatePipeline(ctx ReconcileCtx) *pipeline

func NewReconcilePipeline

func NewReconcilePipeline(ctx ReconcileCtx, item appsv1alpha1.ConfigurationItemDetail, itemStatus *appsv1alpha1.ConfigurationItemDetailStatus, configSpec *appsv1alpha1.ComponentConfigSpec) *updatePipeline

func SyncEnvConfigmap

func SyncEnvConfigmap(configSpec appsv1alpha1.ComponentConfigSpec, cmObj *corev1.ConfigMap, cc *appsv1alpha1.ConfigConstraintSpec, cli client.Client, ctx context.Context) error

func UpdateCMConfigSpecLabels

func UpdateCMConfigSpecLabels(cm *corev1.ConfigMap, configSpec appsv1alpha1.ComponentConfigSpec)

Types

type ReconcileCtx

type ReconcileCtx struct {
	*intctrlutil.ResourceCtx

	Cluster   *appsv1alpha1.Cluster
	Component *component.SynthesizedComponent
	PodSpec   *corev1.PodSpec

	Cache []client.Object
}

type ResourceDefinition

type ResourceDefinition struct {
	MemorySize int64 `json:"memorySize,omitempty"`
	CoreNum    int64 `json:"coreNum,omitempty"`
}

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 appsv1alpha1.ConfigTemplateExtension, ctx context.Context, cli client.Client, builder *configTemplateBuilder, configSpec appsv1alpha1.ComponentConfigSpec, ccSpec *appsv1alpha1.ConfigConstraintSpec) (TemplateMerger, error)