Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for observed (0.15 sec)

  1. internal/grid/types.go

    		return msgp.NilSize
    	}
    	sz := msgp.ArrayHeaderSize
    	for _, v := range j.val {
    		sz += v.Msgsize()
    	}
    	return sz
    }
    
    // Value returns the underlying value.
    // Regular append mechanics should be observed.
    // If no value has been set yet, a new array is created.
    func (j *Array[T]) Value() []T {
    	if j.val == nil {
    		j.val = j.p.newA(10)
    	}
    	return j.val
    }
    
    // Append a value to the underlying array.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEntityTooLarge), r.URL)
    		return
    	}
    
    	// We have to copy metadata only if source and destination are same.
    	// this changes for encryption which can be observed below.
    	if cpSrcDstSame {
    		srcInfo.metadataOnly = true
    	}
    
    	var chStorageClass bool
    	if dstSc != "" && dstSc != srcInfo.StorageClass {
    		chStorageClass = true
    		srcInfo.metadataOnly = false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/generic-handlers_test.go

    		test := test
    		t.Run("", func(t *testing.T) {
    			contains := containsReservedMetadata(test.header)
    			if contains && !test.shouldFail {
    				t.Errorf("contains reserved header but should not fail")
    			} else if !contains && test.shouldFail {
    				t.Errorf("does not contain reserved header but failed")
    			}
    		})
    	}
    }
    
    var sseTLSHandlerTests = []struct {
    	URL               *url.URL
    	Header            http.Header
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. cmd/tier-handlers.go

    		Message:    "Invalid remote tier credentials",
    		StatusCode: http.StatusBadRequest,
    	}
    	// error returned when reserved internal names are used.
    	errTierReservedName = AdminError{
    		Code:       "XMinioAdminTierReserved",
    		Message:    "Cannot use reserved tier name",
    		StatusCode: http.StatusBadRequest,
    	}
    )
    
    func (api adminAPIHandlers) AddTierHandler(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. cmd/metrics.go

    			Name:    "s3_ttfb_seconds",
    			Help:    "Time taken by requests served by current MinIO server instance",
    			Buckets: []float64{.05, .1, .25, .5, 1, 2.5, 5, 10},
    		},
    		[]string{"api"},
    	)
    	bucketHTTPRequestsDuration = prometheus.NewHistogramVec(
    		prometheus.HistogramOpts{
    			Name:    "s3_ttfb_seconds",
    			Help:    "Time taken by requests served by current MinIO server instance per bucket",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	// the open file descriptor.
    	//
    	// Failing to check the return value when closing a file may lead to silent loss of data.
    	// This can especially be observed with NFS and with disk quota.
    	return w.Close()
    }
    
    func (s *xlStorage) writeAll(ctx context.Context, volume string, path string, b []byte, sync bool, skipParent string) (err error) {
    	if contextCanceled(ctx) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/tier.go

    		Name:    "tier_ttlb_seconds",
    		Help:    "Time taken by requests served by warm tier",
    		Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60},
    	}, []string{"tier"}),
    }
    
    func (t *tierMetrics) Observe(tier string, dur time.Duration) {
    	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
    }
    
    func (t *tierMetrics) logSuccess(tier string) {
    	t.Lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  8. internal/s3select/select_test.go

    			wantResult: `1
    3`,
    		},
    		{
    			name:  "Select reserved word column",
    			query: `select "CAST"  from s3object`,
    			wantResult: `true
    false`,
    		},
    		{
    			name:  "Select reserved word column with table alias",
    			query: `select S3Object."CAST" from s3object`,
    			wantResult: `true
    false`,
    		},
    		{
    			name:  "Select reserved word column with unused table alias",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    		}
    
    		op := auditTierOp{
    			Tier:        tier,
    			OutputBytes: bytes,
    		}
    
    		if err == nil {
    			since := time.Since(startTime)
    			op.TimeToResponseNS = since.Nanoseconds()
    			globalTierMetrics.Observe(tier, since)
    			globalTierMetrics.logSuccess(tier)
    		} else {
    			op.Error = err.Error()
    			globalTierMetrics.logFailure(tier)
    		}
    
    		logger.GetReqInfo(ctx).AppendTags("tierStats", op)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  10. internal/grid/handlers.go

    func makeSubHandlerID(id HandlerID, subRoute string) subHandlerID {
    	b := subHandlerID(sha256.Sum256([]byte(subRoute)))
    	b[0] = byte(id)
    	b[1] = 0 // Reserved
    	return b
    }
    
    func (s subHandlerID) withHandler(id HandlerID) subHandlerID {
    	s[0] = byte(id)
    	s[1] = 0 // Reserved
    	return s
    }
    
    func (s *subHandlerID) String() string {
    	if s == nil {
    		return ""
    	}
    	return hex.EncodeToString(s[:])
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
Back to top