Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 62 for newString (0.22 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/sets/string.go

    //
    // Deprecated: use generic Set instead.
    // new ways:
    // s1 := Set[string]{}
    // s2 := New[string]()
    type String map[string]Empty
    
    // NewString creates a String from a list of values.
    func NewString(items ...string) String {
    	return String(New[string](items...))
    }
    
    // StringKeySet creates a String from a keys of a map[string](? extends interface{}).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 20 03:47:18 UTC 2022
    - 4K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/pkginit/initAsanGlobals.go

    		// asanName = symbol's linkname + "\000"
    		// globals[i].name = (*defString)(unsafe.Pointer(&asanName)).data
    		name := g.Linksym().Name
    		init.Append(typecheck.Stmt(ir.NewAssignStmt(base.Pos, asanName, ir.NewString(base.Pos, name+"\000"))))
    		c = tconv(typecheck.NodAddr(asanName), types.Types[types.TUNSAFEPTR])
    		c = tconv(c, types.NewPtr(defStringstruct))
    		c = ir.NewSelectorExpr(base.Pos, ir.ODOT, c, lname("data"))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 17 19:36:24 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  3. pkg/kubeapiserver/authorizer/modes/modes.go

    // IsValidAuthorizationMode returns true if the given authorization mode is a valid one for the apiserver
    func IsValidAuthorizationMode(authzMode string) bool {
    	return sets.NewString(AuthorizationModeChoices...).Has(authzMode)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 05 01:22:41 UTC 2018
    - 1.6K bytes
    - Viewed (0)
  4. cmd/kube-controller-manager/app/controllermanager_test.go

    			t.Errorf("name consistency check failed: controller %q must have \"-controller\" suffix", name)
    		}
    	}
    }
    
    func TestControllerNamesDeclaration(t *testing.T) {
    	declaredControllers := sets.NewString(
    		names.ServiceAccountTokenController,
    		names.EndpointsController,
    		names.EndpointSliceController,
    		names.EndpointSliceMirroringController,
    		names.ReplicationControllerController,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. pkg/apis/discovery/validation/validation.go

    	"k8s.io/kubernetes/pkg/apis/discovery"
    )
    
    var (
    	supportedAddressTypes = sets.NewString(
    		string(discovery.AddressTypeIPv4),
    		string(discovery.AddressTypeIPv6),
    		string(discovery.AddressTypeFQDN),
    	)
    	supportedPortProtocols = sets.NewString(
    		string(api.ProtocolTCP),
    		string(api.ProtocolUDP),
    		string(api.ProtocolSCTP),
    	)
    	maxTopologyLabels = 16
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 18 08:49:15 UTC 2021
    - 7.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/filters/webhook_duration.go

    import (
    	"context"
    	"net/http"
    	"time"
    
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/apiserver/pkg/endpoints/request"
    	"k8s.io/apiserver/pkg/endpoints/responsewriter"
    )
    
    var (
    	watchVerbs = sets.NewString("watch")
    )
    
    // WithLatencyTrackers adds a LatencyTrackers instance to the
    // context associated with a request so that we can measure latency
    // incurred in various components within the apiserver.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 21:12:12 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/cli-runtime/pkg/printers/jsonpath_test.go

    				Ports:     []v1.EndpointPort{{Port: 8080}},
    			}}},
    	}
    
    	// Set of strings representing objects that should produce an error.
    	expectedErrors := sets.NewString("emptyPodList", "nonEmptyPodList", "endpoints")
    
    	for oName, obj := range objects {
    		b := &bytes.Buffer{}
    		if err := jsonpathPrinter.PrintObj(obj, b); err != nil {
    			if expectedErrors.Has(oName) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 15 21:58:20 UTC 2020
    - 2.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/root_test.go

    	return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    		ctx := req.Context()
    		resolver := &request.RequestInfoFactory{
    			APIPrefixes:          sets.NewString("api", "apis"),
    			GrouplessAPIPrefixes: sets.NewString("api"),
    		}
    		info, err := resolver.NewRequestInfo(req)
    		if err == nil {
    			ctx = request.WithRequestInfo(ctx, info)
    		}
    		req = req.WithContext(ctx)
    		handler.ServeHTTP(w, req)
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 08 22:33:50 UTC 2018
    - 6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/authorization/path/path.go

    // Each path is either a fully matching path or it ends in * in case a prefix match is done. A leading / is optional.
    func NewAuthorizer(alwaysAllowPaths []string) (authorizer.Authorizer, error) {
    	var prefixes []string
    	paths := sets.NewString()
    	for _, p := range alwaysAllowPaths {
    		p = strings.TrimPrefix(p, "/")
    		if len(p) == 0 {
    			// matches "/"
    			paths.Insert(p)
    			continue
    		}
    		if strings.ContainsRune(p[:len(p)-1], '*') {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 09 13:47:19 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/deleted_kinds.go

    	versionsToRemove := sets.NewString()
    	for apiVersion := range sets.StringKeySet(versionedResourcesStorageMap) {
    		versionToResource := versionedResourcesStorageMap[apiVersion]
    		resourcesToRemove := sets.NewString()
    		for resourceName, resourceServingInfo := range versionToResource {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 16 03:02:49 UTC 2022
    - 7.6K bytes
    - Viewed (0)
Back to top