- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,843 for lake (0.05 sec)
-
src/net/smtp/smtp_test.go
func TestClientAuthTrimSpace(t *testing.T) { server := "220 hello world\r\n" + "200 some more" var wrote strings.Builder var fake faker fake.ReadWriter = struct { io.Reader io.Writer }{ strings.NewReader(server), &wrote, } c, err := NewClient(fake, "fake.host") if err != nil { t.Fatalf("NewClient: %v", err) } c.tls = true c.didHello = true c.Auth(toServerEmptyAuth{})
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pkg/volume/fc/fc_test.go
tmpDir: utiltesting.MkTmpdirOrDie("fc_test"), } } func (fake *fakeDiskManager) Cleanup() { os.RemoveAll(fake.tmpDir) } func (fake *fakeDiskManager) MakeGlobalPDName(disk fcDisk) string { return fake.tmpDir } func (fake *fakeDiskManager) MakeGlobalVDPDName(disk fcDisk) string { return fake.tmpDir } func (fake *fakeDiskManager) AttachDisk(b fcDiskMounter) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered_test.go
backend := NewBackend(&fake.Backend{}, config).(*bufferedBackend) backend.ProcessEvents(newEvents(2)...) require.Len(t, backend.buffer, 1, "buffed contains more elements than it should") } func TestBufferedBackendShutdownWaitsForDelegatedCalls(t *testing.T) { t.Parallel() delegatedCallStartCh := make(chan struct{}) delegatedCallEndCh := make(chan struct{}) delegateBackend := &fake.Backend{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 14 17:20:35 UTC 2018 - 5.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
VolumeSource: v1.VolumeSource{ GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{ PDName: "fake-device1", }, }, }, }, }, } volumeSpec := &volume.Spec{Volume: &pod.Spec.Volumes[0]} devicePath := "fake/device/path" deviceMountPath := "fake/device/mount/path" generatedVolumeName, err := util.GetUniqueVolumeNameFromSpec(plugin, volumeSpec) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
t.Log("drop") // After leader is lost, we can take over _, stop3 := createPerRevisionElection(t, "pod2", "foo", watcher, true, client) // Other revisions are independent _, stop4 := createPerRevisionElection(t, "pod4", "not-foo", watcher, true, client) close(stop3) close(stop4) } func TestPrioritizedLeaderElection(t *testing.T) { client := fake.NewSimpleClientset() watcher := &fakeDefaultWatcher{defaultRevision: "red"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
{ name: "when two pods are using same volume and both are deleted", volumePaths: []string{ filepath.Join("pod1", "volumes", "fake-plugin", "pvc-abcdef"), filepath.Join("pod2", "volumes", "fake-plugin", "pvc-abcdef"), }, expectedVolumesNeedDevicePath: []string{"fake-plugin/pvc-abcdef", "fake-plugin/pvc-abcdef"}, expectedVolumesFailedReconstruction: []string{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/volume/nfs/nfs_test.go
if err != nil { t.Errorf("Can't find the plugin by name") } fake := mount.NewFakeMounter(nil) pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}} mounter, err := plug.(*nfsPlugin).newMounterInternal(spec, pod, fake) if err != nil { t.Errorf("Failed to make a new Mounter: %v", err) } if mounter == nil { t.Errorf("Got a nil Mounter") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 9K bytes - Viewed (0) -
cmd/kubeadm/test/resources/pods.go
staticpodutil "k8s.io/kubernetes/cmd/kubeadm/app/util/staticpod" ) // FakeStaticPod represents a fake static pod type FakeStaticPod struct { NodeName string Component string Annotations map[string]string } // Pod returns a pod structure representing the fake static pod with a // given suffix func (p *FakeStaticPod) Pod(suffix string) *v1.Pod { pod := staticpodutil.ComponentPod(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 17 14:40:46 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
return nil, fmt.Errorf("not implemented") } // PersistentVolumeClaims returns a fake PersistentVolumeClaimLister object. func (pvcs PersistentVolumeClaimLister) PersistentVolumeClaims(namespace string) corelisters.PersistentVolumeClaimNamespaceLister { ps := make([]*v1.PersistentVolumeClaim, len(pvcs)) for i := range pvcs { ps[i] = &pvcs[i] } return &persistentVolumeClaimNamespaceLister{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
defer cleanup(t, m) now := time.Now() fakePods := make([]*fakePod, numTestPods) for i := 0; i < numTestPods; i++ { fake, err := newFakePod(tt.http) if err != nil { t.Fatalf("unexpected error creating fake pod: %v", err) } defer fake.stop() handler := fake.probeHandler() fakePods[i] = fake pod := v1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0)