- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 348 for spreading (0.23 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
See the License for the specific language governing permissions and limitations under the License. */ // Package streaming implements encoder and decoder for streams // of runtime.Objects over io.Writer/Readers. package streaming import ( "bytes" "fmt" "io" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
cmd/bitrot-streaming.go
} // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation. // The output is written to the supplied writer w. func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer { return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}} } // Returns streaming bitrot writer implementation.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
err error debug bool } func (cr *s3UnsignedChunkedReader) Close() (err error) { return cr.err } // Read - implements `io.Reader`, which transparently decodes // the incoming AWS Signature V4 streaming signature. func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) { // First, if there is any unread data, copy it to the client // provided buffer. if cr.offset > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
cmd/streaming-signature-v4_test.go
Harshavardhana <******@****.***> 1618774873 -0700
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsentity/BsElevateWord.java
this.permissions = value; } public String getReading() { checkSpecifiedProperty("reading"); return convertEmptyToNull(reading); } public void setReading(String value) { registerModifiedProperty("reading"); this.reading = value; } public String getSuggestWord() { checkSpecifiedProperty("suggestWord");
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.1K bytes - Viewed (0) -
ci/official/utilities/cleanup_summary.sh
can view more detailed results that are probably easier to read than this log. Try the links below: EOF # Find any "Streaming build results to" line, then print the last word in it, # and don't print duplicates awk '/Streaming build results to/ {print $NF}' "$TFCI_OUTPUT_DIR/script.log" | uniq } # Print out any ResultStore URLs for Bazel invocations' results.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Nov 08 17:50:27 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/StreamFailureHandler.java
*/ package org.gradle.internal.remote.internal.hub; /** * A handler for messages that fail while streaming to the peer, either on the sending side or on the receiving side */ public interface StreamFailureHandler { /** * Called when notification of a streaming failure is received on an incoming channel. */ void handleStreamFailure(Throwable t);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 984 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/negotiation/negotiate.go
} // NegotiateInputSerializer returns the input serializer for the provided request. func NegotiateInputSerializer(req *http.Request, streaming bool, ns runtime.NegotiatedSerializer) (runtime.SerializerInfo, error) { mediaType := req.Header.Get("Content-Type") return NegotiateInputSerializerForMediaType(mediaType, streaming, ns) } // NegotiateInputSerializerForMediaType returns the appropriate serializer for the given media type or an error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 10 10:53:34 UTC 2019 - 9.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/tests/mark_functions_noinline.mlir
// RUN: tf-quant-opt %s -mark-functions-noinline='noinline-functions=noinline0' \ // RUN: -allow-unregistered-dialect -mlir-disable-threading \ // RUN: -split-input-file -verify-diagnostics | FileCheck %s // Tests that the function is marked tf._noinline = true. // CHECK-LABEL: @noinline0 // CHECK-SAME: attributes {{{.*tf._noinline = true.*}}} func.func @noinline0() -> (tensor<0xf32>) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jan 12 00:02:46 UTC 2023 - 841 bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/doc.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ // Package httpstream adds multiplexed streaming support to HTTP requests and // responses via connection upgrades.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 20:10:42 UTC 2017 - 758 bytes - Viewed (0)