Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for Streaming (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelSourceTransformer.java

     */
    package org.apache.maven.model.building;
    
    import java.nio.file.Path;
    
    import org.apache.maven.model.Model;
    
    /**
     * The ModelSourceTransformer is a way to transform the local pom while streaming the input.
     *
     * The {@link #transform(Path, TransformerContext, Model)} method uses a Path on purpose, to ensure the
     * local pom is the original source.
     *
     * @since 4.0.0
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/middleware.md

    ## `GZipMiddleware`
    
    Handles GZip responses for any request that includes `"gzip"` in the `Accept-Encoding` header.
    
    The middleware will handle both standard and streaming responses.
    
    {* ../../docs_src/advanced_middleware/tutorial003.py hl[2,6] *}
    
    The following arguments are supported:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 16:45:50 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. docs/de/docs/advanced/middleware.md

    ## `GZipMiddleware`
    
    Verarbeitet GZip-Responses für alle Requests, die `"gzip"` im `Accept-Encoding`-Header enthalten.
    
    Diese Middleware verarbeitet sowohl Standard- als auch Streaming-Responses.
    
    ```Python hl_lines="2  6"
    {!../../docs_src/advanced_middleware/tutorial003.py!}
    ```
    
    Die folgenden Argumente werden unterstützt:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.3K 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. guava/src/com/google/common/net/MediaType.java

       * Powerpoint</a> presentations.
       */
      public static final MediaType MICROSOFT_POWERPOINT =
          createConstant(APPLICATION_TYPE, "vnd.ms-powerpoint");
    
      /**
       * <a
       * href="https://learn.microsoft.com/en-us/archive/blogs/vsofficedeveloper/office-2007-file-format-mime-types-for-http-content-streaming-2">Microsoft
       * Word</a> documents.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Sep 26 19:15:09 UTC 2024
    - 47.5K bytes
    - Viewed (0)
  9. 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)
  10. docs/pt/docs/advanced/middleware.md

    ## `GZipMiddleware`
    
    Gerencia respostas GZip para qualquer requisição que inclua `"gzip"` no cabeçalho `Accept-Encoding`.
    
    O middleware lidará com respostas padrão e de streaming.
    
    {* ../../docs_src/advanced_middleware/tutorial003.py hl[2,6] *}
    
    Os seguintes argumentos são suportados:
    
    * `minimum_size` - Não comprima respostas menores que este tamanho mínimo em bytes. O padrão é `500`.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 30 20:00:22 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top