Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,061 for Arrange (0.04 sec)

  1. internal/http/listener_test.go

    	}
    
    	for testIdx, testCase := range testCases {
    		listener, listenErrs := newHTTPListener(t.Context(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for i, expectedListenErr := range testCase.expectedListenErrs {
    			if !expectedListenErr {
    				if listenErrs[i] != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    	compress.SetCompressionConfig(newCfg, cfg.Compression)
    
    	for k, args := range cfg.Notify.AMQP {
    		notify.SetNotifyAMQP(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Elasticsearch {
    		notify.SetNotifyES(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Kafka {
    		notify.SetNotifyKafka(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.MQTT {
    		notify.SetNotifyMQTT(newCfg, k, args)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    				m := make(map[string]epHealth, len(eps))
    				start := time.Now()
    
    				for result := range sys.hcClient.Alive(cctx, madmin.AliveOpts{}, eps...) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  4. internal/grid/types.go

    func (m MSS) ToQuery() string {
    	if len(m) == 0 {
    		return ""
    	}
    	var buf strings.Builder
    	buf.WriteByte('?')
    	keys := make([]string, 0, len(m))
    	for k := range m {
    		keys = append(keys, k)
    	}
    	sort.Strings(keys)
    	for _, k := range keys {
    		v := m[k]
    		keyEscaped := url.QueryEscape(k)
    		if buf.Len() > 1 {
    			buf.WriteByte('&')
    		}
    		buf.WriteString(keyEscaped)
    		buf.WriteByte('=')
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    			t.Fatal(err)
    		}
    		vers = append(vers, xl.versions)
    	}
    	for _, v2 := range vers {
    		for _, ver := range v2 {
    			b, _ := json.Marshal(ver.header)
    			t.Log(string(b))
    			var x xlMetaV2Version
    			_, _ = x.unmarshalV(0, ver.meta)
    			b, _ = json.Marshal(x)
    			t.Log(string(b), x.getSignature())
    		}
    	}
    
    	for i := range vers {
    		t.Run(fmt.Sprintf("non-strict-q%d", i), func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server_gen.go

    	o = msgp.AppendArrayHeader(o, uint32(len(z.CmdLines)))
    	for za0001 := range z.CmdLines {
    		o = msgp.AppendString(o, z.CmdLines[za0001])
    	}
    	// string "MinioEnv"
    	o = append(o, 0xa8, 0x4d, 0x69, 0x6e, 0x69, 0x6f, 0x45, 0x6e, 0x76)
    	o = msgp.AppendMapHeader(o, uint32(len(z.MinioEnv)))
    	for za0002, za0003 := range z.MinioEnv {
    		o = msgp.AppendString(o, za0002)
    		o = msgp.AppendString(o, za0003)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  7. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt

            }
            is MappedRange.Inline2 -> {
              rangesBuffer.writeByte(range.b1)
              rangesBuffer.writeByte(range.b2)
              rangesBuffer.writeByte(range.b3)
            }
            is MappedRange.InlineDelta -> {
              rangesBuffer.writeByte(range.b1)
              rangesBuffer.writeByte(range.b2)
              rangesBuffer.writeByte(range.b3)
            }
            is MappedRange.External -> {
              // Write the mapping.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  8. cmd/admin-handlers_test.go

    	}
    
    	// Body is always valid - we do not test JSON decoding.
    	body := `{"recursive": false, "dryRun": true, "remove": false, "scanMode": 0}`
    
    	// Test all combinations!
    	for pIdx, params := range qParamsArr {
    		for vIdx, vars := range varsArr {
    			_, err := extractHealInitParams(vars, params, bytes.NewReader([]byte(body)))
    			isErrCase := false
    			if pIdx < 4 || vIdx < 1 {
    				isErrCase = true
    			}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  9. schema/relationship.go

    		refForeignFields = []*Field{}
    		for _, foreignKey := range relation.primaryKeys {
    			if field := relation.FieldSchema.LookUpField(foreignKey); field != nil {
    				refForeignFields = append(refForeignFields, field)
    			} else {
    				schema.err = fmt.Errorf("invalid foreign key: %s", foreignKey)
    				return
    			}
    		}
    	}
    
    	for idx, ownField := range ownForeignFields {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun Nov 16 04:11:05 UTC 2025
    - 23.1K bytes
    - Viewed (1)
  10. cmd/site-replication.go

    	allPolicies := set.NewStringSet()
    	for _, sri := range sris {
    		for b := range sri.Buckets {
    			allBuckets.Add(b)
    		}
    		for u := range sri.UserInfoMap {
    			allUsers.Add(u)
    		}
    		for g := range sri.GroupDescMap {
    			allGroups.Add(g)
    		}
    		for p := range sri.Policies {
    			allPolicies.Add(p)
    		}
    		for u := range sri.UserPolicies {
    			allUserWPolicies.Add(u)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
Back to top