podunavailablebudget

Documentation

Index

• Constants
• Variables
• func Add(mgr manager.Manager) error
• func GetPubForPod(c client.Client, pod *corev1.Pod) (*policyv1alpha1.PodUnavailableBudget, error)
• type ReconcilePodUnavailableBudget
  • func (r *ReconcilePodUnavailableBudget) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error)
• type SetEnqueueRequestForPUB
  • func (e *SetEnqueueRequestForPUB) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *SetEnqueueRequestForPUB) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *SetEnqueueRequestForPUB) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *SetEnqueueRequestForPUB) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Constants

const (
	DeletionTimeout       = 20 * time.Second
	UpdatedDelayCheckTime = 10 * time.Second
)

Variables

var ConflictRetry = wait.Backoff{
	Steps:    4,
	Duration: 500 * time.Millisecond,
	Factor:   1.0,
	Jitter:   0.1,
}

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new PodUnavailableBudget Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func GetPubForPod

func GetPubForPod(c client.Client, pod *corev1.Pod) (*policyv1alpha1.PodUnavailableBudget, error)

Types

type ReconcilePodUnavailableBudget

type ReconcilePodUnavailableBudget struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ReconcilePodUnavailableBudget reconciles a PodUnavailableBudget object

func (*ReconcilePodUnavailableBudget) Reconcile

func (r *ReconcilePodUnavailableBudget) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error)

pkg/controller/cloneset/cloneset_controller.go Watch for changes to CloneSet

type SetEnqueueRequestForPUB

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

func (*SetEnqueueRequestForPUB) Create

func (e *SetEnqueueRequestForPUB) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)

Create implements EventHandler

func (*SetEnqueueRequestForPUB) Delete

func (e *SetEnqueueRequestForPUB) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

Delete implements EventHandler

func (*SetEnqueueRequestForPUB) Generic

func (e *SetEnqueueRequestForPUB) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*SetEnqueueRequestForPUB) Update

func (e *SetEnqueueRequestForPUB) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler