- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for lake (0.19 sec)
-
pkg/printers/internalversion/printers_test.go
ObjectMeta: metav1.ObjectMeta{Name: "pod-template-2"}, Spec: api.PodSpec{ Containers: []api.Container{ { Name: "fake-container1", Image: "fake-image1", }, { Name: "fake-container2", Image: "fake-image2", }, }, }, }, }, options: printers.GenerateOptions{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
Clientset: fake.NewSimpleClientset(&v1.PodList{Items: []v1.Pod{*testutil.NewPod("pod0", "node0")}}), }, fakeGetPodsAssignedToNode: func(c *fake.Clientset) func(string) ([]*v1.Pod, error) { i := 0 f := fakeGetPodsAssignedToNode(c) return func(nodeName string) ([]*v1.Pod, error) { i++ if i == 1 { return nil, fmt.Errorf("fake error") } return f(nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} func TestStatefulSetControlRollingUpdateWithMaxUnavailableInOrderedModeVerifyInvariant(t *testing.T) { // Make all pods in statefulset unavailable one by one // and verify that RollingUpdate doesnt proceed with maxUnavailable set // this could have been a simple loop, keeping it like this to be able // to add more params here. testCases := []struct { ordinalOfPodToTerminate []int }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
"k8s.io/apimachinery/pkg/util/strategicpatch" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/rest" core "k8s.io/client-go/testing" "k8s.io/component-base/version" kubeletapis "k8s.io/kubelet/pkg/apis" cadvisortest "k8s.io/kubernetes/pkg/kubelet/cadvisor/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
{ Name: "fake/fake-device", DevicePath: "fake/path", }, }, }, }, }, } kubelet.recorder = fakeRecorder if err := kubelet.setupDataDirs(); err != nil { t.Fatalf("can't initialize kubelet data dirs: %v", err) } kubelet.daemonEndpoints = &v1.NodeDaemonEndpoints{} kubelet.cadvisor = &cadvisortest.Fake{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
src/net/http/transport_test.go
tr := c.Transport.(*Transport) dialStarted := make(chan struct{}) stallDial := make(chan struct{}) tr.Dial = func(network, addr string) (net.Conn, error) { dialStarted <- struct{}{} <-stallDial return net.Dial(network, addr) } tr.DisableKeepAlives = true tr.MaxConnsPerHost = 1 preDial := make(chan struct{}) reqComplete := make(chan struct{}) doReq := func(reqId string) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
initialNodeNumber = 1000 initialPodNumber = 500 waitSchedulingPodNumber = 200 deleteNodeNumberPerRound = 20 createPodNumberPerRound = 50 fakeSchedulerName = "fake-scheduler" fakeNamespace = "fake-namespace" initialNodes []runtime.Object initialPods []runtime.Object ) for i := 0; i < initialNodeNumber; i++ { nodeName := fmt.Sprintf("node%d", i)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
nodeStore cache.Store fakeRecorder *record.FakeRecorder } func newTestController(ctx context.Context, initialObjects ...runtime.Object) (*daemonSetsController, *fakePodControl, *fake.Clientset, error) { clientset := fake.NewSimpleClientset(initialObjects...) informerFactory := informers.NewSharedInformerFactory(clientset, controller.NoResyncPeriodFunc()) dsc, err := NewDaemonSetsController( ctx,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// CGO_CPPFLAGS, CGO_CPPFLAGS_ALLOW, CGO_CPPFLAGS_DISALLOW // Like CGO_CFLAGS, CGO_CFLAGS_ALLOW, and CGO_CFLAGS_DISALLOW, // but for the C preprocessor. // CGO_CXXFLAGS, CGO_CXXFLAGS_ALLOW, CGO_CXXFLAGS_DISALLOW // Like CGO_CFLAGS, CGO_CFLAGS_ALLOW, and CGO_CFLAGS_DISALLOW, // but for the C++ compiler. // CGO_FFLAGS, CGO_FFLAGS_ALLOW, CGO_FFLAGS_DISALLOW // Like CGO_CFLAGS, CGO_CFLAGS_ALLOW, and CGO_CFLAGS_DISALLOW,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
manager.podStoreSynced = alwaysReady manager.jobStoreSynced = alwaysReady var testJob batch.Job received := make(chan struct{}) // The update sent through the fakeWatcher should make its way into the workqueue, // and eventually into the syncHandler. manager.syncHandler = func(ctx context.Context, key string) error { defer close(received) ns, name, err := cache.SplitMetaNamespaceKey(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)