Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 392 for jstream (0.28 sec)

  1. src/archive/tar/reader_test.go

    	}
    
    	data1, data2, pax, sparse := ss[0], ss[1], ss[2], ss[3]
    	data2 += strings.Repeat("\x00", 10*512)
    	trash := strings.Repeat("garbage ", 64) // Exactly 512 bytes
    
    	vectors := []struct {
    		input string // Input stream
    		cnt   int    // Expected number of headers read
    		err   error  // Expected error outcome
    	}{
    		{"", 0, io.EOF}, // Empty file is a "valid" tar file
    		{data1[:511], 0, io.ErrUnexpectedEOF},
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  2. cmd/handler-utils.go

    			return nil, err
    		}
    	}
    
    	// Set content-type to default value if it is not set.
    	if _, ok := metadata[strings.ToLower(xhttp.ContentType)]; !ok {
    		metadata[strings.ToLower(xhttp.ContentType)] = "binary/octet-stream"
    	}
    
    	// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    	for k := range metadata {
    		if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    	}
    
    	if isTruncated {
    		listObjectsInfo.IsTruncated = true
    		listObjectsInfo.NextContinuationToken = nextToken
    	}
    
    	return listObjectsInfo, nil
    }
    
    // getFilesFromZIPObject reads a partial stream of a zip file to build the zipindex.Files index
    func getFilesListFromZIPObject(ctx context.Context, objectAPI ObjectLayer, bucket, object string, opts ObjectOptions) (zipindex.Files, ObjectInfo, error) {
    	size := 1 << 20
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

        protected String[] toStringArray(final Object value) {
            if (value instanceof String[]) {
                return (String[]) value;
            } else if (value instanceof List) {
                return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]);
            }
            String str = DfTypeUtil.toString(value);
            if (str == null) {
                return null;
            }
            return new String[] { str };
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

        protected String[] toStringArray(final Object value) {
            if (value instanceof String[]) {
                return (String[]) value;
            } else if (value instanceof List) {
                return ((List<?>) value).stream().map(v -> v.toString()).toArray(n -> new String[n]);
            }
            String str = DfTypeUtil.toString(value);
            if (str == null) {
                return null;
            }
            return new String[] { str };
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    		// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream
    		// is always going to be in-memory as we cannot re-read from what we
    		// wrote to disk - since that amounts to "copying" from a "copy"
    		// instead of "copying" from source, we need the stream to be seekable
    		// to ensure that we can make fan-out calls concurrently.
    		buf := bytebufferpool.Get()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    			select {
    			case <-ctx.Done():
    			case updates <- *resp.Update:
    			}
    		}
    		if resp.Final != nil {
    			final = resp.Final
    		}
    		// We can't reuse the response since it is sent upstream.
    		return nil
    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	if final == nil {
    		return cache, errors.New("no final cache")
    	}
    	return *final, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. cmd/generic-handlers.go

    				return
    			} else if rec != nil {
    				stack := debug.Stack()
    				logger.Error("panic: \"%s %s\": %v\n%s", r.Method, r.URL, rec, string(stack))
    				// Try to write an error response, upstream may not have written header.
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrInternalError), r.URL)
    				return
    			}
    		}()
    		h.ServeHTTP(w, r)
    	})
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  9. 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",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  10. docs/bigdata/README.md

    - Install MinIO Distributed Server using one of the guides below.
      - [Deployment based on Kubernetes](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes)
      - [Deployment based on MinIO Helm Chart](https://github.com/helm/charts/tree/master/stable/minio)
    
    ## **3. Configure Hadoop, Spark, Hive to use MinIO**
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top