Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 119 for Walker (0.19 sec)

  1. 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 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    func (d *DeletedObject) VersionPurgeStatus() VersionPurgeStatusType {
    	return d.ReplicationState.CompositeVersionPurgeStatus()
    }
    
    // DeleteMarkerReplicationStatus return composite replication status of delete marker across targets
    func (d *DeletedObject) DeleteMarkerReplicationStatus() replication.StatusType {
    	return d.ReplicationState.CompositeReplicationStatus()
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  3. cmd/utils.go

    	runtime.SetMutexProfileFraction(0) // Disable until needed
    	runtime.SetBlockProfileRate(0)     // Disable until needed
    }
    
    // Starts a profiler returns nil if profiler is not enabled, caller needs to handle this.
    func startProfiler(profilerType string) (minioProfiler, error) {
    	var prof profilerWrapper
    	prof.ext = "pprof"
    	// Enable profiler and set the name of the file that pkg/pprof
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/expiration.go

    	set bool
    }
    
    // MarshalXML encodes delete marker boolean into an XML form.
    func (b Boolean) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !b.set {
    		return nil
    	}
    	return e.EncodeElement(b.val, startElement)
    }
    
    // UnmarshalXML decodes delete marker boolean from the XML form.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 6.6K bytes
    - Viewed (1)
  5. internal/logger/logger.go

    		f = strings.TrimPrefix(filepath.ToSlash(f), filepath.ToSlash(trimString))
    	}
    	return filepath.FromSlash(f)
    }
    
    func getSource(level int) string {
    	pc, file, lineNumber, ok := runtime.Caller(level)
    	if ok {
    		// Clean up the common prefixes
    		file = trimTrace(file)
    		_, funcName := filepath.Split(runtime.FuncForPC(pc).Name())
    		return fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName)
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  6. cmd/api-datatypes.go

    	VersionID             string `xml:"VersionId,omitempty"`
    	// MTime of DeleteMarker on source that needs to be propagated to replica
    	DeleteMarkerMTime DeleteMarkerMTime `xml:"-"`
    	// MinIO extensions to support delete marker replication
    	ReplicationState ReplicationState `xml:"-"`
    }
    
    // DeleteMarkerMTime is an embedded type containing time.Time for XML marshal
    type DeleteMarkerMTime struct {
    	time.Time
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jan 03 09:28:52 GMT 2022
    - 3K bytes
    - Viewed (0)
  7. cmd/batch-expire_test.go

              # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest.
              # retainVersions: 5 # keep the latest 5 versions of the object.
      
        - type: deleted # objects with delete marker as their latest version
          name: NAME # match object names that satisfy the wildcard expression.
          olderThan: 10h # match objects older than this value (e.g. 7d10h31s)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3K bytes
    - Viewed (0)
  8. internal/etag/etag.go

    //     In this case, the caller has to decrypt the ETag first
    //     before calling Format.
    //     S3 clients expect that the ETag of an SSE-S3 encrypted
    //     single-part object is equal to the object's content MD5.
    //     Formatting the SSE-S3 ETag before decryption will result
    //     in a random-looking ETag which an S3 client will not accept.
    //
    // Hence, a caller has to check:
    //
    //	if method == SSE-S3 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/lifecycle_test.go

    			objectName:     "foodir/fooobject",
    			objectModTime:  time.Now().UTC().Add(-24 * time.Hour), // Created 1 day ago
    			expectedAction: DeleteAction,
    		},
    		// Should delete expired delete marker right away
    		{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 45.6K bytes
    - Viewed (0)
  10. cmd/local-locker.go

    				// No more resources for UID, but we did update at least one.
    				return true, nil
    			}
    		}
    	}
    }
    
    // Similar to removeEntry but only removes an entry only if the lock entry exists in map.
    // Caller must hold 'l.mutex' lock.
    func (l *localLocker) expireOldLocks(interval time.Duration) {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    
    	for k, lris := range l.lockMap {
    		modified := false
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
Back to top