Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 651 for crawler (0.06 sec)

  1. cmd/testdata/undeleteable-object.tgz

    ssion":{"_":[{"key":"enable","value":"off"},{"key":"allow_encryption","value":"off"},{"key":"extensions","value":".txt,.log,.csv,.json,.tar,.xml,.bin"},{"key":"mime_types","value":"text/*,application/json,application/xml,binary/octet-stream"}]},"crawler":{"_":null},"credentials":{"_":null},"drive":{"_":[{"key":"max_timeout","value":""}]},"etcd":{"_":[{"key":"endpoints","value":""},{"key":"path_prefix","value":""},{"key":"coredns_path","value":"/skydns"},{"key":"client_cert","value":""},{"key":"c...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  2. cmd/streaming-signature-v4.go

    func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    	cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer)
    	if errCode != ErrNone {
    		return nil, errCode
    	}
    
    	if trailer {
    		// Discard anything unsigned.
    		req.Trailer = make(http.Header)
    		trailers := req.Header.Values(awsTrailerHeader)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. internal/hash/reader.go

    	cs, err := GetContentChecksum(req.Header)
    	if err != nil {
    		return ErrInvalidChecksum
    	}
    	if cs == nil {
    		return nil
    	}
    	r.contentHash = *cs
    	if cs.Type.Trailing() {
    		r.trailer = req.Trailer
    	}
    	return r.AddNonTrailingChecksum(cs, ignoreValue)
    }
    
    // AddChecksumNoTrailer will add checksum checks as specified in
    // https://docs.aws.amazon.com/AmazonS3/latest/userguide/checking-object-integrity.html
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. cmd/streaming-v4-unsigned.go

    func newUnsignedV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    	if trailer {
    		// Discard anything unsigned.
    		req.Trailer = make(http.Header)
    		trailers := req.Header.Values(awsTrailerHeader)
    		for _, key := range trailers {
    			req.Trailer.Add(key, "")
    		}
    	} else {
    		req.Trailer = nil
    	}
    	return &s3UnsignedChunkedReader{
    		trailers: req.Trailer,
    		reader:   bufio.NewReader(req.Body),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * shared state without additional synchronization necessary for visibility to later executions of
     * the life cycle methods.
     *
     * <h3>Usage Example</h3>
     *
     * <p>Here is a sketch of a service which crawls a website and uses the scheduling capabilities to
     * rate limit itself.
     *
     * <pre>{@code
     * class CrawlingService extends AbstractScheduledService {
     *   private Set<Uri> visited;
     *   private Queue<Uri> toCrawl;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  6. tensorflow/c/c_api_experimental.h

    // The returned string is heap-allocated, and caller should call free() on it.
    TF_CAPI_EXPORT extern const char* TF_GraphDebugString(TF_Graph* graph,
                                                          size_t* len);
    
    // Returns the function content in a human-readable format, with length set in
    // `len`. The format is subject to change in the future.
    // The returned string is heap-allocated, and caller should call free() on it.
    //
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * exception is propagated to the caller exactly as-is. If, on the other hand, the time limit is
       * reached, the proxy will attempt to abort the call to the target, and will throw an {@link
       * UncheckedTimeoutException} to the caller.
       *
       * <p>It is important to note that the primary purpose of the proxy object is to return control to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/ByteSink.java

     *
     * <p>{@code ByteSink} provides two kinds of methods:
     *
     * <ul>
     *   <li><b>Methods that return a stream:</b> These methods should return a <i>new</i>, independent
     *       instance each time they are called. The caller is responsible for ensuring that the
     *       returned stream is closed.
     *   <li><b>Convenience methods:</b> These are implementations of common operations that are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. internal/cachevalue/cache.go

    	t.Once.Do(func() {
    		t.ttl = ttl
    		t.updateFn = update
    		t.opts = opts
    	})
    }
    
    // GetWithCtx will return a cached value or fetch a new one.
    // passes a caller context, if caller context cancels nothing
    // is cached.
    // If the Update function returns an error the value is forwarded as is and not cached.
    func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) {
    	v := t.val.Load()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/reflect/TypeToInstanceMap.java

     *
     * <p>Generally, implementations don't support {@link #put} and {@link #putAll} because there is no
     * way to check an object at runtime to be an instance of a {@link TypeToken}. Instead, caller
     * should use the type safe {@link #putInstance}.
     *
     * <p>Also, if caller suppresses unchecked warnings and passes in an {@code Iterable<String>} for
     * type {@code Iterable<Integer>}, the map won't be able to detect and throw type error.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Apr 22 01:15:23 UTC 2023
    - 3.8K bytes
    - Viewed (0)
Back to top