Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 281 for Initialized (0.05 seconds)

  1. cmd/bucket-object-lock.go

    		}
    		return "", objectlock.RetentionDate{}, legalHold, ErrNone
    	}
    	return mode, retainDate, legalHold, ErrNone
    }
    
    // NewBucketObjectLockSys returns initialized BucketObjectLockSys
    func NewBucketObjectLockSys() *BucketObjectLockSys {
    	return &BucketObjectLockSys{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:25 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  2. finisher_api.go

    			if where, ok := c.Expression.(clause.Where); ok {
    				tx.assignInterfacesToValue(where.Exprs)
    			}
    		}
    
    		// initialize with attrs, conds
    		if len(tx.Statement.attrs) > 0 {
    			tx.assignInterfacesToValue(tx.Statement.attrs...)
    		}
    	}
    
    	// initialize with attrs, conds
    	if len(tx.Statement.assigns) > 0 {
    		tx.assignInterfacesToValue(tx.Statement.assigns...)
    	}
    	return
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  3. cmd/globals.go

    	// and is 'true' when etcdConfig.PathPrefix is empty
    	globalBucketFederation bool
    
    	// Allocated DNS config wrapper over etcd client.
    	globalDNSConfig dns.Store
    
    	// GlobalKMS initialized KMS configuration
    	GlobalKMS *kms.KMS
    
    	// Common lock for various subsystems performing the leader tasks
    	globalLeaderLock *sharedLock
    
    	// Auto-Encryption, if enabled, turns any non-SSE-C request
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
  4. cmd/global-heal.go

    	bgSeq, found := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !found {
    		return errors.New("no local healing sequence initialized, unable to heal the drive")
    	}
    
    	scanMode := madmin.HealNormalScan
    
    	// Make sure to copy since `buckets slice`
    	// is modified in place by tracker.
    	healBuckets := make([]string, len(buckets))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  5. internal/bucket/object/lock/lock.go

    	config := Config{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil {
    		return nil, err
    	}
    
    	return &config, nil
    }
    
    // NewObjectLockConfig returns a initialized lock.Config struct
    func NewObjectLockConfig() *Config {
    	return &Config{
    		ObjectLockEnabled: Enabled,
    	}
    }
    
    // RetentionDate is a embedded type containing time.Time to unmarshal
    // Date in Retention
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  6. cmd/bucket-lifecycle.go

    // newTransitionState returns a transitionState object ready to be initialized
    // via its Init method.
    func newTransitionState(ctx context.Context) *transitionState {
    	return &transitionState{
    		transitionCh: make(chan transitionTask, 100000),
    		ctx:          ctx,
    		killCh:       make(chan struct{}),
    		lastDayStats: make(map[string]*lastDayTierStats),
    	}
    }
    
    // Init initializes t with given objAPI and instantiates the configured number
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  7. cmd/tier.go

    	defer config.RUnlock()
    	data := make([]byte, 4, config.Msgsize()+4)
    
    	// Initialize the header.
    	binary.LittleEndian.PutUint16(data[0:2], tierConfigFormat)
    	binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion)
    
    	// Marshal the tier config
    	return config.MarshalMsg(data)
    }
    
    // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  8. cmd/bucket-replication-utils.go

    		return VersionPurgeStatusType(rs.VersionPurgeStatusInternal)
    	default:
    		return getCompositeVersionPurgeStatus(rs.PurgeTargets)
    	}
    }
    
    // TargetState returns replicatedInfos struct initialized with the previous state of replication
    func (rs *ReplicationState) targetState(arn string) (r replicatedTargetInfo) {
    	return replicatedTargetInfo{
    		Arn:                   arn,
    		PrevReplicationStatus: rs.Targets[arn],
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  9. cmd/metrics-v2.go

    }
    
    // MetricsGroupV2 are a group of metrics that are initialized together.
    type MetricsGroupV2 struct {
    	metricsCache     *cachevalue.Cache[[]MetricV2] `msg:"-"`
    	cacheInterval    time.Duration
    	metricsGroupOpts MetricsGroupOpts
    }
    
    // MetricsGroupOpts are a group of metrics opts to be used to initialize the metrics group.
    type MetricsGroupOpts struct {
    	dependGlobalObjectAPI           bool
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  10. cmd/background-newdisks-heal-ops.go

    	poolIdx, setIdx := endpoint.PoolIdx, endpoint.SetIdx
    	disk := getStorageViaEndpoint(endpoint)
    	if disk == nil {
    		return fmt.Errorf("Unexpected error disk must be initialized by now after formatting: %s", endpoint)
    	}
    
    	_, err := disk.DiskInfo(ctx, DiskInfoOptions{})
    	if err != nil {
    		if errors.Is(err, errDriveIsRoot) {
    			// This is a root drive, ignore and move on
    			return nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
Back to Top