- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for ResourceNames (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)