Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for Streaming (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        carrier.cancel()
      }
    
      /**
       * Prepares the HTTP headers and sends them to the server.
       *
       * For streaming requests with a body, headers must be prepared **before** the output stream has
       * been written to. Otherwise the body would need to be buffered!
       *
       * For non-streaming requests with a body, headers must be prepared **after** the output stream
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. internal/config/notify/help.go

    			Description: queueLimitComment,
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         target.NATSStreaming,
    			Description: "[DEPRECATED] set to 'on', to use streaming NATS server",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.NATSStreamingAsync,
    			Description: "[DEPRECATED] set to 'on', to enable asynchronous publish",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  8. docs/logging/README.md

        "Content-Length": "401",
        "Content-Type": "application/octet-stream",
        "User-Agent": "MinIO (linux; amd64) minio-go/v7.0.70 mc/RELEASE.2024-04-30T17-44-48Z",
        "X-Amz-Content-Sha256": "STREAMING-AWS4-HMAC-SHA256-PAYLOAD",
        "X-Amz-Date": "20240509T073810Z",
        "X-Amz-Decoded-Content-Length": "228"
      },
      "responseHeader": {
        "Accept-Ranges": "bytes",
        "Content-Length": "0",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 17:15:03 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. ci/official/utilities/extract_resultstore_links.py

    import os
    import re
    from typing import Dict, Union
    import xml.etree.ElementTree as ElemTree
    
    
    ResultDictType = Dict[str, Dict[str, Union[str, int]]]
    
    RESULT_STORE_LINK_RE = re.compile(
        r'^INFO: Streaming build results to: (https://[\w./\-]+)')
    FAILED_BUILD_LINE = 'FAILED: Build did NOT complete successfully'
    BUILD_STATUS_LINE = 'INFO: Build'
    TESTS_FAILED_RE = re.compile(r'^INFO: Build completed, \d+ tests? FAILED')
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Nov 08 17:50:27 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  10. internal/config/notify/parse.go

    				clusterIDEnv = clusterIDEnv + config.Default + k
    			}
    			natsArgs.Streaming.Enable = streamingEnabled
    			natsArgs.Streaming.ClusterID = env.Get(clusterIDEnv, kv.Get(target.NATSStreamingClusterID))
    			natsArgs.Streaming.Async = env.Get(asyncEnv, kv.Get(target.NATSStreamingAsync)) == config.EnableOn
    			natsArgs.Streaming.MaxPubAcksInflight = maxPubAcksInflight
    		}
    
    		if err = natsArgs.Validate(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
Back to top