Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for ResourceNames (0.21 sec)

  1. pilot/pkg/xds/delta.go

    				if wr == nil {
    					wr = &model.WatchedResource{TypeUrl: res.TypeUrl}
    				}
    				// some resources dynamically update ResourceNames. Most don't though
    				if newResourceNames != nil {
    					wr.ResourceNames = newResourceNames
    				}
    				wr.NonceSent = res.Nonce
    				if features.EnableUnsafeDeltaTest {
    					wr.LastResources = applyDelta(wr.LastResources, res)
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. security/pkg/nodeagent/sds/sdsservice.go

    			}
    
    			return nil
    		})
    	}()
    
    	return ret
    }
    
    var version uberatomic.Uint64
    
    func (s *sdsservice) generate(resourceNames []string) (*discovery.DiscoveryResponse, error) {
    	resources := xds.Resources{}
    	for _, resourceName := range resourceNames {
    		secret, err := s.st.GenerateSecret(resourceName)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 25 00:20:04 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. pkg/xds/server.go

    	var previousResources []string
    	var alwaysRespond bool
    	w.UpdateWatchedResource(request.TypeUrl, func(wr *WatchedResource) *WatchedResource {
    		previousResources = wr.ResourceNames
    		wr.NonceAcked = request.ResponseNonce
    		wr.ResourceNames = request.ResourceNames
    		alwaysRespond = wr.AlwaysRespond
    		wr.AlwaysRespond = false
    		return wr
    	})
    
    	// Envoy can send two DiscoveryRequests with same version and nonce.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  4. pilot/pkg/xds/sds_test.go

    			}
    			cc.Fake.Unlock()
    
    			gen := s.Discovery.Generators[v3.SecretType]
    			tt.request.Start = time.Now()
    			secrets, _, _ := gen.Generate(s.SetupProxy(tt.proxy), &model.WatchedResource{ResourceNames: tt.resources}, tt.request)
    			raw := xdstest.ExtractTLSSecrets(t, xdsserver.ResourcesToAny(secrets))
    
    			got := map[string]Expected{}
    			for _, scrt := range raw {
    				got[scrt.Name] = Expected{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/rbac/v1/types.go

    	Resources []string `json:"resources,omitempty" protobuf:"bytes,3,rep,name=resources"`
    	// ResourceNames is an optional white list of names that the rule applies to.  An empty set means that everything is allowed.
    	// +optional
    	// +listType=atomic
    	ResourceNames []string `json:"resourceNames,omitempty" protobuf:"bytes,4,rep,name=resourceNames"`
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/authorization/v1/types.go

    	Resources []string `json:"resources,omitempty" protobuf:"bytes,3,rep,name=resources"`
    	// ResourceNames is an optional white list of names that the rule applies to.  An empty set means that everything is allowed.  "*" means all.
    	// +optional
    	// +listType=atomic
    	ResourceNames []string `json:"resourceNames,omitempty" protobuf:"bytes,4,rep,name=resourceNames"`
    }
    
    // NonResourceRule holds information that describes a rule for the non-resource
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	}
    	pathsToIgnore := openapiutil.NewTrie(s.openAPIV3Config.IgnorePrefixes)
    	resourceNames := make([]string, 0)
    	for _, apiGroupInfo := range apiGroupInfos {
    		groupResources, err := getResourceNamesForGroup(apiPrefix, apiGroupInfo, pathsToIgnore)
    		if err != nil {
    			return nil, err
    		}
    		resourceNames = append(resourceNames, groupResources...)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  8. samples/addons/kiali.yaml

      - routes
      verbs:
      - get
    - apiGroups: ["authentication.k8s.io"]
      resources:
      - tokenreviews
      verbs:
      - create
    - apiGroups: ["oauth.openshift.io"]
      resources:
      - oauthclients
      resourceNames:
      - kiali-istio-system
      verbs:
      - get
    ...
    ---
    # Source: kiali-server/templates/rolebinding.yaml
    apiVersion: rbac.authorization.k8s.io/v1
    kind: ClusterRoleBinding
    metadata:
      name: kiali
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:57:35 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. pilot/pkg/xds/eds.go

    		edsUpdatedServices = model.ConfigNamesOfKind(req.ConfigsUpdated, kind.ServiceEntry)
    	}
    	var resources model.Resources
    	empty := 0
    	cached := 0
    	regenerated := 0
    	for _, clusterName := range w.ResourceNames {
    		if edsUpdatedServices != nil {
    			if _, ok := edsUpdatedServices[model.ParseSubsetKeyHostname(clusterName)]; !ok {
    				// Cluster was not updated, skip recomputing. This happens when we get an incremental update for a
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. pilot/pkg/xds/bench_test.go

    		}
    		return &model.WatchedResource{ResourceNames: watchedResources}
    	case v3.RouteType:
    		l := s.ConfigGen.BuildListeners(proxy, s.PushContext())
    		routeNames := xdstest.ExtractRoutesFromListeners(l)
    		return &model.WatchedResource{ResourceNames: routeNames}
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 22 18:13:40 UTC 2024
    - 19.7K bytes
    - Viewed (0)
Back to top