pod

Documentation

Index

• Constants
• Variables
• func IsPodInPdMembers(tc *v1alpha1.TidbCluster, pod *core.Pod, pdClient pdapi.PDClient) (bool, error)
• func IsPodWithPDDeferDeletingAnnotations(pod *core.Pod) bool
• type PodAdmissionControl
  • func NewPodAdmissionControl(extraServiceAccounts []string, resyncDuration time.Duration) *PodAdmissionControl
  • func (pc *PodAdmissionControl) Admit(ar *admission.AdmissionRequest) *admission.AdmissionResponse
  • func (a *PodAdmissionControl) Initialize(cfg *rest.Config, stopCh <-chan struct{}) error
  • func (w *PodAdmissionControl) MutatingResource() (plural schema.GroupVersionResource, singular string)
  • func (pc *PodAdmissionControl) Validate(ar *admission.AdmissionRequest) *admission.AdmissionResponse
  • func (w *PodAdmissionControl) ValidatingResource() (plural schema.GroupVersionResource, singular string)

Constants

const (
	// EvictLeaderBeginTime is the key of evict Leader begin time
	EvictLeaderBeginTime = label.AnnEvictLeaderBeginTime
)

Variables

var (
	AstsControllerServiceAccounts string
)

Functions

func IsPodInPdMembers

func IsPodInPdMembers(tc *v1alpha1.TidbCluster, pod *core.Pod, pdClient pdapi.PDClient) (bool, error)

func IsPodWithPDDeferDeletingAnnotations

func IsPodWithPDDeferDeletingAnnotations(pod *core.Pod) bool

check whether this pod have PD DeferDeleting Annotations

Types

type PodAdmissionControl

type PodAdmissionControl struct {
	// contains filtered or unexported fields
}

func NewPodAdmissionControl

func NewPodAdmissionControl(extraServiceAccounts []string, resyncDuration time.Duration) *PodAdmissionControl

func (*PodAdmissionControl) Admit

func (pc *PodAdmissionControl) Admit(ar *admission.AdmissionRequest) *admission.AdmissionResponse

func (*PodAdmissionControl) Initialize

func (a *PodAdmissionControl) Initialize(cfg *rest.Config, stopCh <-chan struct{}) error

Initialize implements AdmissionHook.Initialize interface. It's is called as a post-start hook.

func (*PodAdmissionControl) MutatingResource

func (w *PodAdmissionControl) MutatingResource() (plural schema.GroupVersionResource, singular string)

func (*PodAdmissionControl) Validate

func (pc *PodAdmissionControl) Validate(ar *admission.AdmissionRequest) *admission.AdmissionResponse

func (*PodAdmissionControl) ValidatingResource

func (w *PodAdmissionControl) ValidatingResource() (plural schema.GroupVersionResource, singular string)