- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 174 for readWrite (0.29 sec)
-
pkg/kube/kclient/clienttest/direct.go
ret := make([]T, 0, items.Len()) for i := 0; i < items.Len(); i++ { itm := items.Index(i).Interface().(PT) ret = append(ret, any(&itm).(T)) } return ret } var _ kclient.ReadWriter[controllers.Object] = &directClient[controllers.Object, any, controllers.Object]{} // NewWriter returns a new client for the given type. // Any errors will call t.Fatal.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 3K bytes - Viewed (0) -
pkg/kube/kclient/interfaces.go
Patch(name, namespace string, pt apitypes.PatchType, data []byte) (T, error) // Delete removes a resource. Delete(name, namespace string) error } type ReadWriter[T controllers.Object] interface { Reader[T] Writer[T] } // Client wraps a Kubernetes client providing cached read access and direct write access. type Client[T controllers.Object] interface { Reader[T]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:09:57 UTC 2024 - 3.4K bytes - Viewed (0) -
src/bufio/bufio.go
} return n, err } // buffered input and output // ReadWriter stores pointers to a [Reader] and a [Writer]. // It implements [io.ReadWriter]. type ReadWriter struct { *Reader *Writer } // NewReadWriter allocates a new [ReadWriter] that dispatches to r and w. func NewReadWriter(r *Reader, w *Writer) *ReadWriter { return &ReadWriter{r, w}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/tpu-resource-read-for-write.mlir
%0 = "tf.ReadVariableOp"(%arg2) : (tensor<*x!tf_type.resource<tensor<i32>>>) -> tensor<i32> %1:2 = "tf_device.cluster_func"(%arg0, %arg1, %0) {_xla_compile_device_type = "TPU", _replication_info = "read_write", func = @read_write_func} : (tensor<i32>, tensor<f32>, tensor<i32>) -> (tensor<f32>, tensor<i32>) "tf.AssignVariableOp"(%arg2, %1#1) : (tensor<*x!tf_type.resource<tensor<i32>>>, tensor<i32>) -> () func.return }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 16:54:40 UTC 2024 - 5.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FilesTest.java
File file = createTempFile(); Files.write(bytes, file); Random random = new Random(); random.nextBytes(expectedBytes); // Test MappedByteBuffer map = Files.map(file, MapMode.READ_WRITE); map.put(expectedBytes); // Verify byte[] actualBytes = Files.toByteArray(file); assertTrue(Arrays.equals(expectedBytes, actualBytes)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/FilesTest.java
File file = createTempFile(); Files.write(bytes, file); Random random = new Random(); random.nextBytes(expectedBytes); // Test MappedByteBuffer map = Files.map(file, MapMode.READ_WRITE); map.put(expectedBytes); // Verify byte[] actualBytes = Files.toByteArray(file); assertTrue(Arrays.equals(expectedBytes, actualBytes)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/term/terminal.go
// historyPending. historyPending string } // NewTerminal runs a VT100 terminal on the given ReadWriter. If the ReadWriter is // a local terminal, that terminal must first have been put into raw mode. // prompt is a string that is written at the start of each input line (i.e. // "> "). func NewTerminal(c io.ReadWriter, prompt string) *Terminal { return &Terminal{ Escape: &vt100EscapeCodes, c: c,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 22 17:16:14 UTC 2022 - 22.5K bytes - Viewed (0) -
internal/http/response-recorder.go
headers bytes.Buffer body bytes.Buffer // Indicate if headers are written in the log headersLogged bool } // Hijack - hijacks the underlying connection func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) { hj, ok := lrw.ResponseWriter.(http.Hijacker) if !ok { return nil, nil, fmt.Errorf("response writer does not support hijacking. Type is %T", lrw.ResponseWriter) } return hj.Hijack() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 00:13:19 UTC 2023 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
hijacked bool } // Hijack returns a delegate "net.Conn". // An error is returned if Write(), WriteHeader(), or Hijack() was previously called. // The returned bufio.ReadWriter is always nil. func (w *tunnelingResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) { w.mu.Lock() defer w.mu.Unlock() if w.written { klog.Errorf("Hijack called after write")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
src/net/http/socks_bundle.go
// Authenticate specifies the optional authentication // function. It must be non-nil when AuthMethods is not empty. // It must return an error when the authentication is failed. Authenticate func(context.Context, io.ReadWriter, socksAuthMethod) error } // DialContext connects to the provided address on the provided // network. // // The returned error value may be a net.OpError. When the Op field of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 22:42:18 UTC 2023 - 12.9K bytes - Viewed (0)