Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 122 for bucketOf (0.29 sec)

  1. cmd/dummy-handlers.go

    // They are only defined to be used in this file alone.
    
    // GetBucketWebsite  - GET bucket website, a dummy api
    func (api objectAPIHandlers) GetBucketWebsiteHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetBucketWebsite")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. cmd/metrics-v3-api.go

    		}
    		sentBytes := inOut.Out
    		if sentBytes > 0 {
    			m.Set(apiTrafficRecvBytes, float64(sentBytes), "bucket", bucket, "type", "s3")
    		}
    
    		httpStats := globalBucketHTTPStats.load(bucket)
    		for k, v := range httpStats.currentS3Requests.Load(false) {
    			m.Set(apiRequestsInFlightTotal, float64(v), "bucket", bucket, "name", k, "type", "s3")
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 07:41:18 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. cmd/acl-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Before proceeding validate if bucket exists.
    	_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	aclHeader := r.Header.Get(xhttp.AmzACL)
    	if aclHeader == "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/telemetry/internal/config/config.go

    	}
    	return s
    }
    
    // Expand takes a counter defined with buckets and expands it into distinct
    // strings for each bucket
    func Expand(counter string) []string {
    	prefix, rest, hasBuckets := strings.Cut(counter, "{")
    	var counters []string
    	if hasBuckets {
    		buckets := strings.Split(strings.TrimSuffix(rest, "}"), ",")
    		for _, b := range buckets {
    			counters = append(counters, prefix+b)
    		}
    	} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:57:25 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. internal/crypto/key_test.go

    		UnsealExtKey: [32]byte{}, UnsealDomain: "SSE-C", UnsealBucket: "bucket", UnsealObject: "object",
    		ShouldPass: true,
    	}, // 0
    	{
    		SealExtKey: [32]byte{}, SealIV: [32]byte{}, SealDomain: "SSE-C", SealBucket: "bucket", SealObject: "object",
    		UnsealExtKey: [32]byte{1}, UnsealDomain: "SSE-C", UnsealBucket: "bucket", UnsealObject: "object", // different ext-key
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 02 00:13:57 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. cmd/warm-backend-s3.go

    type warmBackendS3 struct {
    	client       *minio.Client
    	core         *minio.Core
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (s3 *warmBackendS3) ToObjectError(err error, params ...string) error {
    	object := ""
    	if len(params) >= 1 {
    		object = params[0]
    	}
    
    	return ErrorRespToObjectError(err, s3.Bucket, s3.getDest(object))
    }
    
    func (s3 *warmBackendS3) getDest(object string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-usage.go

    		m.Set(usageBucketObjectsCount, float64(usage.ObjectsCount), "bucket", bucket)
    		m.Set(usageBucketVersionsCount, float64(usage.VersionsCount), "bucket", bucket)
    		m.Set(usageBucketDeleteMarkersCount, float64(usage.DeleteMarkersCount), "bucket", bucket)
    
    		if quota != nil && quota.Quota > 0 {
    			m.Set(usageBucketQuotaTotalBytes, float64(quota.Quota), "bucket", bucket)
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. cmd/data-scanner_test.go

    import (
    	"context"
    	"encoding/xml"
    	"fmt"
    	"strings"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/versioning"
    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. docs/metrics/prometheus/README.md

      bearer_token: <secret>
      metrics_path: /minio/v2/metrics/cluster
      scheme: http
      static_configs:
      - targets: ['localhost:9000']
    ```
    
    ##### Bucket centric
    
    ```yaml
    - job_name: minio-job-bucket
      bearer_token: <secret>
      metrics_path: /minio/v2/metrics/bucket
      scheme: http
      static_configs:
      - targets: ['localhost:9000']
    ```
    
    ##### Node centric (optional)
    
    ```yaml
    - job_name: minio-job-node
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 12 15:49:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  10. docs/iam/policies/pbac-tests.sh

    ./mc admin policy attach myminio consoleAdmin --user minio123
    
    ./mc mb -l myminio/test-bucket
    ./mc mb -l myminio/multi-key-poc
    
    export MC_HOST_myminio1="http://minio123:minio123@localhost:9000/"
    
    ./mc cp /etc/issue myminio1/test-bucket
    ret=$?
    if [ $ret -ne 0 ]; then
    	echo "BUG: PutObject to bucket: test-bucket should succeed. Failed"
    	exit 1
    fi
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top