utils

func AddConfigMapDigestSuffix ¶

func AddConfigMapDigestSuffix(cm *corev1.ConfigMap) error

func DeleteStatefulSetWithOrphan ¶ added in v1.5.3

func DeleteStatefulSetWithOrphan(
	ctx context.Context,
	setCtl controller.StatefulSetControlInterface,
	tcCtl controller.TidbClusterControlInterface,
	tc *v1alpha1.TidbCluster, sts *apps.StatefulSet) error

func FindConfigMapNameFromTCAnno ¶ added in v1.5.3

func FindConfigMapNameFromTCAnno(ctx context.Context, cmLister corelisters.ConfigMapLister, tc *v1alpha1.TidbCluster, componentType v1alpha1.MemberType, newCm *corev1.ConfigMap) (cmName string, _ error)

FindConfigMapNameFromTCAnno is used to find ConfigMap name from tc.annotations which is saved before deleting STS. If the data of ConfigMap referenced in anno matches the newCm's data return the name in anno otherwise newCm's name.

In some cases, we may need to delete and recreate STS for updating some immutable fields and are expected to keep the name of ConfigMap unchanged to ensure no accidentally restart of pod. For example: Updating storage size, iops or throughput of PVC using by TiKV. Now, the annotation is set by pvc_resizer(not supported yet), pvc_modifier or pvc_replacer, See pkg/manager/utils/statefulset.go:DeleteStatefulSetWithOrphan.

func FindConfigMapVolume ¶

func FindConfigMapVolume(podSpec *corev1.PodSpec, pred func(string) bool) string

FindConfigMapVolume returns the configmap which's name matches the predicate in a PodSpec, empty indicates not found

func SetStatefulSetLastAppliedConfigAnnotation ¶

func SetStatefulSetLastAppliedConfigAnnotation(set *apps.StatefulSet) error

SetStatefulSetLastAppliedConfigAnnotation set last applied config to Statefulset's annotation

func SetUpgradePartition ¶

func SetUpgradePartition(set *apps.StatefulSet, upgradeOrdinal int32)

SetUpgradePartition set statefulSet's rolling update partition

func Sha256Sum ¶

func Sha256Sum(v interface{}) (string, error)

func StatefulSetIsUpgrading ¶

func StatefulSetIsUpgrading(set *apps.StatefulSet) bool

StatefulSetIsUpgrading confirms whether the statefulSet is upgrading phase

func UpdateConfigMapIfNeed ¶

func UpdateConfigMapIfNeed(
	cmLister corelisters.ConfigMapLister,
	configUpdateStrategy v1alpha1.ConfigUpdateStrategy,
	inUseName string,
	desired *corev1.ConfigMap,
) error

UpdateConfigMapIfNeed set the toml field as the old one if they are logically equal.

func UpdateStatefulSet ¶

func UpdateStatefulSet(setCtl controller.StatefulSetControlInterface, object runtime.Object, newSet, oldSet *apps.StatefulSet) error

UpdateStatefulSet is a template function to update the statefulset of components

func UpdateStatefulSetWithPrecheck ¶

func UpdateStatefulSetWithPrecheck(
	deps *controller.Dependencies,
	tc *v1alpha1.TidbCluster,
	reason string,
	newTiDBSet *apps.StatefulSet,
	oldTiDBSet *apps.StatefulSet,
) error