- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 85 for ktesting (0.11 sec)
-
pkg/api/pod/util_test.go
"k8s.io/apimachinery/pkg/util/validation/field" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/features" "k8s.io/utils/pointer" ) func TestVisitContainers(t *testing.T) { setAllFeatureEnabledContainersDuringTest := ContainerType(0) testCases := []struct { desc string spec *api.PodSpec
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
} } func TestDeleteInvokesAdmissionControl(t *testing.T) { // TODO: remove mutating deny when we removed it from the endpoint implementation and ported all plugins for _, admit := range []admission.Interface{alwaysMutatingDeny{}, alwaysValidatingDeny{}} { t.Logf("Testing %T", admit) storage := map[string]rest.Storage{} simpleStorage := SimpleRESTStorage{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0) -
pkg/config/validation/validation_test.go
"istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/test/util/assert" ) const ( // Config name for testing someName = "foo" // Config namespace for testing. someNamespace = "bar" ) func TestValidateMaxServerConnectionAge(t *testing.T) { type durationCheck struct { duration time.Duration isValid bool } durMin, _ := time.ParseDuration("-30m")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 03:11:45 UTC 2024 - 196K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
rejectedPods []rejectedPod terminatingErr error prepareWorker func(t *testing.T, w *podWorkers, records map[types.UID][]syncPodRecord) wantWorker func(t *testing.T, w *podWorkers, records map[types.UID][]syncPodRecord) wantWorkerAfterRetry func(t *testing.T, w *podWorkers, records map[types.UID][]syncPodRecord) wantErr bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
import ( "context" "fmt" "reflect" "sort" "strings" "testing" "time" "github.com/google/go-cmp/cmp" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
return set } func runTestOverPVCRetentionPolicies(t *testing.T, testName string, testFn func(*testing.T, *apps.StatefulSetPersistentVolumeClaimRetentionPolicy)) { subtestName := "StatefulSetAutoDeletePVCDisabled" if testName != "" { subtestName = fmt.Sprintf("%s/%s", testName, subtestName) } t.Run(subtestName, func(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
cmd/object-handlers_test.go
func TestAPIPutObjectPartHandler(t *testing.T) { defer DetectTestLeak(t)() ExecExtendedObjectLayerAPITest(t, testAPIPutObjectPartHandler, []string{"PutObjectPart"}) } func testAPIPutObjectPartHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) { // Initiate Multipart upload for testing PutObjectPartHandler. testObject := "testobject"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
pkg/apis/apps/validation/validation_test.go
t.Run(name, func(t *testing.T) { errs := ValidateControllerRevision(&tc.history) if tc.isValid && len(errs) > 0 { t.Errorf("%v: unexpected error: %v", name, errs) } if !tc.isValid && len(errs) == 0 { t.Errorf("%v: unexpected non-error", name) } }) } } func TestValidateControllerRevisionUpdate(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 111.9K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
return nil } func (t *TestPrintHandler) getNumCalls() int { return t.numCalls } func TestAllHandlers(t *testing.T) { h := &TestPrintHandler{numCalls: 0} AddHandlers(h) if h.getNumCalls() == 0 { t.Error("TableHandler not called in AddHandlers") } } func TestPrintEvent(t *testing.T) { tests := []struct { event api.Event options printers.GenerateOptions expected []metav1.TableRow }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go
utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/component-base/metrics/testutil" "k8s.io/klog/v2" "k8s.io/utils/pointer" ) // utilities for loading JOSE keys. func loadRSAKey(t *testing.T, filepath string, alg jose.SignatureAlgorithm) *jose.JSONWebKey { return loadKey(t, filepath, alg, func(b []byte) (interface{}, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 97.7K bytes - Viewed (0)