util

Documentation

Index

• Variables
• func AppendEnv(a []corev1.EnvVar, b []corev1.EnvVar) []corev1.EnvVar
• func AppendEnvIfPresent(envs []corev1.EnvVar, name string) []corev1.EnvVar
• func AppendOverwriteEnv(a []corev1.EnvVar, b []corev1.EnvVar) []corev1.EnvVar
• func BuildStorageVolumeAndVolumeMount(storageVolumes []v1alpha1.StorageVolume, defaultStorageClassName *string, ...) ([]corev1.VolumeMount, []corev1.PersistentVolumeClaim)
• func ClusterClientTLSSecretName(tcName string) string
• func ClusterTLSSecretName(tcName, component string) string
• func Encode(obj interface{}) (string, error)
• func GetAutoScalingOutSlots(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) sets.Int32
• func GetCrdKindFromKindName(kindName string) (v1alpha1.CrdKind, error)
• func GetDeleteSlotsNumber(annotations map[string]string) (int32, error)
• func GetOrdinalFromPodName(podName string) (int32, error)
• func GetPodName(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType, ordinal int32) string
• func GetPodOrdinals(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) (sets.Int32, error)
• func GetStatefulSetName(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) string
• func IsOwnedByTidbCluster(obj metav1.Object) (bool, *metav1.OwnerReference)
• func IsPodOrdinalNotExceedReplicas(pod *corev1.Pod, sts *appsv1.StatefulSet) (bool, error)
• func IsStatefulSetScaling(set *appsv1.StatefulSet) bool
• func IsStatefulSetUpgrading(set *appsv1.StatefulSet) bool
• func IsSubMapOf(first map[string]string, second map[string]string) bool
• func MatchLabelFromStoreLabels(storeLabels []*metapb.StoreLabel, componentLabel string) bool
• func MustNewRequirement(key string, op selection.Operator, vals []string) *labels.Requirement
• func NewCustomResourceDefinition(crdKind v1alpha1.CrdKind, group string, labels map[string]string, ...) *extensionsobj.CustomResourceDefinition
• func OrdinalPVCName(memberType v1alpha1.MemberType, setName string, ordinal int32) string
• func RetainManagedFields(desiredSvc, existedSvc *corev1.Service)
• func TiDBClientTLSSecretName(tcName string) string
• func VolumeClaimTemplate(r corev1.ResourceRequirements, metaName string, storageClassName *string) corev1.PersistentVolumeClaim
• type SortEnvByName
  • func (e SortEnvByName) Len() int
  • func (e SortEnvByName) Less(i, j int) bool
  • func (e SortEnvByName) Swap(i, j int)

Variables

var (
	ClusterClientTLSPath = "/var/lib/cluster-client-tls"
	TiDBClientTLSPath    = "/var/lib/tidb-client-tls"
	BRBinPath            = "/var/lib/br-bin"
	DumplingBinPath      = "/var/lib/dumpling-bin"
	LightningBinPath     = "/var/lib/lightning-bin"
	ClusterClientVolName = "cluster-client-tls"
)

Functions

func AppendEnv

func AppendEnv(a []corev1.EnvVar, b []corev1.EnvVar) []corev1.EnvVar

AppendEnv appends envs `b` into `a` ignoring envs whose names already exist in `b`. Note that this will not change relative order of envs.

func AppendEnvIfPresent

func AppendEnvIfPresent(envs []corev1.EnvVar, name string) []corev1.EnvVar

AppendEnvIfPresent appends the given environment if present

func AppendOverwriteEnv

func AppendOverwriteEnv(a []corev1.EnvVar, b []corev1.EnvVar) []corev1.EnvVar

AppendOverwriteEnv appends envs b into a and overwrites the envs whose names already exist in b. Note that this will not change relative order of envs.

func BuildStorageVolumeAndVolumeMount

func BuildStorageVolumeAndVolumeMount(storageVolumes []v1alpha1.StorageVolume, defaultStorageClassName *string, memberType v1alpha1.MemberType) ([]corev1.VolumeMount, []corev1.PersistentVolumeClaim)

BuildStorageVolumeAndVolumeMount builds VolumeMounts and PVCs for volumes declaired in spec.storageVolumes of ComponentSpec

func ClusterClientTLSSecretName

func ClusterClientTLSSecretName(tcName string) string

func ClusterTLSSecretName

func ClusterTLSSecretName(tcName, component string) string

func Encode

func Encode(obj interface{}) (string, error)

func GetAutoScalingOutSlots

func GetAutoScalingOutSlots(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) sets.Int32

func GetCrdKindFromKindName

func GetCrdKindFromKindName(kindName string) (v1alpha1.CrdKind, error)

func GetDeleteSlotsNumber

func GetDeleteSlotsNumber(annotations map[string]string) (int32, error)

func GetOrdinalFromPodName

func GetOrdinalFromPodName(podName string) (int32, error)

func GetPodName

func GetPodName(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType, ordinal int32) string

func GetPodOrdinals

func GetPodOrdinals(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) (sets.Int32, error)

GetPodOrdinals gets desired ordials of member in given TidbCluster.

func GetStatefulSetName

func GetStatefulSetName(tc *v1alpha1.TidbCluster, memberType v1alpha1.MemberType) string

func IsOwnedByTidbCluster

func IsOwnedByTidbCluster(obj metav1.Object) (bool, *metav1.OwnerReference)

IsOwnedByTidbCluster checks if the given object is owned by TidbCluster. Schema Kind and Group are checked, Version is ignored.

func IsPodOrdinalNotExceedReplicas

func IsPodOrdinalNotExceedReplicas(pod *corev1.Pod, sts *appsv1.StatefulSet) (bool, error)

func IsStatefulSetScaling

func IsStatefulSetScaling(set *appsv1.StatefulSet) bool

func IsStatefulSetUpgrading

func IsStatefulSetUpgrading(set *appsv1.StatefulSet) bool

func IsSubMapOf

func IsSubMapOf(first map[string]string, second map[string]string) bool

IsSubMapOf returns whether the first map is a sub map of the second map

func MatchLabelFromStoreLabels

func MatchLabelFromStoreLabels(storeLabels []*metapb.StoreLabel, componentLabel string) bool

func MustNewRequirement

func MustNewRequirement(key string, op selection.Operator, vals []string) *labels.Requirement

MustNewRequirement calls NewRequirement and panics on failure.

func NewCustomResourceDefinition

func NewCustomResourceDefinition(crdKind v1alpha1.CrdKind, group string, labels map[string]string, validation bool) *extensionsobj.CustomResourceDefinition

func OrdinalPVCName

func OrdinalPVCName(memberType v1alpha1.MemberType, setName string, ordinal int32) string

func RetainManagedFields

func RetainManagedFields(desiredSvc, existedSvc *corev1.Service)

RetainManagedFields retains the fields in the old object that are managed by kube-controller-manager, such as node ports

func TiDBClientTLSSecretName

func TiDBClientTLSSecretName(tcName string) string

func VolumeClaimTemplate

func VolumeClaimTemplate(r corev1.ResourceRequirements, metaName string, storageClassName *string) corev1.PersistentVolumeClaim

Types

type SortEnvByName

type SortEnvByName []corev1.EnvVar

SortEnvByName implements sort.Interface to sort env list by name.

func (SortEnvByName) Len

func (e SortEnvByName) Len() int

func (SortEnvByName) Less

func (e SortEnvByName) Less(i, j int) bool

func (SortEnvByName) Swap

func (e SortEnvByName) Swap(i, j int)