- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 50 for restMapper (0.29 sec)
-
pkg/controller/validatingadmissionpolicystatus/controller_test.go
typeChecker := &validatingadmissionpolicy.TypeChecker{ SchemaResolver: resolver.NewDefinitionsSchemaResolver(openapi.GetOpenAPIDefinitions, scheme.Scheme), RestMapper: testrestmapper.TestOnlyStaticRESTMapper(scheme.Scheme), } controller, err := NewController( informerFactory.Admissionregistration().V1().ValidatingAdmissionPolicies(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
// a graph that caches the dependencies as we know, and enqueues // items to the attemptToDelete and attemptToOrphan. type GraphBuilder struct { restMapper meta.RESTMapper // each monitor list/watches a resource, the results are funneled to the // dependencyGraphBuilder monitors monitors monitorLock sync.RWMutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
} garbageCollector, err := garbagecollector.NewComposedGarbageCollector( ctx, gcClientset, metadataClient, controllerContext.RESTMapper, controllerContext.GraphBuilder, ) if err != nil { return nil, true, fmt.Errorf("failed to start the generic garbage collector: %w", err) } // Start the garbage collector.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go
} return basicInfo } // Namespaced returns true if the object belongs to a namespace func (i *Info) Namespaced() bool { if i.Mapping != nil { // if we have RESTMapper info, use it return i.Mapping.Scope.Name() == meta.RESTScopeNameNamespace } // otherwise, use the presence of a namespace in the info as an indicator return len(i.Namespace) > 0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 21.3K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
// control. type HorizontalController struct { scaleNamespacer scaleclient.ScalesGetter hpaNamespacer autoscalingclient.HorizontalPodAutoscalersGetter mapper apimeta.RESTMapper replicaCalc *ReplicaCalculator eventRecorder record.EventRecorder downscaleStabilisationWindow time.Duration monitor monitor.Monitor
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
t.Fatalf("Expected quotacontroller.Sync to still be running but it is blocked: %v", err) } assertMonitors(t, qc, "pods", "deployments") // Simulate the discovery client returning a resource the restmapper can resolve, but will not sync caches fakeDiscoveryClient.setPreferredResources(unsyncableServerResources, nil) // Wait until sync discovers the change time.Sleep(1 * time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/firsthit_restmapper.go
"k8s.io/apimachinery/pkg/runtime/schema" utilerrors "k8s.io/apimachinery/pkg/util/errors" ) var ( _ ResettableRESTMapper = &FirstHitRESTMapper{} ) // FirstHitRESTMapper is a wrapper for multiple RESTMappers which returns the // first successful result for the singular requests type FirstHitRESTMapper struct { MultiRESTMapper } func (m FirstHitRESTMapper) String() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 23:44:02 UTC 2021 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/values_test.go
added := lister.Add(addition).Value() if !reflect.DeepEqual(added, tc.expectAdded) { t.Errorf("Expected Add to return %v but got %v", tc.expectAdded, added) } }) } } func TestMapper(t *testing.T) { cases := []struct { name string unstructured map[string]interface{} schema *schema.Structural propertySchema func(key string) (*schema.Structural, bool)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 20:13:14 UTC 2024 - 17.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/openapi/values_test.go
added := lister.Add(addition).Value() if !reflect.DeepEqual(added, tc.expectAdded) { t.Errorf("Expected Add to return %v but got %v", tc.expectAdded, added) } }) } } func TestMapper(t *testing.T) { cases := []struct { name string unstructured map[string]interface{} schema *spec.Schema propertySchema func(key string) (*spec.Schema, bool) size int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:30:17 UTC 2023 - 17.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.11.md
* The shortcuts that were moved server-side in at least 1.9 have been removed from being hardcoded in kubectl. This means that the client-based restmappers have been moved to client-go, where everyone who needs them can have access. ([#63507](https://github.com/kubernetes/kubernetes/pull/63507), [@deads2k](https://github.com/deads2k))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 06 06:04:15 UTC 2020 - 328.4K bytes - Viewed (0)