- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 62 for newString (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)