Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 137 for Walker (0.26 sec)

  1. istioctl/pkg/describe/describe.go

    // When the config has no selector labels, this method will treat it as qualified namespace level
    // config. So configs passed into this method should only contains workload's namespaces configs
    // and rootNamespaces configs, caller should be responsible for controlling configs passed
    // in.
    func findMatchedConfigs(podsLabels klabels.Set, configs []*config.Config) []*config.Config {
    	var cfgs []*config.Config
    
    	for _, cfg := range configs {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  2. internal/crypto/sse-s3.go

    	}
    
    	// There are two possibilities:
    	// - We use a KMS -> There must be non-empty key ID and a KMS data key.
    	// - We use a K/V -> There must be no key ID and no KMS data key.
    	// Otherwise, the caller has passed an invalid argument combination.
    	if keyID == "" && len(kmsKey) != 0 {
    		logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present"))
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    		return validMeta, false
    	}
    
    	if nonActionableMetaErrs > 0 || nonActionablePartsErrs > 0 {
    		return validMeta, false
    	}
    
    	if validMeta.Deleted {
    		// notFoundPartsErrs is ignored since
    		// - delete marker does not have any parts
    		dataBlocks := (len(errs) + 1) / 2
    		return validMeta, notFoundMetaErrs > dataBlocks
    	}
    
    	// TODO: It is possible to replay the object via just single
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. src/archive/tar/common.go

    		}
    	}
    	if sysStat != nil {
    		return h, sysStat(fi, h, doNameLookups)
    	}
    	return h, nil
    }
    
    // FileInfoNames extends [fs.FileInfo].
    // Passing an instance of this to [FileInfoHeader] permits the caller
    // to avoid a system-dependent name lookup by specifying the Uname and Gname directly.
    type FileInfoNames interface {
    	fs.FileInfo
    	// Uname should give a user name.
    	Uname() (string, error)
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 15 16:01:50 GMT 2024
    - 24.7K bytes
    - Viewed (2)
  5. cmd/erasure-healing_test.go

    				errFileNotFound,
    				errFileNotFound,
    				nil,
    			},
    			dataErrs:         nil,
    			expectedMeta:     ifi,
    			expectedDangling: true,
    		},
    		{
    			name: "FileInfoDecided-case2-delete-marker",
    			metaArr: []FileInfo{
    				{},
    				{},
    				{},
    				{Deleted: true},
    			},
    			errs: []error{
    				errFileNotFound,
    				errFileNotFound,
    				errFileNotFound,
    				nil,
    			},
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. internal/config/identity/plugin/config.go

    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    	// Assumes the caller has h.Lock()'ed
    	h.lastFullMinute = h.currentMinute
    	h.currentMinute = serviceRTTMinuteStats{
    		statsTime: currReqMinute,
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
  7. cmd/metacache-entries_test.go

    					ModTime:   baseTime.Add(30 * time.Minute).UnixNano(),
    					Signature: [4]byte{1, 1, 1, 1},
    					Type:      ObjectType,
    					Flags:     0,
    				}},
    			},
    		},
    		// Delete marker.
    		8: {
    			versions: []xlMetaV2ShallowVersion{
    				{header: xlMetaV2VersionHeader{
    					VersionID: [16]byte{7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7, 7},
    					ModTime:   baseTime.Add(90 * time.Minute).UnixNano(),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 31.6K bytes
    - Viewed (0)
  8. cmd/bucket-handlers_test.go

    			accessKey:          credentials.AccessKey,
    			secretKey:          credentials.SecretKey,
    			expectedRespStatus: http.StatusOK,
    			shouldPass:         true,
    		},
    		// Test case - 4.
    		// Setting Invalid prefix and marker combination.
    		{
    			bucket:             bucketName,
    			prefix:             "asia",
    			keyMarker:          "europe-object",
    			uploadIDMarker:     "",
    			delimiter:          "",
    			maxUploads:         "0",
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  9. internal/logger/target/http/http.go

    // format of a log entry to the configured http endpoint.
    // An internal buffer of logs is maintained but when the
    // buffer is full, new logs are just ignored and an error
    // is returned to the caller.
    type Target struct {
    	totalMessages  int64
    	failedMessages int64
    	status         int32
    
    	// Worker control
    	workers    int64
    	maxWorkers int64
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  10. cmd/iam-object-store.go

    	iamOS.Lock()
    	defer iamOS.Unlock()
    	iamOS.iamCache.iamSTSAccountsMap = stsAccountsFromStore
    	iamOS.iamCache.iamSTSPolicyMap = stsAccPoliciesFromStore
    
    	return nil
    }
    
    // Assumes cache is locked by caller.
    func (iamOS *IAMObjectStore) loadAllFromObjStore(ctx context.Context, cache *iamCache) error {
    	if iamOS.objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	bootstrapTraceMsg("loading all IAM items")
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
Back to top