pod_controller

Documentation

Index

• Constants
• type PodCtrl
  • func (podctrl *PodCtrl) DeletePodAll(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) bool
  • func (podctrl *PodCtrl) ExpansionPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) (*iapetosapiv1.PodStatus, error)
  • func (podctrl *PodCtrl) IsPodDeleting(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool
  • func (podctrl *PodCtrl) MaintainPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int
  • func (podctrl *PodCtrl) MonitorPodStatus(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, pod *corev1.Pod, ...) bool
  • func (podctrl *PodCtrl) PodIsOk(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int
  • func (podctrl *PodCtrl) ShrinkPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool
• type PodCtrlFunc
  • func NewPodCtrl(client client.Client) PodCtrlFunc

Constants

const (
	Preparing     = corev1.PodPhase("Preparing")
	Deleting      = corev1.PodPhase("Deleting")
	CreateTimeOut = corev1.PodPhase("CreateTimeOut")
)

Types

type PodCtrl

type PodCtrl struct {
	client.Client
}

func (*PodCtrl) DeletePodAll

func (podctrl *PodCtrl) DeletePodAll(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) bool

func (*PodCtrl) ExpansionPod

func (podctrl *PodCtrl) ExpansionPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) (*iapetosapiv1.PodStatus, error)

扩容 pod

func (*PodCtrl) IsPodDeleting

func (podctrl *PodCtrl) IsPodDeleting(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool

func (*PodCtrl) MaintainPod

func (podctrl *PodCtrl) MaintainPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int

func (*PodCtrl) MonitorPodStatus

func (podctrl *PodCtrl) MonitorPodStatus(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, pod *corev1.Pod, index *int) bool

func (*PodCtrl) PodIsOk

func (podctrl *PodCtrl) PodIsOk(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int

func (*PodCtrl) ShrinkPod

func (podctrl *PodCtrl) ShrinkPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool

缩容 pod

type PodCtrlFunc

type PodCtrlFunc interface {
	ExpansionPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) (*iapetosapiv1.PodStatus, error)
	ShrinkPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool
	DeletePodAll(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) bool
	MaintainPod(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int
	MonitorPodStatus(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, pod *corev1.Pod, index *int) bool
	PodIsOk(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod) *int
	//IsCreationPodTimeout(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool
	IsPodDeleting(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, index int) bool
}

func NewPodCtrl

func NewPodCtrl(client client.Client) PodCtrlFunc