Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 424 for jstream (0.04 sec)

  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 {
    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. cmd/postpolicyform.go

    	var buf bytes.Buffer
    	e := json.NewEncoder(&buf)
    	d := jstream.NewDecoder(r, 0).ObjectAsKVS().MaxDepth(10)
    	sset := set.NewStringSet()
    	for mv := range d.Stream() {
    		if mv.ValueType == jstream.Object {
    			// This is a JSON object type (that preserves key order)
    			kvs, ok := mv.Value.(jstream.KVS)
    			if ok {
    				for _, kv := range kvs {
    					if sset.Contains(kv.Key) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Oct 23 15:10:12 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  3. internal/s3select/sql/evaluate.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package sql
    
    import (
    	"encoding/json"
    	"errors"
    	"fmt"
    	"math"
    	"strings"
    
    	"github.com/minio/minio/internal/s3select/jstream"
    	"github.com/minio/simdjson-go"
    )
    
    var (
    	errInvalidASTNode    = errors.New("invalid AST Node")
    	errExpectedBool      = errors.New("expected bool")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  4. internal/s3select/jstream/decoder.go

    // values within the array are emitted to the stream, then the array
    // containing those values is emitted.
    func (d *Decoder) Recursive() *Decoder {
    	d.emitRecursive = true
    	return d
    }
    
    // Stream begins decoding from the underlying reader and returns a
    // streaming MetaValue channel for JSON values at the configured emitDepth.
    func (d *Decoder) Stream() chan *MetaValue {
    	go d.decode()
    	return d.metaCh
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/Streams.java

        }
      }
    
      /**
       * Returns a {@link Stream} 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).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 36.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Streams.java

        }
      }
    
      /**
       * Returns a {@link Stream} 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).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 21 15:40:45 UTC 2025
    - 36.8K bytes
    - Viewed (0)
  7. cmd/metacache-stream.go

    	"github.com/tinylib/msgp/msgp"
    	"github.com/valyala/bytebufferpool"
    )
    
    // metadata stream format:
    //
    // The stream is s2 compressed.
    // https://github.com/klauspost/compress/tree/master/s2#s2-compression
    // This ensures integrity and reduces the size typically by at least 50%.
    //
    // All stream elements are msgpack encoded.
    //
    // 1 Integer, metacacheStreamVersion of the writer.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

              writeBytesTotal >= writeBytesMaximum ||
              stream.writeBytesTotal >= stream.writeBytesMaximum
            if (stream.isOpen) {
              streams[streamId] = stream
            }
          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/curl/io/ContentCacheTest.java

            }
        }
    
        @Test
        public void testFileBasedCacheWithEmptyFile() throws IOException {
            tempFile = File.createTempFile("empty", ".tmp", Curl.tmpDir);
            // File is created but empty
    
            ContentCache cache = new ContentCache(tempFile);
    
            try (InputStream stream = cache.getInputStream()) {
                assertNotNull(stream);
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

          return javaNetSocket.isHealthy(socket.source)
        }
    
        return true
      }
    
      /** Refuse incoming streams. */
      @Throws(IOException::class)
      override fun onStream(stream: Http2Stream) {
        stream.close(ErrorCode.REFUSED_STREAM, null)
      }
    
      /** When settings are received, adjust the allocation limit. */
      override fun onSettings(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
Back to top