statefulset

Documentation

Index

• Constants
• func GetWorkloadName(statefulSetName string) string
• func NewReconciler(client client.Client, _ record.EventRecorder, _ ...jobframework.Option) jobframework.JobReconcilerInterface
• func SetupIndexes(context.Context, client.FieldIndexer) error
• func SetupWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
• type StatefulSet
  • func (d *StatefulSet) GVK() schema.GroupVersionKind
  • func (d *StatefulSet) Object() client.Object
• type Webhook
  • func (wh *Webhook) Default(ctx context.Context, obj runtime.Object) error
  • func (wh *Webhook) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)
  • func (wh *Webhook) ValidateDelete(context.Context, runtime.Object) (warnings admission.Warnings, err error)
  • func (wh *Webhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (warnings admission.Warnings, err error)

Constants

const (
	FrameworkName = "statefulset"
)

Functions

func GetWorkloadName

func GetWorkloadName(statefulSetName string) string

func NewReconciler

func NewReconciler(client client.Client, _ record.EventRecorder, _ ...jobframework.Option) jobframework.JobReconcilerInterface

func SetupIndexes

func SetupIndexes(context.Context, client.FieldIndexer) error

func SetupWebhook

func SetupWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error

Types

type Reconciler

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

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

type StatefulSet

type StatefulSet appsv1.StatefulSet

func (*StatefulSet) GVK

func (d *StatefulSet) GVK() schema.GroupVersionKind

func (*StatefulSet) Object

func (d *StatefulSet) Object() client.Object

type Webhook

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

func (*Webhook) Default

func (wh *Webhook) Default(ctx context.Context, obj runtime.Object) error

func (*Webhook) ValidateCreate

func (wh *Webhook) ValidateCreate(ctx context.Context, obj runtime.Object) (warnings admission.Warnings, err error)

func (*Webhook) ValidateDelete

func (wh *Webhook) ValidateDelete(context.Context, runtime.Object) (warnings admission.Warnings, err error)

func (*Webhook) ValidateUpdate

func (wh *Webhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (warnings admission.Warnings, err error)