- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 176 for newobj (0.13 sec)
-
pkg/kube/kclient/clienttest/test_helpers.go
return controllers.EventHandler[controllers.Object]{ AddFunc: func(obj controllers.Object) { tracker.Record("add/" + obj.GetName()) }, UpdateFunc: func(oldObj, newObj controllers.Object) { tracker.Record("update/" + newObj.GetName()) }, DeleteFunc: func(obj controllers.Object) { tracker.Record("delete/" + obj.GetName()) }, } } func Names[T controllers.Object](list []T) sets.String {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
src/go/ast/scope.go
Data any // object-specific data; or nil Type any // placeholder for type information; may be nil } // NewObj creates a new object of a given kind and name. func NewObj(kind ObjKind, name string) *Object { return &Object{Kind: kind, Name: name} } // Pos computes the source position of the declaration of an object name.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 28 21:32:41 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
} reg, err := policyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.enqueuePolicy(obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.enqueuePolicy(newObj) }, }) if err != nil { return nil, err } c.policySynced = reg.HasSynced return c, nil } func (c *Controller) enqueuePolicy(policy any) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/capmanagers.go
oldUpdatesManagerName: "ancient-changes", } } // Update implements Manager. func (f *capManagersManager) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { object, managed, err := f.fieldManager.Update(liveObj, newObj, managed, manager) if err != nil { return object, managed, err } if managed, err = f.capUpdateManagers(managed); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
func (adc *attachDetachController) processNextItem(logger klog.Logger) bool { keyObj, shutdown := adc.pvcQueue.Get() if shutdown { return false } defer adc.pvcQueue.Done(keyObj) if err := adc.syncPVCByKey(logger, keyObj); err != nil { // Rather than wait for a full resync, re-add the key to the // queue to be processed. adc.pvcQueue.AddRateLimited(keyObj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// clusterEvent has the event and involved objects. type clusterEvent struct { event framework.ClusterEvent // oldObj is the object that involved this event. oldObj interface{} // newObj is the object that involved this event. newObj interface{} } type priorityQueueOptions struct { clock clock.Clock podInitialBackoffDuration time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
func (qm *QuotaMonitor) controllerFor(ctx context.Context, resource schema.GroupVersionResource) (cache.Controller, error) { logger := klog.FromContext(ctx) handlers := cache.ResourceEventHandlerFuncs{ UpdateFunc: func(oldObj, newObj interface{}) { if qm.updateFilter != nil && qm.updateFilter(resource, oldObj, newObj) { event := &event{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
} func (pl *PodTopologySpread) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kube/krt/informer.go
AddExtendedFunc: func(obj I, initialSync bool) { handler(Event[I]{ New: &obj, Event: controllers.EventAdd, }, initialSync) }, UpdateFunc: func(oldObj, newObj I) { handler(Event[I]{ Old: &oldObj, New: &newObj, Event: controllers.EventUpdate, }, false) }, DeleteFunc: func(obj I) { handler(Event[I]{ Old: &obj, Event: controllers.EventDelete,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
type DistroReportHandler struct { dc *Controller } func (drh *DistroReportHandler) OnAdd(obj any, _ bool) { drh.HandleNew(obj) } func (drh *DistroReportHandler) OnUpdate(oldObj, newObj any) { drh.HandleNew(newObj) } func (drh *DistroReportHandler) HandleNew(obj any) { cm, ok := obj.(*v1.ConfigMap) if !ok { scope.Warnf("expected configmap, but received %v, discarding", obj) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0)