- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 89 for Streaming (0.06 sec)
-
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
xhttp "github.com/minio/minio/internal/http" ) // Streaming AWS Signature Version '4' constants. const ( emptySHA256 = "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855" streamingContentSHA256 = "STREAMING-AWS4-HMAC-SHA256-PAYLOAD" streamingContentSHA256Trailer = "STREAMING-AWS4-HMAC-SHA256-PAYLOAD-TRAILER" signV4ChunkedAlgorithm = "AWS4-HMAC-SHA256-PAYLOAD"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
internal/event/target/nats.go
connOpts := []stan.Option{stan.NatsURL(addressURL)} if n.Streaming.MaxPubAcksInflight > 0 { connOpts = append(connOpts, stan.MaxPubAcksInflight(n.Streaming.MaxPubAcksInflight)) } if n.UserCredentials != "" { connOpts = append(connOpts, stan.NatsOptions(nats.UserCredentials(n.UserCredentials))) } return stan.Connect(n.Streaming.ClusterID, clientID, connOpts...) } // NATSTarget - NATS target.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 12.9K 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" lines, # de-duplicate, # and print the last word from each awk '/Streaming build results to/ {print $NF}' "$TFCI_OUTPUT_DIR/script.log" | uniq } # Print out any ResultStore URLs for Bazel invocations' results.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Aug 07 23:01:25 UTC 2024 - 1.8K bytes - Viewed (0) -
internal/s3select/jstream/README.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/handler-utils.go
// parameter for a streaming signature which is set // to a custom value for example: "aws-chunked,gzip". metadata[strings.ToLower(xhttp.ContentEncoding)] = contentEncoding } else { // Trimmed content encoding is empty when the header // value is set to "aws-chunked" only. // Make sure to delete the content-encoding parameter // for a streaming signature which is set to value
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
internal/config/notify/legacy.go
Key: target.NATSStreaming, Value: func() string { if cfg.Streaming.Enable { return config.EnableOn } return config.EnableOff }(), }, config.KV{ Key: target.NATSStreamingClusterID, Value: cfg.Streaming.ClusterID, }, config.KV{ Key: target.NATSStreamingAsync, Value: config.FormatBool(cfg.Streaming.Async), }, config.KV{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/grid/handlers.go
func setSubroute(ctx context.Context, s string) context.Context { //nolint:staticcheck // SA1029 Staticcheck is drunk. return context.WithValue(ctx, ctxSubrouteKey{}, s) } // StreamTypeHandler is a type safe handler for streaming requests. type StreamTypeHandler[Payload, Req, Resp RoundTripper] struct { WithPayload bool // Override the default capacities (1) OutCapacity int // Set to 0 if no input is expected.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 27.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineProcessor.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.IOException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A callback to be used with the streaming {@code readLines} methods. * * <p>{@link #processLine} will be called for each line that is read, and should return {@code * false} when you want to stop processing. * * @author Miles Barr * @since 1.0 */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 1.7K bytes - Viewed (0)