Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 467 for Uint64 (0.11 sec)

  1. cmd/bucket-targets.go

    	lastmin lastMinuteLatency
    	curr    time.Duration
    	avg     time.Duration
    	peak    time.Duration
    	N       int64
    }
    
    func (l *latencyStat) update(d time.Duration) {
    	l.lastmin.add(d)
    	l.N++
    	if d > l.peak {
    		l.peak = d
    	}
    	l.curr = l.lastmin.getTotal().avg()
    	l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N)
    }
    
    // epHealth struct represents health of a replication target endpoint.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/utils_test.go

    	"errors"
    	"fmt"
    	"net/http"
    	"net/url"
    	"reflect"
    	"strings"
    	"testing"
    )
    
    // Tests maximum object size.
    func TestMaxObjectSize(t *testing.T) {
    	sizes := []struct {
    		isMax bool
    		size  int64
    	}{
    		// Test - 1 - maximum object size.
    		{
    			true,
    			globalMaxObjectSize + 1,
    		},
    		// Test - 2 - not maximum object size.
    		{
    			false,
    			globalMaxObjectSize - 1,
    		},
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Feb 23 21:28:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. cmd/config-common.go

    	}
    	return err
    }
    
    func saveConfigWithOpts(ctx context.Context, store objectIO, configFile string, data []byte, opts ObjectOptions) error {
    	hashReader, err := hash.NewReader(ctx, bytes.NewReader(data), int64(len(data)), "", getSHA256Hash(data), int64(len(data)))
    	if err != nil {
    		return err
    	}
    
    	_, err = store.PutObject(ctx, minioMetaBucket, configFile, NewPutObjReader(hashReader), opts)
    	return err
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. cmd/handler-utils_test.go

    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("<>"))),
    		ContentLength: int64(len("<>")),
    	}
    
    	// Not an XML
    	badRequest := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("garbage"))),
    		ContentLength: int64(len("garbage")),
    	}
    
    	// generates the input request with XML bucket configuration set to the request body.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    			globalHTTPStats.updateStats(api, tc.ResponseRecorder)
    			globalConnStats.incS3InputBytes(int64(tc.RequestRecorder.Size()))
    			globalConnStats.incS3OutputBytes(int64(tc.ResponseRecorder.Size()))
    
    			if countBktStat {
    				globalBucketConnStats.incS3InputBytes(bucket, int64(tc.RequestRecorder.Size()))
    				globalBucketConnStats.incS3OutputBytes(bucket, int64(tc.ResponseRecorder.Size()))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. cmd/s3-zip-handlers.go

    func getFilesListFromZIPObject(ctx context.Context, objectAPI ObjectLayer, bucket, object string, opts ObjectOptions) (zipindex.Files, ObjectInfo, error) {
    	size := 1 << 20
    	var objSize int64
    	for {
    		rs := &HTTPRangeSpec{IsSuffixLength: true, Start: int64(-size)}
    		gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, rs, nil, opts)
    		if err != nil {
    			return nil, ObjectInfo{}, err
    		}
    		b, err := io.ReadAll(gr)
    		gr.Close()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. internal/config/lambda/target/webhook.go

    		return errors.New("cert and key must be specified as a pair")
    	}
    	return nil
    }
    
    // WebhookTarget - Webhook target.
    type WebhookTarget struct {
    	activeRequests int64
    	totalRequests  int64
    	failedRequests int64
    
    	lazyInit lazyInit
    
    	id         event.TargetID
    	args       WebhookArgs
    	transport  *http.Transport
    	httpClient *http.Client
    	loggerOnce logger.LogOnce
    	cancel     context.CancelFunc
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. src/main/config/openapi/openapi-user.yaml

                        format: int64
                        example: 0
                      page_size:
                        type: integer
                        example: 20
                      page_number:
                        type: integer
                        example: 1
                      record_count:
                        type: integer
                        format: int64
                        example: 31625
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu May 09 06:31:27 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  9. internal/s3select/csv/record.go

    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Record - is a CSV record.
    type Record struct {
    	columnNames  []string
    	csvRecord    []string
    	nameIndexMap map[string]int64
    }
    
    // Get - gets the value for a column name. CSV fields do not have any
    // defined type (other than the default string). So this function
    // always returns fields using sql.FromBytes so that the type
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. internal/config/storageclass/storage-class.go

    // if versioned is true then we chosen 1/8th inline block size
    // to satisfy the same constraints.
    func (sCfg *Config) ShouldInline(shardSize int64, versioned bool) bool {
    	if shardSize < 0 {
    		return false
    	}
    
    	ConfigLock.RLock()
    	inlineBlock := int64(128 * humanize.KiByte)
    	if sCfg.initialized {
    		inlineBlock = sCfg.inlineBlock
    	}
    	ConfigLock.RUnlock()
    
    	if versioned {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
Back to top