gcpnfsvolume

Documentation

Index

• Variables
• type Reconciler
  • func NewReconciler(kymaRef klog.ObjectRef, kcpCluster cluster.Cluster, skrCluster cluster.Cluster) Reconciler
  • func (r *Reconciler) Run(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type State
  • func (s *State) IsChanged() bool
  • func (s *State) ObjAsGcpNfsVolume() *cloudresourcesv1beta1.GcpNfsVolume
• type StateFactory
  • func NewStateFactory(kymaRef klog.ObjectRef, kcpCluster composed.StateCluster, ...) StateFactory

Variables

var PVEventHandler handler.Funcs = handler.Funcs{

	CreateFunc: func(ctx context.Context, e event.CreateEvent, q workqueue.RateLimitingInterface) {
		if match, key := isMatchingPV(e.Object); match {
			q.Add(reconcile.Request{NamespacedName: *key})
		}
	},
	UpdateFunc: func(ctx context.Context, e event.UpdateEvent, q workqueue.RateLimitingInterface) {
		if match, key := isMatchingPV(e.ObjectNew); match {
			q.Add(reconcile.Request{NamespacedName: *key})
		}
	},
	DeleteFunc: func(ctx context.Context, e event.DeleteEvent, q workqueue.RateLimitingInterface) {
		if match, key := isMatchingPV(e.Object); match {
			q.Add(reconcile.Request{NamespacedName: *key})
		}
	},
}

Types

type Reconciler

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

func NewReconciler

func NewReconciler(kymaRef klog.ObjectRef, kcpCluster cluster.Cluster, skrCluster cluster.Cluster) Reconciler

func (*Reconciler) Run

func (r *Reconciler) Run(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type State

type State struct {
	composed.State
	KymaRef        klog.ObjectRef
	KcpCluster     composed.StateCluster
	KcpNfsInstance *cloudcontrolv1beta1.NfsInstance
	KcpIpRange     *cloudcontrolv1beta1.IpRange
	SkrCluster     composed.StateCluster
	PV             *v1.PersistentVolume
}

func (*State) IsChanged

func (s *State) IsChanged() bool

func (*State) ObjAsGcpNfsVolume

func (s *State) ObjAsGcpNfsVolume() *cloudresourcesv1beta1.GcpNfsVolume

type StateFactory

type StateFactory interface {
	NewState(baseState composed.State) *State
}

func NewStateFactory

func NewStateFactory(kymaRef klog.ObjectRef, kcpCluster composed.StateCluster, skrCluster composed.StateCluster) StateFactory