Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 248 for always (0.18 sec)

  1. cmd/lock-rest-server.go

    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    	// Ignore the Unlock() "reply" return value because if err == nil, "reply" is always true
    	// Consequently, if err != nil, reply is always false
    	return l.makeResp(resp, err)
    }
    
    // RLockHandler - Acquires an RLock.
    func (l *lockRESTServer) RLockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  2. cmd/routers.go

    	registerAdminRouter(router, true)
    
    	// Add healthCheck router
    	registerHealthCheckRouter(router)
    
    	// Add server metrics router
    	registerMetricsRouter(router)
    
    	// Add STS router always.
    	registerSTSRouter(router)
    
    	// Add KMS router
    	registerKMSRouter(router)
    
    	// Add API router
    	registerAPIRouter(router)
    
    	router.Use(globalMiddlewares...)
    
    	return router, nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  3. internal/arn/arn.go

    // String - returns string representation of the ARN.
    func (arn ARN) String() string {
    	return strings.Join(
    		[]string{
    			arnPrefixArn,
    			arn.Partition,
    			arn.Service,
    			arn.Region,
    			"", // account-id is always empty in this implementation
    			arn.ResourceType + "/" + arn.ResourceID,
    		},
    		":",
    	)
    }
    
    // Parse - parses an ARN string into a type.
    func Parse(arnStr string) (arn ARN, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 08:31:34 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  4. cmd/s3-zip-handlers.go

    	if err != nil {
    		// Return empty listing
    		return ListObjectsV2Info{}, nil
    	}
    
    	zipInfo := zipObjInfo.ArchiveInfo()
    	if len(zipInfo) == 0 {
    		// Always update the latest version
    		zipInfo, err = updateObjectMetadataWithZipInfo(ctx, objectAPI, bucket, zipPath, ObjectOptions{})
    	}
    	if err != nil {
    		return ListObjectsV2Info{}, err
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  5. cmd/metacache.go

    	metacacheMaxClientWait = 3 * time.Minute
    
    	// metacacheBlockSize is the number of file/directory entries to have in each block.
    	metacacheBlockSize = 5000
    
    	// metacacheSharePrefix controls whether prefixes on dirty paths are always shared.
    	// This will make `test/a` and `test/b` share listings if they are concurrent.
    	// Enabling this will make cache sharing more likely and cause less IO,
    	// but may cause additional latency to some calls.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    			e.AllTierStats = newAllTierStats()
    		}
    		e.AllTierStats.merge(other.AllTierStats)
    	}
    }
    
    // mod returns true if the hash mod cycles == cycle.
    // If cycles is 0 false is always returned.
    // If cycles is 1 true is always returned (as expected).
    func (h dataUsageHash) mod(cycle uint32, cycles uint32) bool {
    	if cycles <= 1 {
    		return cycles == 1
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  7. internal/config/scanner/scanner.go

    	EnvMaxWaitLegacy = "MINIO_CRAWLER_MAX_WAIT"
    )
    
    // Config represents the heal settings.
    type Config struct {
    	// Delay is the sleep multiplier.
    	Delay float64 `json:"delay"`
    
    	// Sleep always or based on incoming S3 requests.
    	IdleMode int32 // 0 => on, 1 => off
    
    	// Alert upon this many excess object versions
    	ExcessVersions int64 // 100
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  8. docs/bucket/versioning/README.md

    ## Concepts
    
    - All Buckets on MinIO are always in one of the following states: unversioned (the default) and all other existing deployments, versioning-enabled, or versioning-suspended.
    - Versioning state applies to all of the objects in the versioning enabled bucket. The first time you enable a bucket for versioning, objects in the bucket are thereafter always versioned and given a unique version ID.
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu May 04 21:43:52 GMT 2023
    - 11.9K bytes
    - Viewed (1)
  9. cmd/bitrot-streaming.go

    	return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) error {
    		// Similar to CloseWithError on pipes we always return nil.
    		return nil
    	}}
    }
    
    // Returns streaming bitrot writer implementation.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v1.go

    	Parts []ObjectPartInfo `json:"parts,omitempty"`
    
    	// Dummy values used for legacy use cases.
    	VersionID string `json:"versionId,omitempty"`
    	DataDir   string `json:"dataDir,omitempty"` // always points to "legacy"
    }
    
    // StatInfo - carries stat information of the object.
    type StatInfo struct {
    	Size    int64     `json:"size"`    // Size of the object `xl.meta`.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 8.2K bytes
    - Viewed (0)
Back to top