Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 106 for Walker (0.14 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    		return
    	}
    
    	if maxUploads < 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidMaxUploads), r.URL)
    		return
    	}
    
    	if keyMarker != "" {
    		// Marker not common with prefix is not implemented.
    		if !HasPrefix(keyMarker, prefix) {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    			return
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  5. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  6. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  7. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 6.6K bytes
    - Viewed (1)
  8. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/lifecycle_test.go

    			objectModTime:  time.Now().UTC().Add(-1 * time.Hour), // Created one hour ago
    			isDelMarker:    true,
    			expectedAction: DeleteVersionAction,
    		},
    		// Should not expire a delete marker; ExpiredObjectDeleteAllVersions applies only when current version is not a DEL marker.
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  10. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3K bytes
    - Viewed (0)
Back to top