Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 492 for Buckets (0.04 seconds)

  1. internal/bucket/bandwidth/measurement.go

    )
    
    const (
    	// betaBucket is the weight used to calculate exponential moving average
    	betaBucket = 0.1 // Number of averages considered = 1/(1-betaObject)
    )
    
    // bucketMeasurement captures the bandwidth details for one bucket
    type bucketMeasurement struct {
    	lock                 sync.Mutex
    	bytesSinceLastWindow uint64    // Total bytes since last window was processed
    	startTime            time.Time // Start time for window
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Jun 03 20:41:51 GMT 2023
    - 2.9K bytes
    - Click Count (0)
  2. docs/metrics/healthcheck/README.md

    ```
    curl http://minio1:9001/minio/health/cluster
    HTTP/1.1 503 Service Unavailable
    Accept-Ranges: bytes
    Content-Length: 0
    Server: MinIO
    Vary: Origin
    X-Amz-Bucket-Region: us-east-1
    X-Minio-Write-Quorum: 3
    X-Amz-Request-Id: 16239D6AB80EBECF
    X-Xss-Protection: 1; mode=block
    Date: Tue, 21 Jul 2020 00:36:14 GMT
    ```
    
    ### Cluster-readable probe
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Jul 06 16:18:38 GMT 2023
    - 2.5K bytes
    - Click Count (0)
  3. cmd/batch-expire_gen.go

    		case "APIVersion":
    			z.APIVersion, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "APIVersion")
    				return
    			}
    		case "Bucket":
    			z.Bucket, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Bucket")
    				return
    			}
    		case "Prefix":
    			err = z.Prefix.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Prefix")
    				return
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  4. cmd/rebalance-admin.go

    import (
    	"context"
    	"time"
    )
    
    type rebalPoolProgress struct {
    	NumObjects  uint64        `json:"objects"`
    	NumVersions uint64        `json:"versions"`
    	Bytes       uint64        `json:"bytes"`
    	Bucket      string        `json:"bucket"`
    	Object      string        `json:"object"`
    	Elapsed     time.Duration `json:"elapsed"`
    	ETA         time.Duration `json:"eta"`
    }
    
    type rebalancePoolStatus struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  5. cmd/object-handlers-common.go

    		} else {
    			remaining = nil
    		}
    		vc, _ := globalBucketVersioningSys.Get(bucket)
    		deletedObjs, errs := o.DeleteObjects(ctx, bucket, toDel, ObjectOptions{
    			PrefixEnabledFn:  vc.PrefixEnabled,
    			VersionSuspended: vc.Suspended(),
    		})
    
    		for i, dobj := range deletedObjs {
    			oi := ObjectInfo{
    				Bucket:    bucket,
    				Name:      dobj.ObjectName,
    				VersionID: dobj.VersionID,
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jul 23 12:36:06 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  6. cmd/erasure-metadata.go

    // ToObjectInfo - Converts metadata to object info.
    func (fi FileInfo) ToObjectInfo(bucket, object string, versioned bool) ObjectInfo {
    	object = decodeDirObject(object)
    	versionID := fi.VersionID
    	if versioned && versionID == "" {
    		versionID = nullVersionID
    	}
    
    	objInfo := ObjectInfo{
    		IsDir:            HasSuffix(object, SlashSeparator),
    		Bucket:           bucket,
    		Name:             object,
    		ParityBlocks:     fi.Erasure.ParityBlocks,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  7. docs/sts/web-identity.py

                                     config=Config(signature_version='s3v4'),
                                     region_name='us-east-1')
    
        bucket = s3_resource.Bucket('testbucket')
    
        for obj in bucket.objects.all():
            print(obj)
    
        return "success"
    
    
    if __name__ == '__main__':
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jul 28 01:37:51 GMT 2021
    - 2.9K bytes
    - Click Count (0)
  8. docs/sts/custom-token-identity.go

    	token string
    
    	// Role ARN to use
    	roleArn string
    
    	// Display credentials flag
    	displayCreds bool
    
    	// Credential expiry duration
    	expiryDuration time.Duration
    
    	// Bucket to list
    	bucketToList string
    )
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 3.4K bytes
    - Click Count (0)
  9. cmd/config-current.go

    			Description:     "publish bucket notifications to webhook endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyAMQPSubSys,
    			Description:     "publish bucket notifications to AMQP endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyKafkaSubSys,
    			Description:     "publish bucket notifications to Kafka endpoints",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  10. internal/crypto/sse.go

    // and returns the decrypted object key.
    func (sse ssecCopy) UnsealObjectKey(h http.Header, metadata map[string]string, bucket, object string) (key ObjectKey, err error) {
    	clientKey, err := sse.ParseHTTP(h)
    	if err != nil {
    		return key, err
    	}
    	return unsealObjectKey(clientKey[:], metadata, bucket, object)
    }
    
    // unsealObjectKey decrypts and returns the sealed object key
    // from the metadata using the SSE-C client key.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.3K bytes
    - Click Count (0)
Back to Top