noderesource

Documentation

Index

• Constants
• Variables
• func Add(mgr ctrl.Manager) error
• func InitFlags(fs *flag.FlagSet)
• type EnqueueRequestForNodeMetric
  • func (n *EnqueueRequestForNodeMetric) Create(ctx context.Context, e event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Delete(ctx context.Context, e event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Generic(ctx context.Context, e event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Update(ctx context.Context, e event.UpdateEvent, q workqueue.RateLimitingInterface)
• type NodeResourceReconciler
  • func (r *NodeResourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NodeResourceReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	Name = "noderesource"
)

Variables

var (
	NodeResourcePlugins []string
	AllPlugins          []string
)

Functions

func Add

func Add(mgr ctrl.Manager) error

func InitFlags

func InitFlags(fs *flag.FlagSet)

Types

type EnqueueRequestForNodeMetric

type EnqueueRequestForNodeMetric struct {
	client.Client
	// contains filtered or unexported fields
}

func (*EnqueueRequestForNodeMetric) Create

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

func (*EnqueueRequestForNodeMetric) Delete

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

func (*EnqueueRequestForNodeMetric) Generic

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

func (*EnqueueRequestForNodeMetric) Update

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

type NodeResourceReconciler

type NodeResourceReconciler struct {
	Client          client.Client
	Recorder        record.EventRecorder
	Scheme          *runtime.Scheme
	Clock           clock.Clock
	NodeSyncContext *framework.SyncContext
	GPUSyncContext  *framework.SyncContext
	// contains filtered or unexported fields
}

func (*NodeResourceReconciler) Reconcile

func (r *NodeResourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NodeResourceReconciler) SetupWithManager

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