Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 255 for configmaps (0.16 sec)

  1. pkg/config/mesh/kubemesh/watcher_test.go

    func makeConfigMapWithName(name, resourceVersion string, data map[string]string) *v1.ConfigMap {
    	return &v1.ConfigMap{
    		ObjectMeta: metav1.ObjectMeta{
    			Namespace:       namespace,
    			Name:            name,
    			ResourceVersion: resourceVersion,
    		},
    		Data: data,
    	}
    }
    
    func makeConfigMap(resourceVersion string, data map[string]string) *v1.ConfigMap {
    	return makeConfigMapWithName(name, resourceVersion, data)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. pkg/kube/watcher/configmapwatcher/configmapwatcher_test.go

    	cm2 := makeConfigMap("not-watched", "1")
    	steps := []struct {
    		added        *v1.ConfigMap
    		updated      *v1.ConfigMap
    		deleted      *v1.ConfigMap
    		expectCalled bool
    		expectCM     *v1.ConfigMap
    	}{
    		{added: cm2},
    		{added: cm, expectCalled: true, expectCM: cm},
    		{updated: cm},
    		{updated: cm1, expectCalled: true, expectCM: cm1},
    		{deleted: cm1, expectCalled: true},
    		{deleted: cm2},
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. pkg/kube/inject/watcher_test.go

    	controller := w.(*configMapWatcher).c
    	client.RunAndWait(stop)
    	kube.WaitForCacheSync("test", stop, controller.HasSynced)
    
    	cms := client.Kube().CoreV1().ConfigMaps(namespace)
    	steps := []struct {
    		added   *v1.ConfigMap
    		updated *v1.ConfigMap
    		deleted *v1.ConfigMap
    	}{
    		{added: cm},
    
    		// Handle misconfiguration errors.
    		{updated: badCM},
    		{updated: cm},
    		{updated: badCM2},
    		{updated: badCM},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  4. cmd/kube-controller-manager/app/bootstrap.go

    	bsc, err := bootstrap.NewSigner(
    		controllerContext.ClientBuilder.ClientOrDie("bootstrap-signer"),
    		controllerContext.InformerFactory.Core().V1().Secrets(),
    		controllerContext.InformerFactory.Core().V1().ConfigMaps(),
    		bootstrap.DefaultSignerOptions(),
    	)
    	if err != nil {
    		return nil, true, fmt.Errorf("error creating BootstrapSigner controller: %v", err)
    	}
    	go bsc.Run(ctx)
    	return nil, true, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 11:28:02 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/phases/uploadconfig/uploadconfig_test.go

    					t2.Fatalf("UploadConfiguration() error = %v", err)
    				}
    			}
    			if tt.verifyResult {
    				controlPlaneCfg, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(context.TODO(), kubeadmconstants.KubeadmConfigConfigMap, metav1.GetOptions{})
    				if err != nil {
    					t2.Fatalf("Fail to query ConfigMap error = %v", err)
    				}
    				configData := controlPlaneCfg.Data[kubeadmconstants.ClusterConfigurationConfigMapKey]
    				if configData == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 08:46:51 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  6. pkg/controlplane/storageversionhashdata/data.go

    	"authorization.k8s.io/v1/subjectaccessreviews",
    )
    
    // GVRToStorageVersionHash shouldn't change unless we intentionally change the
    // storage version of a resource.
    var GVRToStorageVersionHash = map[string]string{
    	"v1/configmaps":             "qFsyl6wFWjQ=",
    	"v1/endpoints":              "fWeeMqaN/OA=",
    	"v1/events":                 "r2yiGXH7wu8=",
    	"v1/limitranges":            "EBKMFVe6cwo=",
    	"v1/namespaces":             "Q3oi5N2YM8M=",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 20:14:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. cluster/addons/rbac/cluster-loadbalancing/glbc/roles.yaml

    apiVersion: rbac.authorization.k8s.io/v1
    kind: Role
    metadata:
      name: system:controller:glbc
      namespace: kube-system
      labels:
        addonmanager.kubernetes.io/mode: Reconcile
    rules:
    - apiGroups: [""]
      resources: ["configmaps"]
      verbs: ["get", "list", "watch", "update", "create", "patch"]
    ---
    apiVersion: rbac.authorization.k8s.io/v1
    kind: ClusterRole
    metadata:
      name: system:controller:glbc
      labels:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 15 13:39:59 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  8. operator/cmd/mesh/testdata/operator/output/operator-dump.yaml

      - roles
      - rolebindings
      verbs:
      - '*'
    - apiGroups:
      - coordination.k8s.io
      resources:
      - leases
      verbs:
      - get
      - create
      - update
    - apiGroups:
      - ""
      resources:
      - configmaps
      - endpoints
      - events
      - namespaces
      - pods
      - pods/proxy
      - pods/portforward
      - persistentvolumeclaims
      - secrets
      - services
      - serviceaccounts
      - resourcequotas
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 10 05:10:03 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  9. pkg/registry/admissionregistration/validatingadmissionpolicy/authz_test.go

    			userInfo: &user.DefaultInfo{Groups: []string{user.AllAuthenticated}},
    			auth: func(ctx context.Context, a authorizer.Attributes) (authorized authorizer.Decision, reason string, err error) {
    				if a.GetResource() == "configmaps" {
    					return authorizer.DecisionAllow, "", nil
    				}
    				return authorizer.DecisionDeny, "", nil
    			},
    			resourceResolver: func(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 21:29:56 UTC 2022
    - 3.8K bytes
    - Viewed (0)
  10. pilot/pkg/bootstrap/sidecarinjector.go

    		if err != nil {
    			return nil, err
    		}
    	} else if s.kubeClient != nil {
    		configMapName := getInjectorConfigMapName(args.Revision)
    		cms := s.kubeClient.Kube().CoreV1().ConfigMaps(args.Namespace)
    		if _, err := cms.Get(context.TODO(), configMapName, metav1.GetOptions{}); err != nil {
    			if errors.IsNotFound(err) {
    				log.Infof("Skipping sidecar injector, template not found")
    				return nil, nil
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 04 20:39:38 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top