- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 62 for newString (0.2 sec)
-
pkg/registry/discovery/endpointslice/strategy.go
return nil } var names sets.String for _, ep := range eps.Endpoints { if nodeName, ok := ep.DeprecatedTopology[corev1.LabelHostname]; ok && len(nodeName) > 0 { if names == nil { names = sets.NewString() } names.Insert(nodeName) } } return names } // warnOnDeprecatedAddressType returns a warning for endpointslices with FQDN AddressType
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 10:00:01 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/validator.go
allErrs = append(allErrs, a.ValidateScaleSpec(ctx, obj, scale)...) allErrs = append(allErrs, a.ValidateScaleStatus(ctx, obj, scale)...) return allErrs } var standardFinalizers = sets.NewString( metav1.FinalizerOrphanDependents, metav1.FinalizerDeleteDependents, string(corev1.FinalizerKubernetes), ) func validateKubeFinalizerName(stringValue string, fldPath *field.Path) []string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 14:00:05 UTC 2024 - 7.4K bytes - Viewed (0) -
src/cmd/compile/internal/coverage/cover.go
pkIdNode := ir.NewInt(base.Pos, int64(pkid)) cmodeNode := ir.NewInt(base.Pos, int64(cnames.CounterMode)) cgranNode := ir.NewInt(base.Pos, int64(cnames.CounterGran)) pkPathNode := ir.NewString(base.Pos, base.Ctxt.Pkgpath) callx := typecheck.Call(pos, fn, []ir.Node{mdauspx, lenx, hashx, pkPathNode, pkIdNode, cmodeNode, cgranNode}, false) assign := callx if pkid == coverage.NotHardCoded {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 21:55:46 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/config.go
"k8s.io/utils/path" "sigs.k8s.io/yaml" ) var cfgScheme = runtime.NewScheme() // validEgressSelectorNames contains the set of valid egress selctor names. var validEgressSelectorNames = sets.NewString("controlplane", "cluster", "etcd") func init() { install.Install(cfgScheme) } // ReadEgressSelectorConfiguration reads the egress selector configuration at the specified path.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 8.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker.go
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/klog/v2" ) // readOnlyVerbs contains verbs for read-only requests. var readOnlyVerbs = sets.NewString("get", "list", "watch", "proxy") // watchIdentifier identifies group of watches that are similar. // As described in the "Priority and Fairness" KEP, we consider // watches similar if they have the same resourceType, namespace
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/errors/errors.go
func (agg aggregate) Error() string { if len(agg) == 0 { // This should never happen, really. return "" } if len(agg) == 1 { return agg[0].Error() } seenerrs := sets.NewString() result := "" agg.visit(func(err error) bool { msg := err.Error() if seenerrs.Has(msg) { return false } seenerrs.Insert(msg) if len(seenerrs) > 1 { result += ", " }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 29 09:44:02 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/apis/storagemigration/validation/validation.go
} return allErrs } func validateCondition(condition storagemigration.MigrationCondition, fldPath *field.Path) field.ErrorList { var allErrs field.ErrorList var validConditionStatuses = sets.NewString(string(metav1.ConditionTrue), string(metav1.ConditionFalse), string(metav1.ConditionUnknown)) // type is set and is a valid format
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/resources.go
results = append(results, k) } } return results } // ToSet takes a list of resource names and converts to a string set func ToSet(resourceNames []corev1.ResourceName) sets.String { result := sets.NewString() for _, resourceName := range resourceNames { result.Insert(string(resourceName)) } return result } // CalculateUsage calculates and returns the requested ResourceList usage.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 06 23:11:22 UTC 2021 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
) // Register registers a plugin func Register(plugins *admission.Plugins) { plugins.Register(PluginName, func(config io.Reader) (admission.Interface, error) { return NewLifecycle(sets.NewString(metav1.NamespaceDefault, metav1.NamespaceSystem, metav1.NamespacePublic)) }) } // Lifecycle is an implementation of admission.Interface. // It enforces life-cycle constraints around a Namespace depending on its Phase
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 8.6K bytes - Viewed (0) -
pkg/credentialprovider/keyring.go
key = parsed.Host + effectivePath } else { key = parsed.Host } dk.creds[key] = append(dk.creds[key], creds) dk.index = append(dk.index, key) } eliminateDupes := sets.NewString(dk.index...) dk.index = eliminateDupes.List() // Update the index used to identify which credentials to use for a given // image. The index is reverse-sorted so more specific paths are matched
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.2K bytes - Viewed (0)