controllers

Documentation

Index

• type DebugPredicate
  • func (p DebugPredicate) Create(e event.CreateEvent) bool
  • func (p DebugPredicate) Delete(e event.DeleteEvent) bool
  • func (p DebugPredicate) Generic(e event.GenericEvent) bool
  • func (DebugPredicate) Update(e event.UpdateEvent) bool
• type MPDClusterReconciler
  • func (r *MPDClusterReconciler) Reconcile(req ctrl.Request) (result ctrl.Result, err error)
  • func (r *MPDClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PolarOptLead
  • func (lead *PolarOptLead) InjectAPIReader(client.Reader) error
  • func (lead *PolarOptLead) InjectCache(cache cache.Cache) error
  • func (lead *PolarOptLead) InjectClient(client client.Client) error
  • func (lead *PolarOptLead) InjectConfig(config *rest.Config) error
  • func (lead *PolarOptLead) InjectFunc(f inject.Func) error
  • func (lead *PolarOptLead) InjectMapper(mapper meta.RESTMapper) error
  • func (lead *PolarOptLead) InjectScheme(scheme *runtime.Scheme) error
  • func (lead *PolarOptLead) InjectStopChannel(<-chan struct{}) error
  • func (lead *PolarOptLead) NeedLeaderElection() bool
  • func (lead *PolarOptLead) Start(stop <-chan struct{}) error

Types

type DebugPredicate

type DebugPredicate struct {
	predicate.Funcs
}

func (DebugPredicate) Create

func (p DebugPredicate) Create(e event.CreateEvent) bool

Create implements Predicate

func (DebugPredicate) Delete

func (p DebugPredicate) Delete(e event.DeleteEvent) bool

Delete implements Predicate

func (DebugPredicate) Generic

func (p DebugPredicate) Generic(e event.GenericEvent) bool

func (DebugPredicate) Update

func (DebugPredicate) Update(e event.UpdateEvent) bool

Update implements default UpdateEvent filter for validating resource version change

type MPDClusterReconciler

type MPDClusterReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

MPDClusterReconciler reconciles a MPDCluster object

func (*MPDClusterReconciler) Reconcile

func (r *MPDClusterReconciler) Reconcile(req ctrl.Request) (result ctrl.Result, err error)

+kubebuilder:rbac:groups=mpd.polardb.aliyun.com,resources=mpdclusters,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=mpd.polardb.aliyun.com,resources=mpdclusters/status,verbs=get;update;patch

func (*MPDClusterReconciler) SetupWithManager

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

type PolarOptLead

type PolarOptLead struct {
	RestConfig      *rest.Config
	KubeClient      client.Client
	InjectFunctions inject.Func
	RsMapper        meta.RESTMapper
	OwnedMgr        manager.Manager
}

func (*PolarOptLead) InjectAPIReader

func (lead *PolarOptLead) InjectAPIReader(client.Reader) error

func (*PolarOptLead) InjectCache

func (lead *PolarOptLead) InjectCache(cache cache.Cache) error

func (*PolarOptLead) InjectClient

func (lead *PolarOptLead) InjectClient(client client.Client) error

func (*PolarOptLead) InjectConfig

func (lead *PolarOptLead) InjectConfig(config *rest.Config) error

func (*PolarOptLead) InjectFunc

func (lead *PolarOptLead) InjectFunc(f inject.Func) error

func (*PolarOptLead) InjectMapper

func (lead *PolarOptLead) InjectMapper(mapper meta.RESTMapper) error

func (*PolarOptLead) InjectScheme

func (lead *PolarOptLead) InjectScheme(scheme *runtime.Scheme) error

func (*PolarOptLead) InjectStopChannel

func (lead *PolarOptLead) InjectStopChannel(<-chan struct{}) error

func (*PolarOptLead) NeedLeaderElection

func (lead *PolarOptLead) NeedLeaderElection() bool

func (*PolarOptLead) Start

func (lead *PolarOptLead) Start(stop <-chan struct{}) error