Documentation
¶
Index ¶
- func ApplyParameters(item parametersv1alpha1.ConfigTemplateItemDetail, baseConfig *corev1.ConfigMap, ...) (*corev1.ConfigMap, error)
- func BuildConfigTemplateAnnotations(object client.Object, synthesizedComp *component.SynthesizedComponent)
- func BuildReloadActionContainer(resourceCtx *render.ResourceCtx, cluster *appsv1.Cluster, ...) error
- func ClassifyComponentParameters(parameters parametersv1alpha1.ComponentParameters, ...) (map[string]map[string]*parametersv1alpha1.ParametersInFile, error)
- func ClassifyParamsFromConfigTemplate(params parametersv1alpha1.ComponentParameters, ...) ([]parametersv1alpha1.ConfigTemplateItemDetail, error)
- func DerefMapValues(m map[string]*parametersv1alpha1.ParametersInFile) map[string]parametersv1alpha1.ParametersInFile
- func DoMerge(baseData map[string]string, ...) (map[string]string, error)
- func HasValidParameterTemplate(pcr *parametersv1alpha1.ParamConfigRenderer) bool
- func MergeComponentParameter(expected *parametersv1alpha1.ComponentParameter, ...) *parametersv1alpha1.ComponentParameter
- func RerenderParametersTemplate(reconcileCtx *render.ReconcileCtx, ...) (*corev1.ConfigMap, error)
- func ResolveComponentTemplate(ctx context.Context, reader client.Reader, cmpd *appsv1.ComponentDefinition) (map[string]*corev1.ConfigMap, error)
- func ResolveParameterTemplate(cmpd appsv1.ComponentDefinitionSpec, ...) []appsv1.ComponentFileTemplate
- func ResolveReloadServerGRPCPort(containers []corev1.Container) (int32, error)
- func ResolveShardingReference(ctx context.Context, reader client.Reader, comp *appsv1.Component) (*appsv1.ClusterSharding, error)
- func UpdateConfigPayload(config *parametersv1alpha1.ComponentParameterSpec, ...) error
- type Fetcher
- type MutateFunc
- type ResourceFetcher
- func (r *ResourceFetcher[T]) Cluster() *T
- func (r *ResourceFetcher[T]) Complete() error
- func (r *ResourceFetcher[T]) ComponentAndComponentDef() *T
- func (r *ResourceFetcher[T]) ComponentParameter() *T
- func (r *ResourceFetcher[T]) ComponentSpec() *T
- func (r *ResourceFetcher[T]) ConfigMap(configSpec string) *T
- func (r *ResourceFetcher[T]) Init(ctx *render.ResourceCtx, object *T) *T
- func (r *ResourceFetcher[T]) Wrap(fn func() error) (ret *T)
- type TemplateMerger
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.ComponentFileTemplate, tpls map[string]*corev1.ConfigMap, pcr *parametersv1alpha1.ParamConfigRenderer) (map[string]map[string]*parametersv1alpha1.ParametersInFile, error)
func ClassifyParamsFromConfigTemplate ¶ added in v1.0.0
func ClassifyParamsFromConfigTemplate(params parametersv1alpha1.ComponentParameters, cmpd *appsv1.ComponentDefinition, paramsDefs []*parametersv1alpha1.ParametersDefinition, tpls map[string]*corev1.ConfigMap, pcr *parametersv1alpha1.ParamConfigRenderer) ([]parametersv1alpha1.ConfigTemplateItemDetail, error)
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 HasValidParameterTemplate ¶ added in v1.0.0
func HasValidParameterTemplate(pcr *parametersv1alpha1.ParamConfigRenderer) bool
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 ResolveParameterTemplate ¶ added in v1.0.0
func ResolveParameterTemplate(cmpd appsv1.ComponentDefinitionSpec, pcr parametersv1alpha1.ParamConfigRendererSpec) []appsv1.ComponentFileTemplate
func ResolveReloadServerGRPCPort ¶ added in v1.0.0
func ResolveShardingReference ¶ added in v0.9.4
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.ComponentFileTemplate, paramsDefs []*parametersv1alpha1.ParametersDefinition, configRender *parametersv1alpha1.ParamConfigRenderer, ) (TemplateMerger, error)
Click to show internal directories.
Click to hide internal directories.