Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 1,029 for Base (0.03 sec)

  1. internal/bucket/bandwidth/monitor_gen.go

    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "LimitInBytesPerSecond":
    			z.LimitInBytesPerSecond, err = dc.ReadInt64()
    			if err != nil {
    				err = msgp.WrapError(err, "LimitInBytesPerSecond")
    				return
    			}
    		case "CurrentBandwidthInBytesPerSecond":
    			z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64()
    			if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. internal/s3select/jstream/scanner_test.go

    		}
    	})
    }
    
    func benchmarkBufioReader(b []byte) {
    	br := bufio.NewReader(bytes.NewReader(b))
    loop:
    	for {
    		_, err := br.ReadByte()
    		switch err {
    		case nil:
    			continue loop
    		case io.EOF:
    			break loop
    		default:
    			panic(err)
    		}
    	}
    }
    
    func BenchmarkScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. tests/create_test.go

    	AssertEqual(t, u2.Mobile, "133xxxx")
    }
    
    func TestCreateFromMapWithoutPK(t *testing.T) {
    	if !isMysql() {
    		t.Skipf("This test case skipped, because of only supporting for mysql")
    	}
    
    	// case 1: one record, create from map[string]interface{}
    	mapValue1 := map[string]interface{}{"name": "create_from_map_with_schema1", "age": 1}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Mar 19 03:50:28 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka_scram_client_contrib.go

    )
    
    func initScramClient(cfg Config, config *sarama.Config) {
    	switch strings.ToLower(cfg.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.3K bytes
    - Viewed (0)
  5. cmd/streaming-v4-unsigned.go

    		// the chunk size to be of variable width. In particular,
    		// a size of 16 is encoded as `10` while a size of 64 KB
    		// is `10000`.
    		switch {
    		case b >= '0' && b <= '9':
    			size = size<<4 | int(b-'0')
    		case b >= 'a' && b <= 'f':
    			size = size<<4 | int(b-('a'-10))
    		case b >= 'A' && b <= 'F':
    			size = size<<4 | int(b-('A'-10))
    		default:
    			if cr.debug {
    				fmt.Printf("err size: %v\n", string(b))
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/tag.go

    			var s string
    			if err = d.DecodeElement(&s, &se); err != nil {
    				return err
    			}
    			switch se.Name.Local {
    			case "Key":
    				if keyAlreadyParsed {
    					return errDuplicatedXMLTag
    				}
    				tag.Key = s
    				keyAlreadyParsed = true
    			case "Value":
    				if valueAlreadyParsed {
    					return errDuplicatedXMLTag
    				}
    				tag.Value = s
    				valueAlreadyParsed = true
    			default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/informers.go

    			})
    		}
    	}
    }
    
    func (s *InformerHandlers) reconcile(input any) error {
    	event := input.(controllers.Event)
    	switch event.Latest().(type) {
    	case *corev1.Namespace:
    		return s.reconcileNamespace(input)
    	case *corev1.Pod:
    		return s.reconcilePod(input)
    	default:
    		return fmt.Errorf("unexpected event type: %+v", input)
    	}
    }
    
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. cmd/data-usage-cache.go

    		if err != nil {
    			switch err.(type) {
    			case ObjectNotFound, BucketNotFound:
    				r, err = store.GetObjectNInfo(ctx, dataUsageBucket, name, nil, http.Header{}, ObjectOptions{NoLock: true})
    				if err != nil {
    					switch err.(type) {
    					case ObjectNotFound, BucketNotFound:
    						return false, nil
    					case InsufficientReadQuorum, StorageErr:
    						return true, nil
    					}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  9. docs/en/docs/deployment/https.md

    In this case, it would use the certificate for `someapp.example.com`.
    
    <img src="/img/deployment/https/https03.svg">
    
    The client already **trusts** the entity that generated that TLS certificate (in this case Let's Encrypt, but we'll see about that later), so it can **verify** that the certificate is valid.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 12K bytes
    - Viewed (0)
  10. cmd/tier-handlers.go

    	}
    
    	// Disallow remote tiers with internal storage class names
    	switch cfg.Name {
    	case storageclass.STANDARD, storageclass.RRS:
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL)
    		return
    	}
    
    	// Refresh from the disk in case we had missed notifications about edits from peers.
    	if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top