Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 264 for OK (0.15 sec)

  1. cmd/bootstrap-peer-server.go

    	var missing []string
    	var mismatching []string
    	for k, v := range s1.MinioEnv {
    		ev, ok := s2.MinioEnv[k]
    		if !ok {
    			missing = append(missing, k)
    		} else if v != ev {
    			mismatching = append(mismatching, k)
    		}
    	}
    	var extra []string
    	for k := range s2.MinioEnv {
    		_, ok := s1.MinioEnv[k]
    		if !ok {
    			extra = append(extra, k)
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. internal/config/identity/openid/openid.go

    			return c, err
    		}
    
    		arnKey := p.roleArn
    		if p.RolePolicy == "" {
    			arnKey = DummyRoleARN
    			// Ensure that at most one JWT policy claim based provider may be
    			// defined.
    			if _, ok := c.arnProviderCfgsMap[DummyRoleARN]; ok {
    				return c, errSingleProvider
    			}
    		}
    
    		c.arnProviderCfgsMap[arnKey] = &p
    		c.ProviderCfgs[cfgName] = &p
    
    		if err = c.PopulatePublicKey(arnKey); err != nil {
    			return c, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  3. internal/jwt/parser.go

    		return jwtgo.ErrSignatureInvalid
    	}
    
    	n, err := base64DecodeBytes(token[i+1:], *bufp)
    	if err != nil {
    		return err
    	}
    
    	var ok bool
    	claims.AccessKey, ok = claims.Lookup("accessKey")
    	if !ok {
    		claims.AccessKey, ok = claims.Lookup("sub")
    		if !ok {
    			return jwtgo.NewValidationError("accessKey/sub missing",
    				jwtgo.ValidationErrorClaimsInvalid)
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 09 07:53:08 GMT 2023
    - 13.9K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    		}
    
    	}
    
    	if _, ok := opts.ObjectAttributes[xhttp.ETag]; ok {
    		OA.ETag = objInfo.ETag
    	}
    
    	if _, ok := opts.ObjectAttributes[xhttp.ObjectSize]; ok {
    		OA.ObjectSize, _ = objInfo.GetActualSize()
    	}
    
    	if _, ok := opts.ObjectAttributes[xhttp.StorageClass]; ok {
    		OA.StorageClass = objInfo.StorageClass
    	}
    
    	objInfo.decryptPartsChecksums()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. internal/s3select/parquet/reader.go

    		var value interface{}
    		if v, ok := nextRow[col.FlatName()]; ok {
    			value, err = convertFromAnnotation(col.Element(), v)
    			if err != nil {
    				return nil, errParquetParsingError(err)
    			}
    		}
    		kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value})
    	}
    
    	// Reuse destination if we can.
    	dstRec, ok := dst.(*jsonfmt.Record)
    	if !ok {
    		dstRec = &jsonfmt.Record{}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  6. internal/s3select/simdj/record.go

    // Reset the record.
    func (r *Record) Reset() {
    	r.object = simdjson.Object{}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	other.object = r.object
    	return other
    }
    
    // CloneTo clones the record to a json Record.
    // Values are only unmashaled on object level.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  7. docs/debugging/s3-check-md5/main.go

    				continue
    			}
    			if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok {
    				log.Println("SKIPPED: Objects encrypted with SSE-C do not have md5sum as ETag:", objFullPath(object))
    				continue
    			}
    			if v, ok := object.UserMetadata["X-Amz-Server-Side-Encryption"]; ok && v == "aws:kms" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 17 01:15:57 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  8. cmd/metrics.go

    	gatherers := prometheus.Gatherers{
    		prometheus.DefaultGatherer,
    		registry,
    	}
    
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = "handler.MetricsLegacy"
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		mfs, err := gatherers.Gather()
    		if err != nil {
    			if len(mfs) == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  9. internal/net/net.go

    	proc, err := procfs.Self()
    	if err != nil {
    		return procfs.NetDevLine{}, err
    	}
    	netDev, err := proc.NetDev()
    	if err != nil {
    		return procfs.NetDevLine{}, err
    	}
    	ndl, ok := netDev[interf]
    	if !ok {
    		return procfs.NetDevLine{}, fmt.Errorf("%v interface not found", interf)
    	}
    	return ndl, nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 17 08:14:01 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    		}
    		// let's the rest shutdown
    	}
    	return nil
    }
    
    // Legacy returns 'true' if distribution algo is CRCMOD
    func (z *erasureServerPools) Legacy() (ok bool) {
    	ok = true
    	for _, set := range z.serverPools {
    		ok = ok && set.Legacy()
    	}
    	return ok
    }
    
    func (z *erasureServerPools) BackendInfo() (b madmin.BackendInfo) {
    	b.Type = madmin.Erasure
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top