- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 2,479 for deer (0.31 sec)
-
pkg/registry/storage/volumeattachment/storage/storage_test.go
func TestDelete(t *testing.T) { storage, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope().ReturnDeletedObject() test.TestDelete(validNewVolumeAttachment("foo")) } func TestGet(t *testing.T) { storage, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 6.2K bytes - Viewed (1) -
pkg/registry/admissionregistration/validatingadmissionpolicy/storage/storage_test.go
} func TestGet(t *testing.T) { storage, server := newInsecureStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope() test.TestGet(validValidatingAdmissionPolicy()) } func TestList(t *testing.T) { storage, server := newInsecureStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 23:43:34 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/registry/storage/volumeattributesclass/storage/storage_test.go
func TestDelete(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store).ClusterScope().ReturnDeletedObject() test.TestDelete(validNewVolumeAttributesClass("foo")) } func TestGet(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 03:18:56 UTC 2023 - 4.3K bytes - Viewed (0) -
src/net/tcpsock_test.go
c, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Fatal(err) } defer c.Close() r, w, err := os.Pipe() if err != nil { t.Fatal(err) } defer r.Close() errc2 := make(chan error, 1) defer func() { if err := <-errc2; err != nil { t.Error(err) } }() defer w.Close() go func() { _, err := io.Copy(c, r) errc2 <- err }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
pkg/registry/policy/poddisruptionbudget/storage/storage_test.go
} func TestGet(t *testing.T) { storage, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestGet(validNewPodDisruptionBudget()) } func TestList(t *testing.T) { storage, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:45 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
func TestDelete(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Controller.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Controller.Store) test.TestDelete(validNewController()) } func TestGenerationNumber(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Controller.Store.DestroyFunc() modifiedSno := *validNewController()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/fake.go
} func (f *fakeResourceManager) HasExpectedNumberActions() bool { f.lock.RLock() defer f.lock.RUnlock() f.expect.lock.RLock() defer f.expect.lock.RUnlock() return len(f.Actions) >= len(f.expect.Actions) } func (f *fakeResourceManager) Validate() error { f.lock.RLock() defer f.lock.RUnlock() f.expect.lock.RLock() defer f.expect.lock.RUnlock() if !reflect.DeepEqual(f.expect.Actions, f.Actions) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage_test.go
} func TestGet(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.StatefulSet.Store.DestroyFunc() test := genericregistrytest.New(t, storage.StatefulSet.Store) test.TestGet(validNewStatefulSet()) } func TestList(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.StatefulSet.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 14K bytes - Viewed (0) -
src/log/syslog/syslog_test.go
} tr := tr t.Run(tr, func(t *testing.T) { t.Parallel() done := make(chan string) addr, sock, srvWG := startServer(t, tr, "", done) defer srvWG.Wait() defer sock.Close() if tr == "unix" || tr == "unixgram" { defer os.Remove(addr) } s, err := Dial(tr, addr, LOG_INFO|LOG_USER, "syslog_test") if err != nil { t.Fatalf("Dial() failed: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 12 16:09:24 UTC 2023 - 9.6K bytes - Viewed (0) -
src/net/splice_linux_test.go
front := newLocalListener(t, upNet) defer front.Close() back := newLocalListener(t, downNet) defer back.Close() var wg sync.WaitGroup wg.Add(2) proxy := func() { src, err := front.Accept() if err != nil { return } dst, err := Dial(downNet, back.Addr().String()) if err != nil { return } defer dst.Close() defer src.Close() go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 14.5K bytes - Viewed (0)