member

Documentation

Index

• Constants
• func EqualService(new, old *corev1.Service) (bool, error)
• func EqualStatefulSet(new apps.StatefulSet, old apps.StatefulSet) (bool, error)
• func EqualTemplate(new corev1.PodTemplateSpec, old corev1.PodTemplateSpec) (bool, error)
• func GetLastAppliedConfig(set *apps.StatefulSet) (*apps.StatefulSetSpec, *corev1.PodSpec, error)
• func NewPDMemberManager(pdControl controller.PDControlInterface, ...) manager.Manager
• func NewTiDBMemberManager(setControl controller.StatefulSetControlInterface, ...) manager.Manager
• func NewTiKVMemberManager(pdControl controller.PDControlInterface, ...) manager.Manager
• func SetLastAppliedConfigAnnotation(set *apps.StatefulSet) error
• func SetServiceLastAppliedConfigAnnotation(svc *corev1.Service) error
• type Scaler
  • func NewFakePDScaler() Scaler
  • func NewFakeTiKVScaler() Scaler
  • func NewPDScaler(pdControl controller.PDControlInterface, ...) Scaler
  • func NewTiKVScaler(pdControl controller.PDControlInterface, ...) Scaler
• type SvcConfig

Constants

const (
	// LastAppliedConfigAnnotation is annotation key of last applied configuration
	LastAppliedConfigAnnotation = "pingcap.com/last-applied-configuration"
)

Functions

func EqualService

func EqualService(new, old *corev1.Service) (bool, error)

EqualService compare the new Service's spec with old Service's last applied config

func EqualStatefulSet

func EqualStatefulSet(new apps.StatefulSet, old apps.StatefulSet) (bool, error)

EqualStatefulSet compare the new Statefulset's spec with old Statefulset's last applied config

func EqualTemplate

func EqualTemplate(new corev1.PodTemplateSpec, old corev1.PodTemplateSpec) (bool, error)

EqualTemplate compare the new podTemplateSpec's spec with old podTemplateSpec's last applied config

func GetLastAppliedConfig

func GetLastAppliedConfig(set *apps.StatefulSet) (*apps.StatefulSetSpec, *corev1.PodSpec, error)

GetLastAppliedConfig get last applied config info from Statefulset's annotation

func NewPDMemberManager

func NewPDMemberManager(pdControl controller.PDControlInterface,
	setControl controller.StatefulSetControlInterface,
	svcControl controller.ServiceControlInterface,
	setLister v1beta1.StatefulSetLister,
	svcLister corelisters.ServiceLister,
	pdScaler Scaler) manager.Manager

NewPDMemberManager returns a *pdMemberManager

func NewTiDBMemberManager

func NewTiDBMemberManager(setControl controller.StatefulSetControlInterface,
	svcControl controller.ServiceControlInterface,
	setLister v1beta1.StatefulSetLister,
	svcLister corelisters.ServiceLister) manager.Manager

NewTiDBMemberManager returns a *tidbMemberManager

func NewTiKVMemberManager

func NewTiKVMemberManager(pdControl controller.PDControlInterface,
	setControl controller.StatefulSetControlInterface,
	svcControl controller.ServiceControlInterface,
	setLister v1beta1.StatefulSetLister,
	svcLister corelisters.ServiceLister,
	podLister corelisters.PodLister,
	nodeLister corelisters.NodeLister,
	tikvScaler Scaler) manager.Manager

NewTiKVMemberManager returns a *tikvMemberManager

func SetLastAppliedConfigAnnotation

func SetLastAppliedConfigAnnotation(set *apps.StatefulSet) error

SetLastAppliedConfigAnnotation set last applied config info to Statefulset's annotation

func SetServiceLastAppliedConfigAnnotation

func SetServiceLastAppliedConfigAnnotation(svc *corev1.Service) error

SetServiceLastAppliedConfigAnnotation set last applied config info to Service's annotation

Types

type Scaler

type Scaler interface {
	// ScaleOut scales out the cluster
	ScaleOut(*v1alpha1.TidbCluster, *apps.StatefulSet, *apps.StatefulSet) error
	// ScaleIn scales in the cluster
	ScaleIn(*v1alpha1.TidbCluster, *apps.StatefulSet, *apps.StatefulSet) error
}

Scaler implements the logic for scaling out or scaling in the cluster.

func NewFakePDScaler

func NewFakePDScaler() Scaler

NewFakePDScaler returns a fake Scaler

func NewFakeTiKVScaler

func NewFakeTiKVScaler() Scaler

NewFakeTiKVScaler returns a fake tikv Scaler

func NewPDScaler

func NewPDScaler(pdControl controller.PDControlInterface,
	pvcLister corelisters.PersistentVolumeClaimLister,
	pvcControl controller.PVCControlInterface) Scaler

NewPDScaler returns a Scaler

func NewTiKVScaler

func NewTiKVScaler(pdControl controller.PDControlInterface,
	pvcLister corelisters.PersistentVolumeClaimLister,
	pvcControl controller.PVCControlInterface) Scaler

NewTiKVScaler returns a tikv Scaler

type SvcConfig

type SvcConfig struct {
	Name       string
	Port       int32
	SvcLabel   func(label.Label) label.Label
	MemberName func(clusterName string) string
	Headless   bool
}

SvcConfig corresponds to a K8s service