util

Documentation

Index

• Variables
• func AppendEnv(a []corev1.EnvVar, b []corev1.EnvVar) []corev1.EnvVar
• 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 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 NewCustomResourceDefinition(crdKind v1alpha1.CrdKind, group string, labels map[string]string, ...) *extensionsobj.CustomResourceDefinition
• func OrdinalPVCName(memberType v1alpha1.MemberType, setName string, ordinal int32) string
• func TiDBClientTLSSecretName(tcName string) string
• 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"
)

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 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 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 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 TiDBClientTLSSecretName

func TiDBClientTLSSecretName(tcName string) string

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)