Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for All (0.13 sec)

  1. cmd/test-utils_test.go

    	if len(apiFunctions) == 0 {
    		// Register all api endpoints by default.
    		registerAPIRouter(muxRouter)
    		return
    	}
    	// API Router.
    	apiRouter := muxRouter.PathPrefix(SlashSeparator).Subrouter()
    	// Bucket router.
    	bucketRouter := apiRouter.PathPrefix("/{bucket}").Subrouter()
    
    	// All object storage operations are registered as HTTP handlers on `objectAPIHandlers`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  2. cmd/iam.go

    		UpdateDate: d.UpdateDate,
    	}, nil
    }
    
    // ListPolicies - lists all canned policies.
    func (sys *IAMSys) ListPolicies(ctx context.Context, bucketName string) (map[string]policy.Policy, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    
    	return sys.store.ListPolicies(ctx, bucketName)
    }
    
    // ListPolicyDocs - lists all canned policy docs.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/iam-store.go

    type ParentUserInfo struct {
    	subClaimValue string
    	roleArns      set.StringSet
    }
    
    // GetAllParentUsers - returns all distinct "parent-users" associated with STS
    // or service credentials, mapped to all distinct roleARNs associated with the
    // parent user. The dummy role ARN is associated with parent users from
    // policy-claim based OpenID providers.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  4. cmd/erasure-object.go

    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    	// Read metadata associated with the object from all disks.
    	storageDisks := er.getDisks()
    
    	var metaArr []FileInfo
    	var errs []error
    
    	// Read metadata associated with the object from all disks.
    	if srcOpts.VersionID != "" {
    		metaArr, errs = readAllFileInfo(ctx, storageDisks, "", srcBucket, srcObject, srcOpts.VersionID, true, false)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. cmd/erasure-server-pool.go

    			set.deleteAll(ctx, bucket, prefix)
    		}
    	}
    }
    
    var listBucketsCache = cachevalue.New[[]BucketInfo]()
    
    // List all buckets from one of the serverPools, we are not doing merge
    // sort here just for simplification. As per design it is assumed
    // that all buckets are present on all serverPools.
    func (z *erasureServerPools) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		// this can be healed since all parts are available.
    		s.deleteFile(dstVolumeDir, dstDataPath, false, false)
    		return res, osErrToFileErr(err)
    	}
    
    	if srcVolume != minioMetaMultipartBucket {
    		// srcFilePath is some-times minioMetaTmpBucket, an attempt to
    		// remove the temporary folder is enough since at this point
    		// ideally all transaction should be complete.
    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/object-api-listobjects_test.go

    		// Marker being set to a value which is greater than and all object names when sorted (36).
    		// Expected to send an empty response in this case.
    		{"test-bucket-list-object", "", "zen", "", 10, ListObjectsInfo{}, nil, true},
    		// Marker being set to a value which is lesser than and all object names when sorted (37).
    		// Expected to send all the objects in the bucket in this case.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  8. cmd/object-api-multipart_test.go

    	}
    
    	// Validate all the test cases.
    	for i, testCase := range testCases {
    		actualInfo, actualErr := obj.PutObjectPart(context.Background(), testCase.bucketName, testCase.objName, testCase.uploadID, testCase.PartID, mustGetPutObjReader(t, bytes.NewBufferString(testCase.inputReaderData), testCase.inputDataSize, testCase.inputMd5, testCase.inputSHA256), opts)
    		// All are test cases above are expected to fail.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  9. cmd/peer-rest-server.go

    		return
    	}
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    	if globalProfiler == nil {
    		globalProfiler = make(map[string]minioProfiler, 10)
    	}
    
    	// Stop profiler of all types if already running
    	for k, v := range globalProfiler {
    		for _, p := range profiles {
    			if p == k {
    				v.Stop()
    				delete(globalProfiler, k)
    			}
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  10. src/bytes/bytes_test.go

    // Copyright 2009 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package bytes_test
    
    import (
    	. "bytes"
    	"fmt"
    	"internal/testenv"
    	"math"
    	"math/rand"
    	"reflect"
    	"strings"
    	"testing"
    	"unicode"
    	"unicode/utf8"
    	"unsafe"
    )
    
    func eq(a, b []string) bool {
    	if len(a) != len(b) {
    		return false
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Jan 24 16:07:25 GMT 2024
    - 56.2K bytes
    - Viewed (0)
Back to top