noderesource

Documentation

Index

• Constants
• Variables
• func Add(mgr ctrl.Manager) error
• func InitFlags(fs *flag.FlagSet)
• type EnqueueRequestForDevice
  • func (n *EnqueueRequestForDevice) Create(e event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForDevice) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForDevice) Generic(e event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForDevice) Update(e event.UpdateEvent, q workqueue.RateLimitingInterface)
• type EnqueueRequestForNodeMetric
  • func (n *EnqueueRequestForNodeMetric) Create(e event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Generic(e event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (n *EnqueueRequestForNodeMetric) Update(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 EnqueueRequestForDevice

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

func (*EnqueueRequestForDevice) Create

func (n *EnqueueRequestForDevice) Create(e event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForDevice) Delete

func (n *EnqueueRequestForDevice) Delete(e event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForDevice) Generic

func (n *EnqueueRequestForDevice) Generic(e event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForDevice) Update

func (n *EnqueueRequestForDevice) Update(e event.UpdateEvent, q workqueue.RateLimitingInterface)

type EnqueueRequestForNodeMetric

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

func (*EnqueueRequestForNodeMetric) Create

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

func (*EnqueueRequestForNodeMetric) Delete

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

func (*EnqueueRequestForNodeMetric) Generic

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

func (*EnqueueRequestForNodeMetric) Update

func (n *EnqueueRequestForNodeMetric) Update(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