Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for jetStream (0.04 sec)

  1. internal/event/target/nats.go

    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    
    	if target.natsConn != nil && args.JetStream.Enable {
    		var jstream nats.JetStream
    		jstream, err = target.natsConn.JetStream()
    		if err != nil {
    			if err.Error() != nats.ErrNoServers.Error() {
    				target.loggerOnce(context.Background(), err, target.ID().String())
    			}
    			return err
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Apr 27 04:30:57 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    			PingInterval:      pingInterval,
    			QueueDir:          env.Get(queueDirEnv, kv.Get(target.NATSQueueDir)),
    			QueueLimit:        queueLimit,
    			RootCAs:           rootCAs,
    		}
    		natsArgs.JetStream.Enable = env.Get(jetStreamEnableEnv, kv.Get(target.NATSJetStream)) == config.EnableOn
    
    		streamingEnableEnv := target.EnvNATSStreaming
    		if k != config.Default {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

            }
          }
        }
      }
    
      /**
       * Returns the number of [open streams][Http2Stream.isOpen] on this connection.
       */
      fun openStreamCount(): Int = withLock { streams.size }
    
      fun getStream(id: Int): Http2Stream? = withLock { streams[id] }
    
      internal fun removeStream(streamId: Int): Http2Stream? {
        withLock {
          val stream = streams.remove(streamId)
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  4. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
    HSPLokhttp3/internal/http2/Http2Connection;->getStream(I)Lokhttp3/internal/http2/Http2Stream;
    HSPLokhttp3/internal/http2/Http2Connection;->pushedStream$okhttp(I)Z
    HSPLokhttp3/internal/http2/Http2Connection;->removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (1)
Back to top