Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 35 for jetstream (0.07 seconds)

  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. 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)
  6. 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)
  7. 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)
  8. android/guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns an {@link IntStream} containing the elements of the first stream, followed by the
       * elements of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMapToInt(stream -> stream)}, but the
       * returned stream may perform better.
       *
       * @see IntStream#concat(IntStream, IntStream)
       */
      public static IntStream concat(IntStream... streams) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns an {@link IntStream} containing the elements of the first stream, followed by the
       * elements of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMapToInt(stream -> stream)}, but the
       * returned stream may perform better.
       *
       * @see IntStream#concat(IntStream, IntStream)
       */
      public static IntStream concat(IntStream... streams) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  10. internal/grid/grid_test.go

    		if _, ok := err.(*RemoteErr); !ok {
    			t.Fatalf("Unexpected error: %v, %T", err, err)
    		}
    		// Streams should not be able to set up until registered.
    		// Thus, the error is a local error.
    		_, err = remoteConn.NewStream(t.Context(), handlerTest, []byte(testPayload))
    		if !errors.Is(err, ErrUnknownHandler) {
    			t.Fatalf("Unexpected error: %v, %T", err, err)
    		}
    	})
    }
    
    func TestSingleRoundtripGenerics(t *testing.T) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top