- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for Streaming (0.21 sec)
-
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) -
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) -
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) -
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) -
docs/en/docs/advanced/middleware.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 16:45:50 UTC 2024 - 4K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)