- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 95 for newString (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)