Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 513 for readAs (0.04 sec)

  1. docs/distributed/README.md

    ### Data protection
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  2. docs/bucket/versioning/README.md

    unintended overwrites, deletions, protect objects with retention policies.
    
    To control data retention and storage usage, use object versioning with [object lifecycle management](https://github.com/minio/minio/blob/master/docs/bucket/lifecycle/README.md).  If you have an object expiration lifecycle policy in your non-versioned bucket and you want to maintain the same permanent delete behavior when on versioning-enabled bucket, you must add a noncurrent expiration policy. The noncurrent expiration...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 12K bytes
    - Viewed (0)
  3. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

            "seqno=$testCase.seqno",
            testCase.headersList,
            hpackReader.getAndResetHeaderList(),
          )
        }
      }
    
      companion object {
        /**
         * Reads all stories in the folders provided, asserts if no story found.
         */
        @JvmStatic
        protected fun createStories(interopTests: Array<String>): List<Any> {
          if (interopTests.isEmpty()) return listOf<Any>(Story.MISSING)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. cmd/erasure-heal_test.go

    		closeBitrotWriters(writers)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    			return s2w.Close()
    		}
    		return nil
    	}
    }
    
    var s2DecPool = bpool.Pool[*s2.Reader]{New: func() *s2.Reader {
    	// Default alloc block for network transfer.
    	return s2.NewReader(nil, s2.ReaderAllocBlock(16<<10))
    }}
    
    // metacacheReader allows reading a cache stream.
    type metacacheReader struct {
    	mr      *msgp.Reader
    	current metaCacheEntry
    	err     error // stateful error
    	closer  func()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        internal val reader: Http2Reader,
      ) : Http2Reader.Handler,
        () -> Unit {
        override fun invoke() {
          var connectionErrorCode = ErrorCode.INTERNAL_ERROR
          var streamErrorCode = ErrorCode.INTERNAL_ERROR
          var errorException: IOException? = null
          try {
            reader.readConnectionPreface(this)
            while (reader.nextFrame(false, this)) {
            }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    		// - xl.meta for inlined objects has already read the data
    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. cmd/bitrot-streaming.go

    	}()
    	return bw
    }
    
    // ReadAt() implementation which verifies the bitrot hash available as part of the stream.
    type streamingBitrotReader struct {
    	disk       StorageAPI
    	data       []byte
    	rc         io.Reader
    	volume     string
    	filePath   string
    	tillOffset int64
    	currOffset int64
    	h          hash.Hash
    	shardSize  int64
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  9. README.md

    <summary>About the command <code>fastapi dev main.py</code>...</summary>
    
    The command `fastapi dev` reads your `main.py` file, detects the **FastAPI** app in it, and starts a server using <a href="https://www.uvicorn.org" class="external-link" target="_blank">Uvicorn</a>.
    
    By default, `fastapi dev` will start with auto-reload enabled for local development.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 15:19:49 UTC 2025
    - 24.3K bytes
    - Viewed (0)
  10. docs/bucket/notifications/README.md

    mc event add myminio/images arn:minio:sqs::1:redis --suffix .jpg
    mc event list myminio/images
    arn:minio:sqs::1:redis s3:ObjectCreated:*,s3:ObjectRemoved:* Filter: suffix=”.jpg”
    ```
    
    ### Step 3: Test on Redis
    
    Start the `redis-cli` Redis client program to inspect the contents in Redis. Run the `monitor` Redis command. This prints each operation performed on Redis as it occurs.
    
    ```
    redis-cli -a yoursecret
    127.0.0.1:6379> monitor
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
Back to top