Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 467 for Uint64 (0.08 sec)

  1. docs/bucket/versioning/DESIGN.md

    xlHeaderVersion version == 1:
    
    ```
    //msgp:tuple xlMetaV2VersionHeader
    type xlMetaV2VersionHeader struct {
     VersionID [16]byte  // Version UUID, raw.
     ModTime   int64     // Unix nanoseconds.
     Signature [4]byte   // Signature of metadata.
     Type      uint8     // Type if the version
     Flags     uint8
    }
    ```
    
    The following flags are defined:
    
    ```
    const (
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  2. cmd/warm-backend-s3.go

    	destObj := object
    	if s3.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", s3.Prefix, object)
    	}
    	return destObj
    }
    
    func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	res, err := s3.client.PutObject(ctx, s3.Bucket, s3.getDest(object), r, length, minio.PutObjectOptions{
    		SendContentMd5: true,
    		StorageClass:   s3.StorageClass,
    	})
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. src/bufio/example_test.go

    	fmt.Fprint(w, "Hello, ")
    	fmt.Fprint(w, "world!")
    	w.Flush() // Don't forget to flush!
    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    		b := w.AvailableBuffer()
    		b = strconv.AppendInt(b, i, 10)
    		b = append(b, ' ')
    		w.Write(b)
    	}
    	w.Flush()
    	// Output: 1 2 3 4
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 23 09:06:30 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. cmd/batch-job-common-types_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"testing"
    )
    
    func TestBatchJobSizeInRange(t *testing.T) {
    	tests := []struct {
    		objSize    int64
    		sizeFilter BatchJobSizeFilter
    		want       bool
    	}{
    		{
    			// 1Mib < 2Mib < 10MiB -> in range
    			objSize: 2 << 20,
    			sizeFilter: BatchJobSizeFilter{
    				UpperBound: 10 << 20,
    				LowerBound: 1 << 20,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 08 23:22:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  5. internal/grid/trace.go

    		TraceType: t.TraceType,
    		FuncName:  prefix + "." + h.String(),
    		NodeName:  remote,
    		Time:      start,
    		Duration:  end.Sub(start),
    		Path:      t.Subroute,
    		Error:     errString,
    		Bytes:     int64(len(req) + len(resp)),
    		HTTP: &madmin.TraceHTTPStats{
    			ReqInfo: madmin.TraceRequestInfo{
    				Time:    start,
    				Proto:   "grid",
    				Method:  "REQ",
    				Client:  local,
    				Headers: nil,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. internal/s3select/select_benchmark_test.go

        <RequestProgress>
            <Enabled>FALSE</Enabled>
        </RequestProgress>
    </SelectObjectContentRequest>
    `)
    
    	csvData := genSampleCSVData(count)
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.SetBytes(int64(count))
    
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			s3Select, err := NewS3Select(bytes.NewReader(requestXML))
    			if err != nil {
    				b.Fatal(err)
    			}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    	opts Opts
    
    	// Once can be used to initialize values for lazy initialization.
    	// Should be set before calling Get().
    	Once sync.Once
    
    	// Managed values.
    	val          atomic.Pointer[T]
    	lastUpdateMs atomic.Int64
    	updating     sync.Mutex
    }
    
    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. docs/debugging/healing-bin/main.go

    		if !c.Args().Present() {
    			cli.ShowAppHelpAndExit(c, 1) // last argument is exit code
    		}
    
    		ht := make(map[string]map[string]interface{})
    		file := c.Args().Get(0)
    		if strings.HasSuffix(file, ".zip") {
    			var sz int64
    			f, err := os.Open(file)
    			if err != nil {
    				return err
    			}
    			if st, err := f.Stat(); err == nil {
    				sz = st.Size()
    			}
    			defer f.Close()
    			zr, err := zip.NewReader(f, sz)
    			if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  9. src/bufio/bufio.go

    // writeBuf writes the [Reader]'s buffer to the writer.
    func (b *Reader) writeBuf(w io.Writer) (int64, error) {
    	n, err := w.Write(b.buf[b.r:b.w])
    	if n < 0 {
    		panic(errNegativeWrite)
    	}
    	b.r += n
    	return int64(n), err
    }
    
    // buffered output
    
    // Writer implements buffering for an [io.Writer] object.
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  10. cmd/warm-backend-azure.go

    	destObj := object
    	if az.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", az.Prefix, object)
    	}
    	return destObj
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{
    		Concurrency: 4,
    		AccessTier:  az.tier(), // set tier if specified
    	})
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top