Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for element (0.25 sec)

  1. internal/bucket/object/lock/lock.go

    	if err := d.DecodeElement(&parsedConfig, &start); err != nil {
    		return err
    	}
    
    	if parsedConfig.ObjectLockEnabled != Enabled {
    		return fmt.Errorf("only 'Enabled' value is allowed to ObjectLockEnabled element")
    	}
    
    	*config = Config(parsedConfig)
    	return nil
    }
    
    // ToRetention - convert to Retention type.
    func (config *Config) ToRetention() Retention {
    	r := Retention{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 17.1K bytes
    - Viewed (0)
  2. internal/config/storageclass/storage-class.go

    // Currently only supported scheme is "EC".
    func parseStorageClass(storageClassEnv string) (sc StorageClass, err error) {
    	s := strings.Split(storageClassEnv, ":")
    
    	// only two elements allowed in the string - "scheme" and "number of parity drives"
    	if len(s) > 2 {
    		return StorageClass{}, config.ErrStorageClassValue(nil).Msg("Too many sections in " + storageClassEnv)
    	} else if len(s) < 2 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.8K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    		}
    	}
    	m.o = dst
    }
    
    // filterRecursiveEntries will keep entries only with the prefix that doesn't contain separator.
    // This can be used to remove recursive listings.
    // To return root elements only set prefix to an empty string.
    // Order is preserved, but the underlying slice is modified.
    func (m *metaCacheEntriesSorted) filterRecursiveEntries(prefix, separator string) {
    	dst := m.o[:0]
    	if prefix != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. internal/bucket/object/lock/lock_test.go

    			expectedErr: errors.New("expected element type <Status> but have <MyStatus>"),
    			expectErr:   true,
    		},
    		// invalid XML attr
    		{
    			value:       `<?xml version="1.0" encoding="UTF-8"?><UnknownLegalHold xmlns="http://s3.amazonaws.com/doc/2006-03-01/"><Status>ON</Status></UnknownLegalHold>`,
    			expectedErr: errors.New("expected element type <LegalHold>/<ObjectLockLegalHold> but have <UnknownLegalHold>"),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 17.1K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/lifecycle.go

    	switch start.Name.Local {
    	case "LifecycleConfiguration", "BucketLifecycleConfiguration":
    	default:
    		return xml.UnmarshalError(fmt.Sprintf("expected element type <LifecycleConfiguration>/<BucketLifecycleConfiguration> but have <%s>",
    			start.Name.Local))
    	}
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    //
    // All stream elements are msgpack encoded.
    //
    // 1 Integer, metacacheStreamVersion of the writer.
    // This can be used for managing breaking changes.
    //
    // For each element:
    // 1. Bool. If false at end of stream.
    // 2. String. Name of object. Directories contains a trailing slash.
    // 3. Binary. Blob of metadata. Length 0 on directories.
    // ... Next element.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  7. cmd/erasure.go

    // Get an aggregated storage info across all disks.
    func getStorageInfo(disks []StorageAPI, endpoints []Endpoint, metrics bool) StorageInfo {
    	disksInfo := getDisksInfo(disks, endpoints, metrics)
    
    	// Sort so that the first element is the smallest.
    	sort.Slice(disksInfo, func(i, j int) bool {
    		return disksInfo[i].TotalSpace < disksInfo[j].TotalSpace
    	})
    
    	storageInfo := StorageInfo{
    		Disks: disksInfo,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  8. cmd/data-usage-cache.go

    }
    
    //msgp:ignore dataUsageEntryInfo
    type dataUsageEntryInfo struct {
    	Name   string
    	Parent string
    	Entry  dataUsageEntry
    }
    
    type dataUsageCacheInfo struct {
    	// Name of the bucket. Also root element.
    	Name       string
    	NextCycle  uint32
    	LastUpdate time.Time
    	// indicates if the disk is being healed and scanner
    	// should skip healing the disk
    	SkipHealing bool
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  9. cmd/bucket-stats.go

    	tMin := t / 60
    	if l.LastMin >= tMin {
    		return
    	}
    	if t-l.LastMin >= 60 {
    		l.Totals = [60]AccElem{}
    		return
    	}
    	for l.LastMin != t {
    		// Clear next element.
    		idx := (l.LastMin + 1) % 60
    		l.Totals[idx] = AccElem{}
    		l.LastMin++
    	}
    }
    
    // BucketStatsMap captures bucket statistics for all buckets
    type BucketStatsMap struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 13.1K bytes
    - Viewed (0)
  10. cmd/endpoint.go

    		}
    	}
    
    	return poolEndpoints, setupType, nil
    }
    
    // GetLocalPeer - returns local peer value, returns globalMinioAddr
    // for FS and Erasure mode. In case of distributed server return
    // the first element from the set of peers which indicate that
    // they are local. There is always one entry that is local
    // even with repeated server endpoints.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
Back to top