- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for UpdateFunc (0.19 sec)
-
pilot/pkg/status/manager.go
return &IstioGenerationProvider{result} } result := &Controller{ fn: wrapper, workers: m.workers, } return result } type UpdateFunc func(status any, context any) GenerationProvider type Controller struct { fn UpdateFunc workers WorkerQueue } // EnqueueStatusUpdateResource informs the manager that this controller would like to
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/kube/controllers/common.go
} else if e.AddFunc != nil { e.AddFunc(Extract[T](obj)) } } func (e EventHandler[T]) OnUpdate(oldObj, newObj interface{}) { if e.UpdateFunc != nil { e.UpdateFunc(Extract[T](oldObj), Extract[T](newObj)) } } func (e EventHandler[T]) OnDelete(obj interface{}) { if e.DeleteFunc != nil { e.DeleteFunc(Extract[T](obj)) } } var _ cache.ResourceEventHandler = EventHandler[Object]{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
graph: graph, } podHandler, _ := pods.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPod, UpdateFunc: g.updatePod, DeleteFunc: g.deletePod, }) pvsHandler, _ := pvs.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPV, UpdateFunc: g.updatePV, DeleteFunc: g.deletePV, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/registry/networking/networkpolicy/storage/storage_test.go
storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestUpdate( // valid validNetworkPolicy(), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*networking.NetworkPolicy) object.Spec.Ingress = []networking.NetworkPolicyIngressRule{ { From: []networking.NetworkPolicyPeer{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 18:19:25 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" ) type SimpleUpdateFunc func(runtime.Object) (runtime.Object, error) // SimpleUpdateFunc converts SimpleUpdateFunc into UpdateFunc func SimpleUpdate(fn SimpleUpdateFunc) UpdateFunc { return func(input runtime.Object, _ ResponseMeta) (runtime.Object, *uint64, error) { out, err := fn(input) return out, nil, err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingadmissionpolicy/storage/storage_test.go
test.TestUpdate( // valid validValidatingAdmissionPolicy(), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*admissionregistration.ValidatingAdmissionPolicy) object.Labels = map[string]string{"c": "d"} return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*admissionregistration.ValidatingAdmissionPolicy)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 23:43:34 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingwebhookconfiguration/storage/storage_test.go
test.TestUpdate( // valid validValidatingWebhookConfiguration(), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*admissionregistration.ValidatingWebhookConfiguration) object.Labels = map[string]string{"c": "d"} return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*admissionregistration.ValidatingWebhookConfiguration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 13 15:10:55 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 2K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
cmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ DeleteFunc: e.configMapDeleted, UpdateFunc: e.configMapUpdated, }) e.cmLister = cmInformer.Lister() e.cmListerSynced = cmInformer.Informer().HasSynced nsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: e.namespaceAdded, UpdateFunc: e.namespaceUpdated, }) e.nsListerSynced = nsInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingadmissionpolicybinding/storage/storage_test.go
test.TestUpdate( // valid b, // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*admissionregistration.ValidatingAdmissionPolicyBinding) object.Labels = map[string]string{"c": "d"} return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 20 16:30:09 UTC 2023 - 7.7K bytes - Viewed (0)