Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 55 for jetstream (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/target/nats.go

    		}
    		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
    		}
    		target.jstream = jstream
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  2. internal/config/notify/help.go

    			Description: "client cert key for NATS mTLS auth",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NATSJetStream,
    			Description: "enable JetStream support",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.NATSQueueDir,
    			Description: queueDirComment,
    			Optional:    true,
    			Type:        "path",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          stream!!.receiveHeaders(headerBlock.toHeaders(), inFinished)
        }
    
        override fun rstStream(
          streamId: Int,
          errorCode: ErrorCode,
        ) {
          if (pushedStream(streamId)) {
            pushResetLater(streamId, errorCode)
            return
          }
          val rstStream = removeStream(streamId)
          rstStream?.receiveRstStream(errorCode)
        }
    
        override fun settings(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Verify the peer received what was expected.
        val rstStream = peer.takeFrame()
        assertThat(rstStream.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(rstStream.streamId).isEqualTo(2)
        assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL)
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  6. docs/debugging/inspect/decrypt-v2.go

    	if false {
    		sr.SkipEncrypted(true)
    		return sr.DebugStream(os.Stdout)
    	}
    	extracted := false
    	for {
    		stream, err := sr.NextStream()
    		if err != nil {
    			if err == io.EOF {
    				if extracted {
    					return nil
    				}
    				return errors.New("no data found on stream")
    			}
    			if errors.Is(err, estream.ErrNoKey) {
    				fmt.Println("Skipping", stream.Name, "no private key")
    				if err := stream.Skip(); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 17 17:09:42 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java

        assertThat(iia.asList()).containsExactly(0, 1, 3).inOrder();
      }
    
      public void testCopyOf_stream() {
        assertThat(ImmutableIntArray.copyOf(IntStream.empty()))
            .isSameInstanceAs(ImmutableIntArray.of());
        assertThat(ImmutableIntArray.copyOf(IntStream.of(0, 1, 3)).asList())
            .containsExactly(0, 1, 3)
            .inOrder();
      }
    
      public void testBuilder_presize_zero() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 12 14:49:24 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java

        assertThat(iia.asList()).containsExactly(0, 1, 3).inOrder();
      }
    
      public void testCopyOf_stream() {
        assertThat(ImmutableIntArray.copyOf(IntStream.empty()))
            .isSameInstanceAs(ImmutableIntArray.of());
        assertThat(ImmutableIntArray.copyOf(IntStream.of(0, 1, 3)).asList())
            .containsExactly(0, 1, 3)
            .inOrder();
      }
    
      public void testBuilder_presize_zero() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 20.2K bytes
    - Click Count (0)
  9. build-logic-commons/basics/src/test/kotlin/gradlebuild/basics/tasks/PackageListGeneratorIntegrationTest.kt

                                val entryName = dir.relativize(file).joinToString(separator = "/") { it.toString() }
                                jarStream.putNextEntry(JarEntry(entryName))
                                Files.copy(file, jarStream)
                                jarStream.closeEntry()
                                return FileVisitResult.CONTINUE
                            }
                        })
                    }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 25 08:50:34 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/SmbFileInputStreamTest.java

            void readNullArrayThrows() throws Exception {
                SmbFileInputStream in = newStream();
                assertThrows(NullPointerException.class, () -> in.read(null));
            }
    
            @Test
            @DisplayName("readDirect with len <= 0 returns 0")
            void readDirectZeroLen() throws Exception {
                SmbFileInputStream in = newStream();
                byte[] buf = new byte[4];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.8K bytes
    - Click Count (0)
Back to Top