Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 95 for newString (0.17 sec)

  1. staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/compatibility.go

    	return &CompatibilityTestOptions{Scheme: scheme}
    }
    
    // coreKinds includes kinds that typically only need to be tested in a single API group
    var coreKinds = sets.NewString(
    	"CreateOptions", "UpdateOptions", "PatchOptions", "DeleteOptions",
    	"GetOptions", "ListOptions", "ExportOptions",
    	"WatchEvent",
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 16:38:32 UTC 2023
    - 17.8K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/options/authorization.go

    	if len(o.Modes) == 0 {
    		allErrors = append(allErrors, fmt.Errorf("at least one authorization-mode must be passed"))
    	}
    
    	modes := sets.NewString(o.Modes...)
    	for _, mode := range o.Modes {
    		if !authzmodes.IsValidAuthorizationMode(mode) {
    			allErrors = append(allErrors, fmt.Errorf("authorization-mode %q is not a valid mode", mode))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/match_test.go

    )
    
    func TestMatching(t *testing.T) {
    	checkFTR(t, mandFTRExempt)
    	checkFTR(t, mandFTRCatchAll)
    	rngOuter := rand.New(rand.NewSource(42))
    	goodPLNames := sets.NewString("pl1", "pl2", "pl3", "pl4", "pl5")
    	badPLNames := sets.NewString("ql1", "ql2", "ql3", "ql4", "ql5")
    	for i := 0; i < 300; i++ {
    		rng := rand.New(rand.NewSource(int64(rngOuter.Uint64())))
    		t.Run(fmt.Sprintf("trial%d:", i), func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 13.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/request/requestinfo_test.go

    		}
    	}
    }
    
    func newTestRequestInfoResolver() *RequestInfoFactory {
    	return &RequestInfoFactory{
    		APIPrefixes:          sets.NewString("api", "apis"),
    		GrouplessAPIPrefixes: sets.NewString("api"),
    	}
    }
    
    func TestFieldSelectorParsing(t *testing.T) {
    	tests := []struct {
    		name         string
    		url          string
    		expectedName string
    		expectedErr  error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 15 12:19:21 UTC 2018
    - 11.3K bytes
    - Viewed (0)
  5. pkg/controller/podautoscaler/replica_calculator.go

    	missingPods = sets.NewString()
    	unreadyPods = sets.NewString()
    	ignoredPods = sets.NewString()
    	for _, pod := range pods {
    		if pod.DeletionTimestamp != nil || pod.Status.Phase == v1.PodFailed {
    			ignoredPods.Insert(pod.Name)
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  6. pkg/registry/discovery/endpointslice/strategy_test.go

    				},
    			},
    			expectedNodeNames: sets.NewString("node-1", "node-3"),
    		},
    		{
    			name: "unset",
    			endpointSlice: &discovery.EndpointSlice{
    				Endpoints: []discovery.Endpoint{
    					{DeprecatedTopology: map[string]string{"other": "value"}},
    					{DeprecatedTopology: map[string]string{"foo": "bar"}},
    					{DeprecatedTopology: nil},
    				},
    			},
    			expectedNodeNames: sets.NewString(),
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  7. pkg/apis/rbac/helpers.go

    	PolicyRule PolicyRule
    }
    
    // NewRule returns new PolicyRule made by input verbs.
    func NewRule(verbs ...string) *PolicyRuleBuilder {
    	return &PolicyRuleBuilder{
    		PolicyRule: PolicyRule{Verbs: sets.NewString(verbs...).List()},
    	}
    }
    
    // Groups combines the PolicyRule.APIGroups and input groups.
    func (r *PolicyRuleBuilder) Groups(groups ...string) *PolicyRuleBuilder {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 23 15:11:00 UTC 2020
    - 12.1K bytes
    - Viewed (0)
  8. pkg/controlplane/apiserver/config.go

    	genericConfig.OpenAPIV3Config.Info.Title = "Kubernetes"
    
    	genericConfig.LongRunningFunc = filters.BasicLongRunningRequestCheck(
    		sets.NewString("watch", "proxy"),
    		sets.NewString("attach", "exec", "proxy", "log", "portforward"),
    	)
    
    	kubeVersion := version.Get()
    	genericConfig.Version = &kubeVersion
    
    	if genericConfig.EgressSelector != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  9. pkg/controller/podgc/gc_controller.go

    func (gcc *PodGCController) gcOrphaned(ctx context.Context, pods []*v1.Pod, nodes []*v1.Node) {
    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("GC'ing orphaned")
    	existingNodeNames := sets.NewString()
    	for _, node := range nodes {
    		existingNodeNames.Insert(node.Name)
    	}
    	// Add newly found unknown nodes to quarantine
    	for _, pod := range pods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/strategy.go

    	newObjAccessor, err := meta.Accessor(obj)
    	if err != nil {
    		return allWarnings
    	}
    
    	newAdded := sets.NewString(newObjAccessor.GetFinalizers()...)
    	if old != nil {
    		oldObjAccessor, err := meta.Accessor(old)
    		if err != nil {
    			return allWarnings
    		}
    		newAdded = newAdded.Difference(sets.NewString(oldObjAccessor.GetFinalizers()...))
    	}
    
    	for _, finalizer := range newAdded.List() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 21:22:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top