Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 50 for restMapper (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top