- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 197 for intVar (0.22 sec)
-
cmd/untar.go
return d.r.Read(p) } return 0, errors.New("reader closed") } func (d *disconnectReader) Close() error { d.mu.Lock() d.r = nil d.mu.Unlock() return nil } func untar(ctx context.Context, r io.Reader, putObject func(reader io.Reader, info os.FileInfo, name string) error, o untarOptions) error { bf := bufio.NewReader(r) switch f := detect(bf); f { case formatGzip:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 6K bytes - Viewed (0) -
pkg/kube/inject/app_probe.go
return nil } var probePort *intstr.IntOrString if p.HTTPGet != nil { probePort = &p.HTTPGet.Port } else { probePort = &p.TCPSocket.Port } if probePort.Type == intstr.String { port, exists := portMap[probePort.StrVal] if !exists { return nil } *probePort = intstr.FromInt32(port) } else if probePort.IntVal == targetPort { // Already is rewritten
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Aug 04 15:06:24 UTC 2023 - 8.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Protocol: "TCP", TargetPort: intstr.IntOrString{Type: intstr.Int, IntVal: 7442}, }, { Name: "tcp-8443", Port: 8443, Protocol: "TCP", TargetPort: intstr.IntOrString{Type: intstr.Int, IntVal: 7442}, }, { Name: "http-7557", Port: 7557, Protocol: "TCP", TargetPort: intstr.IntOrString{Type: intstr.Int, IntVal: 7442}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
operator/pkg/object/objects.go
isDefault := func(item any) bool { var ii intstr.IntOrString switch item := item.(type) { case int: ii = intstr.FromInt32(int32(item)) case int64: ii = intstr.FromInt32(int32(item)) case string: ii = intstr.FromString(item) default: ii = intstr.FromInt32(0) } intVal, err := intstr.GetScaledValueFromIntOrPercent(&ii, 100, false) if err != nil || intVal == 0 { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 21 07:16:46 UTC 2023 - 15.5K bytes - Viewed (1) -
platforms/core-configuration/kotlin-dsl-tooling-builders/src/crossVersionTest/groovy/org/gradle/kotlin/dsl/tooling/builders/r68/AbstractKotlinDslScriptsModelCrossVersionSpec.groovy
class AbstractKotlinDslScriptsModelCrossVersionSpec extends AbstractKotlinScriptModelCrossVersionTest { protected BuildSpec withBuildSrcAndInitScripts() { withBuildSrc() def initJar = withEmptyJar("classes_init.jar") def someInitJar = withEmptyJar("classes_some_init.jar") toolingApi.requireIsolatedUserHome() def gradleUserHomeDir = toolingApi.createExecuter().gradleUserHomeDir
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 3K bytes - Viewed (0) -
pkg/registry/networking/ingress/storage/storage_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/intstr" genericapirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/registry/generic" genericregistrytest "k8s.io/apiserver/pkg/registry/generic/testing" "k8s.io/apiserver/pkg/registry/rest"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 09:01:21 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/controller/deployment/rolling_test.go
"testing" apps "k8s.io/api/apps/v1" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/record" "k8s.io/klog/v2/ktesting" ) func TestDeploymentController_reconcileNewReplicaSet(t *testing.T) { tests := []struct { deploymentReplicas int32 maxSurge intstr.IntOrString oldReplicas int32 newReplicas int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 11K bytes - Viewed (0) -
pkg/apis/policy/validation/validation_test.go
} } func TestValidateMinAvailablePodDisruptionBudgetSpec(t *testing.T) { successCases := []intstr.IntOrString{ intstr.FromString("0%"), intstr.FromString("1%"), intstr.FromString("100%"), intstr.FromInt32(0), intstr.FromInt32(1), intstr.FromInt32(100), } for _, c := range successCases { spec := policy.PodDisruptionBudgetSpec{ MinAvailable: &c, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 20:44:13 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/kubelet/lifecycle/handlers_test.go
tests := []struct { Name string Port intstr.IntOrString ExpectError bool Expected string }{ { Name: "consistent/with port", Port: intstr.FromString("70"), Expected: "https://foo:70/bar", }, { Name: "consistent/without port", Port: intstr.FromString(""), ExpectError: true, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/validation/validation.go
tp := 0 if p == nil { continue } if p.TargetPort != nil && p.TargetPort.Type == int64(intstr.String) { // Do not validate named ports continue } if p.TargetPort != nil && p.TargetPort.Type == int64(intstr.Int) { tp = int(p.TargetPort.IntVal.GetValue()) } if tp == 0 && p.Port > 1024 { // Target port defaults to port. If its >1024, it is safe. continue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 20:02:28 UTC 2024 - 14.9K bytes - Viewed (0)