- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 124 for measure (0.16 sec)
-
pkg/registry/core/pod/strategy_test.go
utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/apiserver/pkg/warning" "k8s.io/client-go/tools/cache" featuregatetesting "k8s.io/component-base/featuregate/testing" ptr "k8s.io/utils/ptr" apitesting "k8s.io/kubernetes/pkg/api/testing" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/kubelet/client" // ensure types are installed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
if err != nil { t.Fatalf("Watch failed: %v", err) } initSignal.Wait() } // RunOptionalTestProgressNotify tests ProgressNotify feature of ListOptions. // Given this feature is currently not explicitly used by higher layers of Kubernetes // (it rather is used by wrappers of storage.Interface to implement its functionalities) // this test is currently considered optional.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go
for _, testValue := range testValues { value := MustParse(testValue) v1 := value.DeepCopy() // ensure non-zero - zero = non-zero (suffix preserved) v1.Sub(zero) // ensure we preserved the input value if v1.String() != testValue { t.Errorf("Expected %v, actual %v", testValue, v1.String()) } // ensure zero - non-zero = -non-zero (suffix preserved) v2 := zero.DeepCopy() v2.Sub(value)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 49.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" kubetypes "k8s.io/apimachinery/pkg/types" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/sets" utilfeature "k8s.io/apiserver/pkg/util/feature" runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1" remote "k8s.io/cri-client/pkg" kubelettypes "k8s.io/kubelet/pkg/types" "k8s.io/kubernetes/pkg/features" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.sendFrame().windowUpdate(3, 5) peer.acceptFrame() // DATA STREAM 3 "fghi" peer.play() // Play it back. val connection = connect(peer) connection.writePingAndAwaitPong() // Ensure the SETTINGS have been received. val stream = connection.newStream(headerEntries("a", "android"), true) val sink = stream.getSink().buffer() sink.writeUtf8("abcdefghi") sink.flush()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
driver: "no_selinux", seLinuxLabel: "s0,c0", volumeContext: nil, enableSELinuxFeatureGate: true, expectedVolumeContext: nil, }, { name: "should not include selinux mount option, if feature gate is enabled but CSIDriver does not exist",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
{clusterIPsCheckChain, filterOutputPostDNATChain, "ct state new"}, } // ensureChain adds commands to tx to ensure that chain exists and doesn't contain // anything from before this transaction (using createdChains to ensure that we don't // Flush a chain more than once and lose *new* rules as well.) func ensureChain(chain string, tx *knftables.Transaction, createdChains sets.Set[string]) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// ensure that watchcache is synchronized up to ResourceVersion X (using Get/List requests // with NotOlderThan semantic), the further requests (even specifying earlier resource // version) will also return the result synchronized to at least ResourceVersion X. // By parallelizing test cases we ensure that the order in which test cases are defined
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener.go
// listeners for these user specified ports, we will auto generate // configs for other ports if and only if the sidecarConfig has an // egressListener on wildcard port. // // Validation will ensure that we have utmost one wildcard egress listener // occurring in the end // Add listeners based on the config in the sidecar.EgressListeners if // no Sidecar CRD is provided for this config namespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0)