Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 326 for atomic (0.04 seconds)

  1. internal/logger/help.go

    		config.HelpKV{
    			Key:         KafkaBrokers,
    			Description: "comma separated list of Kafka broker addresses",
    			Type:        "csv",
    		},
    		config.HelpKV{
    			Key:         KafkaTopic,
    			Description: "Kafka topic used for bucket notifications",
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         KafkaSASLUsername,
    			Description: "username for SASL/PLAIN or SASL/SCRAM authentication",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Sep 11 22:20:42 GMT 2024
    - 7.4K bytes
    - Click Count (0)
  2. logger/sql.go

    		sql = newSQL.String()
    	} else {
    		sql = numericPlaceholder.ReplaceAllString(sql, "$$$1$$")
    
    		sql = numericPlaceholderRe.ReplaceAllStringFunc(sql, func(v string) string {
    			num := v[1 : len(v)-1]
    			n, _ := strconv.Atoi(num)
    
    			// position var start from 1 ($1, $2)
    			n -= 1
    			if n >= 0 && n <= len(vars)-1 {
    				return vars[n]
    			}
    			return v
    		})
    	}
    
    	return sql
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Mar 21 08:00:02 GMT 2024
    - 5K bytes
    - Click Count (0)
  3. internal/s3select/csv/record.go

    func (r *Record) Get(name string) (*sql.Value, error) {
    	index, found := r.nameIndexMap[name]
    	if !found {
    		// Check if index.
    		if after, ok := strings.CutPrefix(name, "_"); ok {
    			idx, err := strconv.Atoi(after)
    			if err != nil {
    				return nil, fmt.Errorf("column %v not found", name)
    			}
    			// The position count starts at 1.
    			idx--
    			if idx >= len(r.csvRecord) || idx < 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  4. internal/store/store.go

    		if k.Compress {
    			return compressExt
    		}
    		return ""
    	}()
    }
    
    func getItemCount(k string) (count int, err error) {
    	count = 1
    	v := strings.Split(k, ":")
    	if len(v) == 2 {
    		return strconv.Atoi(v[0])
    	}
    	return count, err
    }
    
    func parseKey(k string) (key Key) {
    	key.Name = k
    	if strings.HasSuffix(k, compressExt) {
    		key.Compress = true
    		key.Name = strings.TrimSuffix(key.Name, compressExt)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. docs/debugging/pprofgoparser/main.go

    				ret[t] = append(ret[t], stackTrace)
    			}
    		case record:
    			save(line)
    		default:
    			z := goroutinesRE.FindStringSubmatch(line)
    			if len(z) == 3 {
    				if z[2] != "" {
    					a, _ := strconv.Atoi(z[2])
    					t = time.Duration(a) * time.Minute
    					save(line)
    					record = true
    				} else {
    					skip = true
    				}
    			}
    		}
    	}
    
    	return ret, nil
    }
    
    const helpUsage = `
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Mar 06 11:43:16 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  6. internal/config/storageclass/storage-class_test.go

    		},
    		{
    			"EC:4:5",
    			StorageClass{
    				Parity: 4,
    			},
    			errors.New("Too many sections in EC:4:5"),
    		},
    		{
    			"EC:A",
    			StorageClass{
    				Parity: 4,
    			},
    			errors.New(`strconv.Atoi: parsing "A": invalid syntax`),
    		},
    		{
    			"AB",
    			StorageClass{
    				Parity: 4,
    			},
    			errors.New("Too few sections in AB"),
    		},
    	}
    	for i, tt := range tests {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 4.3K bytes
    - Click Count (0)
  7. cmd/background-heal-ops.go

    		}
    	}
    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    
    	if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" {
    		if numHealers, err := strconv.Atoi(envHealWorkers); err != nil {
    			bugLogIf(context.Background(), fmt.Errorf("invalid _MINIO_HEAL_WORKERS value: %w", err))
    		} else {
    			workers = numHealers
    		}
    	}
    
    	if workers == 0 {
    		workers = 4
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. cmd/object-api-options.go

    	var opts ObjectOptions
    
    	var partNumber int
    	var err error
    	if pn := r.Form.Get(xhttp.PartNumber); pn != "" {
    		partNumber, err = strconv.Atoi(pn)
    		if err != nil {
    			return opts, err
    		}
    		if isMaxPartID(partNumber) {
    			return opts, errInvalidMaxParts
    		}
    		if partNumber <= 0 {
    			return opts, errInvalidArgument
    		}
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  9. docs/tr/docs/project-generation.md

    * Atom Hydrogen veya Visual Studio Code Jupyter gibi uzantılarla uzaktan veya Docker içi geliştirme için **Jupyter Çekirdekleri** ile kolay Python entegrasyonu.
    * **Vue** ile frontend:
        * Vue CLI ile oluşturulmuş.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Jul 29 23:35:07 GMT 2024
    - 6K bytes
    - Click Count (0)
  10. cmd/ftp-server.go

    			host, portStr, err := net.SplitHostPort(tokens[1])
    			if err != nil {
    				logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server")
    			}
    			port, err = strconv.Atoi(portStr)
    			if err != nil {
    				logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server")
    			}
    			if port < 1 || port > 65535 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
Back to Top