Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 89 for Streaming (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. internal/s3select/jstream/README.md

    <p align="center"><img width="350px" src="jstream.png" alt="jstream"/></p>
    
    #
    
    [![GoDoc](https://godoc.org/github.com/bcicen/jstream?status.svg)](https://godoc.org/github.com/bcicen/jstream)
    
    
    `jstream` is a streaming JSON parser and value extraction library for Go.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top