Search Options

Results per page
Sort
Preferred Languages
Advance

Results 711 - 720 of 1,029 for Base (0.03 sec)

  1. cmd/xl-storage-free-version.go

    		tierObjKey := ReservedMetadataPrefixLower + TransitionedObjectName
    		tierObjVIDKey := ReservedMetadataPrefixLower + TransitionedVersionID
    
    		for k, v := range j.MetaSys {
    			switch k {
    			case tierKey, tierObjKey, tierObjVIDKey:
    				freeEntry.DeleteMarker.MetaSys[k] = v
    			}
    		}
    		return freeEntry, true
    	}
    	return xlMetaV2Version{}, false
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    )
    
    func initScramClient(args KafkaArgs, config *sarama.Config) {
    	switch strings.ToLower(args.SASL.Mechanism) {
    	case "sha512":
    		config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
    		config.Net.SASL.Mechanism = sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512)
    	case "sha256":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (1)
  3. cmd/erasure-server-pool-rebalance.go

    		var (
    			quit     bool
    			traceMsg string
    		)
    
    		for {
    			select {
    			case rebalErr := <-doneCh:
    				quit = true
    				now := time.Now()
    				var status rebalStatus
    
    				switch {
    				case errors.Is(rebalErr, context.Canceled):
    					status = rebalStopped
    					traceMsg = fmt.Sprintf("stopped at %s", now)
    				case rebalErr == nil:
    					status = rebalCompleted
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    			}
    		}
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case v := <-updateCloser:
    				update()
    				xioutil.SafeClose(v)
    				return
    			case <-updateTicker.C:
    				update()
    			}
    		}
    	}()
    
    	wg.Wait()
    	ch := make(chan struct{})
    	select {
    	case updateCloser <- ch:
    		<-ch
    	case <-ctx.Done():
    		mu.Lock()
    		if firstErr == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/behind-a-proxy.md

    ## Proxy with a stripped path prefix
    
    Having a proxy with a stripped path prefix, in this case, means that you could declare a path at `/app` in your code, but then, you add a layer on top (the proxy) that would put your **FastAPI** application under a path like `/api/v1`.
    
    In this case, the original path `/app` would actually be served at `/api/v1/app`.
    
    Even though all your code is written assuming there's just `/app`.
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. internal/jwt/parser_test.go

    			// Parse the token
    			var err error
    
    			// Figure out correct claims type
    			switch claims := data.claims.(type) {
    			case *MapClaims:
    				if data.tokenString == "" {
    					data.tokenString = mapClaimsToken(claims)
    				}
    				err = ParseWithClaims(data.tokenString, &MapClaims{}, data.keyfunc)
    			case *StandardClaims:
    				if data.tokenString == "" {
    					data.tokenString = standardClaimsToken(claims)
    				}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 6K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/noncurrentversion.go

    func (n NoncurrentVersionExpiration) Validate() error {
    	if !n.set {
    		return nil
    	}
    	val := int(n.NoncurrentDays)
    	switch {
    	case val == 0 && n.NewerNoncurrentVersions == 0:
    		// both fields can't be zero
    		return errXMLNotWellFormed
    
    	case val < 0, n.NewerNoncurrentVersions < 0:
    		// negative values are not supported
    		return errXMLNotWellFormed
    	}
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    		parser:
    			for {
    				var next simdjson.Iter
    				typ, err := i.AdvanceIter(&next)
    				if err != nil {
    					t.Fatal(err)
    				}
    				switch typ {
    				case simdjson.TypeNone:
    					close(dst)
    					break parser
    				case simdjson.TypeRoot:
    					typ, obj, err := next.Root(nil)
    					if err != nil {
    						t.Fatal(err)
    					}
    					if typ != simdjson.TypeObject {
    						if typ == simdjson.TypeNone {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. cmd/handler-utils.go

    		}, r.URL)
    	case strings.HasPrefix(r.URL.Path, adminPathPrefix):
    		var desc string
    		version := extractAPIVersion(r)
    		switch version {
    		case "v1", madmin.AdminAPIVersionV2:
    			desc = fmt.Sprintf("Server expects client requests with 'admin' API version '%s', found '%s', please upgrade the client to latest releases", madmin.AdminAPIVersion, version)
    		case madmin.AdminAPIVersion:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  10. internal/event/target/elasticsearch.go

    		return err
    	}
    
    	switch serverSupportStatus {
    	case ESSUnknown:
    		return errors.New("unable to determine support status of ES (should not happen)")
    
    	case ESSDeprecated:
    		return errors.New("there is no currently deprecated version of ES in MinIO")
    
    	case ESSSupported:
    		target.client = clientV7
    
    	default:
    		// ESSUnsupported case
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top