Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 62 for newString (0.2 sec)

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