Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 392 for jstream (0.09 sec)

  1. cmd/erasure.go

    					// bucketResults channel while the
    					// updates-collector goroutine still
    					// holds a reference to this.
    					wg.Wait()
    					continue
    				}
    
    				wg.Wait()
    				// Flatten for upstream, but save full state.
    				var root dataUsageEntry
    				if r := cache.root(); r != nil {
    					root = cache.flatten(*r)
    				}
    				select {
    				case <-ctx.Done():
    					return
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. internal/bucket/object/lock/lock.go

    	default:
    		return xml.UnmarshalError(fmt.Sprintf("expected element type <LegalHold>/<ObjectLockLegalHold> but have <%s>",
    			start.Name.Local))
    	}
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			switch se.Name.Local {
    			case "Status":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  3. cmd/erasure-decode.go

    				case errors.Is(err, errFileCorrupt):
    					atomic.StoreInt32(&bitrotHeal, 1)
    				case errors.Is(err, errDiskNotFound):
    					atomic.AddInt32(&disksNotFound, 1)
    				}
    
    				// This will be communicated upstream.
    				p.orgReaders[bufIdx] = nil
    				if br, ok := p.readers[i].(io.Closer); ok {
    					br.Close()
    				}
    				p.readers[i] = nil
    
    				// Since ReadAt returned error, trigger another read.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java

    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.stream.Collectors;
    
    import javax.xml.transform.OutputKeys;
    import javax.xml.transform.TransformerFactory;
    import javax.xml.transform.dom.DOMSource;
    import javax.xml.transform.stream.StreamResult;
    
    import org.apache.groovy.util.Maps;
    import org.apache.logging.log4j.LogManager;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Oct 24 13:01:38 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    	LifecycleAuditEvent lcAuditEvent
    
    	WantChecksum *hash.Checksum // x-amz-checksum-XXX checksum sent to PutObject/ CompleteMultipartUpload.
    
    	NoDecryption                        bool      // indicates if the stream must be decrypted.
    	PreserveETag                        string    // preserves this etag during a PUT call.
    	NoLock                              bool      // indicates to lower layers if the caller is expecting to hold locks.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. internal/logger/target/http/http.go

    	migrateTarget *Target
    
    	// Number of events per HTTP send to webhook target
    	// this is ideally useful only if your endpoint can
    	// support reading multiple events on a stream for example
    	// like : Splunk HTTP Event collector, if you are unsure
    	// set this to '1'.
    	batchSize   int
    	payloadType string
    
    	// store to persist and replay the logs to the target
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. cmd/admin-handlers-idp-ldap.go

    		return
    	}
    
    	// Ensure body content type is opaque to ensure that request body has not
    	// been interpreted as form data.
    	contentType := r.Header.Get("Content-Type")
    	if contentType != "application/octet-stream" {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL)
    		return
    	}
    
    	// Validate operation
    	operation := mux.Vars(r)["operation"]
    	if operation != "attach" && operation != "detach" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/es/user/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)
  9. docs/pl/docs/features.md

    * Eventy startup i shutdown.
    * Klient testowy zbudowany na bazie biblioteki `requests`.
    * **CORS**, GZip, pliki statyczne, streamy.
    * Obsługa **sesji i ciasteczek**.
    * 100% pokrycie testami.
    * 100% adnotacji typów.
    
    ## Cechy Pydantic
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // PutObject - creates an object upon reading from the input stream
    // until EOF, erasure codes the data across all disk and additionally
    // writes `xl.meta` which carries the necessary metadata for future
    // object operations.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 78.5K bytes
    - Viewed (0)
Back to top