Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 164 for _new (0.06 sec)

  1. internal/config/storageclass/storage-class.go

    	ConfigLock.RLock()
    	defer ConfigLock.RUnlock()
    	if !sCfg.initialized {
    		return true
    	}
    	return sCfg.Optimize == "availability" || sCfg.Optimize == ""
    }
    
    // Update update storage-class with new config
    func (sCfg *Config) Update(newCfg Config) {
    	ConfigLock.Lock()
    	defer ConfigLock.Unlock()
    	sCfg.RRS = newCfg.RRS
    	sCfg.Standard = newCfg.Standard
    	sCfg.Optimize = newCfg.Optimize
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    var ErrTargetsOffline = errors.New("one or more targets are offline. Please use `mc admin info --json` to check the offline targets")
    
    // TestSubSysNotificationTargets - tests notification targets of given subsystem
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_gen.go

    					if err != nil {
    						err = msgp.WrapError(err, "Infos", za0001)
    						return
    					}
    					z.Infos[za0001] = nil
    				} else {
    					if z.Infos[za0001] == nil {
    						z.Infos[za0001] = new(ObjectPartInfo)
    					}
    					err = z.Infos[za0001].DecodeMsg(dc)
    					if err != nil {
    						err = msgp.WrapError(err, "Infos", za0001)
    						return
    					}
    				}
    			}
    		default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  4. internal/config/identity/openid/jwt.go

    	if err != nil {
    		return err
    	}
    	defer r.closeRespFn(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    		return errors.New(resp.Status)
    	}
    
    	return r.pubKeys.parseAndAdd(resp.Body)
    }
    
    // ErrTokenExpired - error token expired
    var (
    	ErrTokenExpired = errors.New("token expired")
    )
    
    func updateClaimsExpiry(dsecs string, claims map[string]interface{}) error {
    	expStr := claims["exp"]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. internal/kms/config.go

    	switch {
    	case kmsPresent && kesPresent:
    		return false, errors.New("kms: configuration for MinIO KMS and MinIO KES is present")
    	case kmsPresent && staticKeyPresent:
    		return false, errors.New("kms: configuration for MinIO KMS and static KMS key is present")
    	case kesPresent && staticKeyPresent:
    		return false, errors.New("kms: configuration for MinIO KES and static KMS key is present")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  6. internal/config/dns/etcd_dns.go

    )
    
    // ErrNoEntriesFound - Indicates no entries were found for the given key (directory)
    var ErrNoEntriesFound = errors.New("No entries found for this key")
    
    // ErrDomainMissing - Indicates domain is missing
    var ErrDomainMissing = errors.New("domain is missing")
    
    const etcdPathSeparator = "/"
    
    // create a new coredns service record for the bucket.
    func newCoreDNSMsg(ip string, port string, ttl uint32, t time.Time) ([]byte, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    			return index
    		}
    	}
    	return -1
    }
    
    // initRebalanceMeta initializes rebalance metadata for a new rebalance
    // operation and saves it in the object store.
    func (z *erasureServerPools) initRebalanceMeta(ctx context.Context, buckets []string) (arn string, err error) {
    	r := &rebalanceMeta{
    		ID:        shortuuid.New(),
    		PoolStats: make([]*rebalanceStats, len(z.serverPools)),
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    	randmu sync.Mutex
    )
    
    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    	return uint32(time.Now().UnixNano() + int64(os.Getpid()))
    }
    
    // nextSuffix - provides a new unique suffix every time the function is called.
    func nextSuffix() string {
    	randmu.Lock()
    	r := randN
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  9. internal/config/config.go

    				for _, key := range keys {
    					ckvs.Delete(key)
    				}
    			}
    			cp[subSys][tgt] = ckvs
    		}
    	}
    
    	return cp
    }
    
    // New - initialize a new server config.
    func New() Config {
    	srvCfg := make(Config)
    	for _, k := range SubSystems.ToSlice() {
    		srvCfg[k] = map[string]KVS{}
    		srvCfg[k][Default] = DefaultKVS[k]
    	}
    	return srvCfg
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  10. internal/hash/checksum.go

    	case c.Is(ChecksumCRC32C):
    		return crc32.New(crc32.MakeTable(crc32.Castagnoli))
    	case c.Is(ChecksumSHA1):
    		return sha1.New()
    	case c.Is(ChecksumSHA256):
    		return sha256.New()
    	}
    	return nil
    }
    
    // Trailing return whether the checksum is trailing.
    func (c ChecksumType) Trailing() bool {
    	return c.Is(ChecksumTrailing)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top