- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for tc (0.02 sec)
-
pkg/registry/core/pod/storage/eviction_test.go
pod := validNewPod() pod.Name = tc.podName pod.Labels = map[string]string{"a": "true"} pod.Spec.NodeName = "foo" if tc.podPhase != "" { pod.Status.Phase = tc.podPhase } if tc.podTerminating { currentTime := metav1.Now() pod.ObjectMeta.DeletionTimestamp = ¤tTime } // Setup pod condition if tc.prc != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
tcp: &tcp.TcpProxy{}, class: networking.ListenerClassSidecarInbound, expected: &tcp.TcpProxy{}, }, } for _, tc := range cases { t.Run(tc.name, func(t *testing.T) { b.setTCPAccessLog(tc.push, tc.proxy, tc.tcp, tc.class, nil) assert.Equal(t, tc.expected, tc.tcp) }) } } func TestSetHttpAccessLog(t *testing.T) { b := newAccessLogBuilder() env := newTestEnviroment()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
}, } for name, tc := range testCases { t.Run(name, func(t *testing.T) { fakeClock := clocktesting.NewFakeClock(tc.currentTime.Truncate(time.Second)) d := tc.backoffRecord.getRemainingTime(fakeClock, tc.defaultBackoff, tc.maxBackoff) if d.Seconds() != tc.wantDuration.Seconds() { t.Errorf("Expected value of duration %v; got %v", tc.wantDuration, d) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
new: []string{"v1/set/bob", "v1/pod/foo"}, changed: false, }, } for _, tc := range testCases { if ownerRefsChanged(toRefs(tc.orig), toRefs(tc.new)) != tc.changed { t.Errorf("Expected change=%t but got %t for %v vs %v", tc.changed, !tc.changed, tc.orig, tc.new) } } } func TestGetParentNameAndOrdinal(t *testing.T) { set := newStatefulSet(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
fakePodControl := controller.FakePodControl{Err: tc.podControllerError, CreateLimit: tc.podLimit} manager.podControl = &fakePodControl manager.podStoreSynced = alwaysReady manager.jobStoreSynced = alwaysReady // job & pods setup job := newJob(tc.parallelism, tc.completions, tc.backoffLimit, tc.completionMode) job.Spec.Suspend = ptr.To(tc.suspend) if tc.jobPodReplacementPolicy {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/types_test.go
cfg: &ClusterConfiguration{}, expectedResult: "", }, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { if result := tc.cfg.EncryptionAlgorithmType(); result != tc.expectedResult { t.Errorf("expected result: %s, got: %s", tc.expectedResult, result) } }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 09:39:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging_test.go
}, }, }, }, }, } { t.Run(tc.name, func(t *testing.T) { got := buildOpenTelemetryAccessLogConfig(tc.logName, tc.hostname, tc.clusterName, tc.body, tc.labels) assert.Equal(t, tc.expected, got) }) } } func TestTelemetryAccessLogExhaustiveness(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 54K bytes - Viewed (0) -
cmd/generic-handlers.go
if r.Method == http.MethodHead { if ok { tc.FuncName = "handler.ValidRequest" tc.ResponseRecorder.LogErrBody = false } defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) writeErrorResponseHeadersOnly(w, errorCodes.ToAPIErr(ErrInsecureSSECustomerRequest)) } else { if ok { tc.FuncName = "handler.ValidRequest" tc.ResponseRecorder.LogErrBody = true }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 01:01:15 UTC 2024 - 20.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
}, } for name, tc := range testcases { t.Run(name, func(t *testing.T) { logger, ctx := ktesting.NewTestContext(t) p, err := New(ctx, nil, nil, feature.Features{}) if err != nil { t.Fatalf("Creating plugin: %v", err) } actualHint, err := p.(*SchedulingGates).isSchedulableAfterPodChange(logger, tc.pod, tc.oldObj, tc.newObj) if tc.expectedErr { require.Error(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
t.Fatalf("Unexpected success") } // verify the results if tc.expectAnnotation != "" { out := obj.(*example.Pod) if v, found := out.Annotations[tc.expectAnnotation]; !found { t.Errorf("Expected annotation %q not found", tc.expectAnnotation) } else if v != "true" { t.Errorf("Expected annotation %q has wrong value: %q", tc.expectAnnotation, v) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0)