Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Rashed (0.2 sec)

  1. cmd/metacache-set.go

    	Versioning *versioning.Versioning `msg:"-"`
    
    	// Lifecycle performs filtering based on lifecycle.
    	// This will filter out objects if the most recent version should be deleted by lifecycle.
    	// Is not transferred across request calls.
    	Lifecycle *lifecycle.Lifecycle `msg:"-"`
    
    	// Retention configuration, needed to be passed along with lifecycle if set.
    	Retention lock.Retention `msg:"-"`
    
    	// Replication configuration
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. cmd/admin-handlers-users.go

    			})
    		}
    		sort.Slice(buckets, func(i, j int) bool {
    			return buckets[i].Name < buckets[j].Name
    		})
    	} else {
    		buckets, err = objectAPI.ListBuckets(ctx, BucketOptions{Cached: true})
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    
    	accountName := cred.AccessKey
    	if cred.IsTemp() || cred.IsServiceAccount() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 77.3K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	t := time.Now().Unix()
    	e.init.Do(func() {
    		e.cached.Store(&AccElem{})
    		atomic.StoreInt64(&e.cachedSec, t)
    	})
    	acc := e.cached.Load()
    	if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t {
    		// Check if lastT was changed by someone else.
    		if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) {
    			// Now we swap in a new.
    			newAcc := &AccElem{}
    			old := e.cached.Swap(newAcc)
    			var a AccElem
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/iam.go

    	entityKeysInStorage := set.NewStringSet()
    	if iamOS, ok := sys.store.IAMStorageAPI.(*IAMObjectStore); ok {
    		// Load existing mapping keys from the cached listing for
    		// `IAMObjectStore`.
    		iamFilesListing := iamOS.cachedIAMListing.Load().(map[string][]string)
    		listKey := policyDBSTSUsersListKey
    		if isGroup {
    			listKey = policyDBGroupsListKey
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  5. cmd/erasure-server-pool.go

    // that all buckets are present on all serverPools.
    func (z *erasureServerPools) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) {
    	if opts.Cached {
    		listBucketsCache.InitOnce(time.Second,
    			cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    			func() ([]BucketInfo, error) {
    				ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    	}
    	for k, v := range m.VariableLabels {
    		metric.VariableLabels[k] = v
    	}
    	for k, v := range m.Histogram {
    		metric.Histogram[k] = v
    	}
    	return metric
    }
    
    // Get - returns cached value always upton the configured TTL,
    // once the TTL expires "read()" registered function is called
    // to return the new values and updated.
    func (g *MetricsGroupV2) Get() (metrics []MetricV2) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    		// value is cached we should attempt to invalidate it if such calls
    		// were attempted. This can lead to false success under certain conditions
    		// - this change attempts to avoid stale information if the underlying
    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/iam-store.go

    		}
    		groups.Remove(group)
    		c.iamUserGroupMemberships[member] = groups
    	}
    }
    
    // policyDBGet - lower-level helper; does not take locks.
    //
    // If a group is passed, it returns policies associated with the group.
    //
    // If a user is passed, it returns policies of the user along with any groups
    // that the server knows the user is a member of.
    //
    // In LDAP users mode, the server does not store any group membership
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  9. cmd/xl-storage.go

    			return nil, errDiskAccessDenied
    		}
    		storageLogOnceIf(GlobalContext, err, "check-format-json") // log unexpected errors
    		return nil, errCorruptedBackend
    	}
    	return fi, nil
    }
    
    // GetDiskID - returns the cached disk uuid
    func (s *xlStorage) GetDiskID() (string, error) {
    	s.RLock()
    	diskID := s.diskID
    	fileInfo := s.formatFileInfo
    	lastCheck := s.formatLastCheck
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    					return false
    				}
    				storage := newXLStorageDiskIDCheck(xl, true)
    				storage.SetDiskID(xl.diskID)
    				// We do not have to do SetFormatData() since 'xl'
    				// already captures formatData cached.
    
    				globalLocalDrivesMu.Lock()
    				defer globalLocalDrivesMu.Unlock()
    
    				globalLocalDrives = append(globalLocalDrives, storage)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top