- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ioHandler (0.13 sec)
-
pkg/volume/fc/fc.go
wwns []string lun string wwids []string plugin *fcPlugin // Utility interface that provides API calls to the provider to attach/detach disks. manager diskManager // io handler interface io ioHandler volume.MetricsNil } func (fc *fcDisk) GetPath() string { // safe to use PodVolumeDir now: volume teardown occurs before pod is cleaned up
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/testing/testing.go
} return pv, nil } var _ volumepathhandler.BlockVolumePathHandler = &FakeVolumePathHandler{} // NewDeviceHandler Create a new IoHandler implementation func NewBlockVolumePathHandler() volumepathhandler.BlockVolumePathHandler { return &FakeVolumePathHandler{} } type FakeVolumePathHandler struct { sync.RWMutex }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
src/net/http/transport_test.go
retry := true for retry && !t.Failed() { var srvWG sync.WaitGroup inHandler := make(chan bool, 1) mux := NewServeMux() mux.HandleFunc("/fast", func(w ResponseWriter, r *Request) { inHandler <- true srvWG.Done() }) mux.HandleFunc("/slow", func(w ResponseWriter, r *Request) { inHandler <- true <-r.Context().Done() srvWG.Done() })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/http/serve_test.go
} func testServerRequestContextCancel_ConnClose(t *testing.T, mode testMode) { inHandler := make(chan struct{}) handlerDone := make(chan struct{}) ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { close(inHandler) <-r.Context().Done() close(handlerDone) })).ts c, err := net.Dial("tcp", ts.Listener.Addr().String())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0)