Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for CriticalIf (0.2 sec)

  1. cmd/bucket-versioning.go

    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.PrefixEnabled(prefix)
    }
    
    // Suspended suspended versioning?
    func (sys *BucketVersioningSys) Suspended(bucket string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.Suspended()
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 2.6K bytes
    - Viewed (0)
  2. internal/crypto/key.go

    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    	mac := hmac.New(sha256.New, extKey)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  3. internal/crypto/sse-s3.go

    	// Otherwise, the caller has passed an invalid argument combination.
    	if keyID == "" && len(kmsKey) != 0 {
    		logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present"))
    	}
    	if keyID != "" && len(kmsKey) == 0 {
    		logger.CriticalIf(context.Background(), errors.New("The KMS data key must not be empty if a key ID is present"))
    	}
    
    	if metadata == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  4. internal/logger/logger.go

    	sendLog(ctx, entry)
    }
    
    // ErrCritical is the value panic'd whenever CriticalIf is called.
    var ErrCritical struct{}
    
    // CriticalIf logs the provided error on the console. It fails the
    // current go-routine by causing a `panic(ErrCritical)`.
    func CriticalIf(ctx context.Context, err error, errKind ...interface{}) {
    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  5. internal/crypto/sse-kms.go

    	// Otherwise, the caller has passed an invalid argument combination.
    	if keyID == "" && len(kmsKey) != 0 {
    		logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present"))
    	}
    	if keyID != "" && len(kmsKey) == 0 {
    		logger.CriticalIf(context.Background(), errors.New("The KMS data key must not be empty if a key ID is present"))
    	}
    
    	if metadata == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  6. internal/crypto/sse.go

    func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader {
    	r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:], CipherSuites: fips.DARECiphers()})
    	if err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key"))
    	}
    	return r
    }
    
    // EncryptMultiPart encrypts an io.Reader which must be the body of
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 4.4K bytes
    - Viewed (0)
  7. cmd/namespace-lock.go

    	}
    
    	if !locked { // We failed to get the lock
    		// Decrement ref count since we failed to get the lock
    		n.lockMapMutex.Lock()
    		n.lockMap[resource].ref--
    		if n.lockMap[resource].ref < 0 {
    			logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
    		}
    		if n.lockMap[resource].ref == 0 {
    			// Remove from the map if there are no more references.
    			delete(n.lockMap, resource)
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 05 23:56:35 GMT 2023
    - 9.2K bytes
    - Viewed (0)
  8. cmd/bitrot.go

    		return hh
    	case HighwayHash256S:
    		hh, _ := highwayhash.New(magicHighwayHash256Key) // New will never return error since key is 256 bit
    		return hh
    	default:
    		logger.CriticalIf(GlobalContext, errors.New("Unsupported bitrot algorithm"))
    		return nil
    	}
    }
    
    // Available reports whether the given algorithm is available.
    func (a BitrotAlgorithm) Available() bool {
    	_, ok := bitrotAlgorithms[a]
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  9. internal/crypto/sse-c.go

    // metadata map if metadata is nil.
    func (ssec) CreateMetadata(metadata map[string]string, sealedKey SealedKey) map[string]string {
    	if sealedKey.Algorithm != SealAlgorithm {
    		logger.CriticalIf(context.Background(), Errorf("The seal algorithm '%s' is invalid for SSE-C", sealedKey.Algorithm))
    	}
    
    	if metadata == nil {
    		metadata = make(map[string]string, 3)
    	}
    	metadata[MetaAlgorithm] = SealAlgorithm
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  10. cmd/jwt.go

    			}
    			cacheLRU.Add(k, s)
    		}
    		return s, nil
    	}
    	return func(audience string) string {
    		cred := globalActiveCred
    		token, err := fn(cred.AccessKey, cred.SecretKey, audience)
    		logger.CriticalIf(GlobalContext, err)
    		return token
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:45:14 GMT 2024
    - 5.4K bytes
    - Viewed (0)
Back to top