Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 711 - 720 of 982 for Pool (0.02 seconds)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  2. cmd/peer-rest-server.go

    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && values.Get(peerRESTListenBucket) != "" {
    			if ev.S3.Bucket.Name != values.Get(peerRESTListenBucket) {
    				return false
    			}
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  3. docs/debugging/inspect/export.go

    	"io"
    	"os"
    	"strings"
    	"time"
    
    	json "github.com/minio/colorjson"
    
    	"github.com/klauspost/compress/zip"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func inspectToExportType(downloadPath string, datajson bool) error {
    	decode := func(r io.Reader, file string) ([]byte, error) {
    		b, e := io.ReadAll(r)
    		if e != nil {
    			return nil, e
    		}
    		b, _, minor, e := checkXL2V1(b)
    		if e != nil {
    			return nil, e
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (1)
  4. internal/disk/stat_solaris.go

    package disk
    
    import (
    	"errors"
    	"fmt"
    
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := unix.Statvfs_t{}
    	if err = unix.Statvfs(path, &s); err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  5. cmd/object-api-putobject_test.go

    		bucketName    string
    		objName       string
    		inputData     []byte
    		inputMeta     map[string]string
    		inputDataSize int64
    		// flag indicating whether the test should pass.
    		shouldPass bool
    		// expected error output.
    		expectedMd5   string
    		expectedError error
    	}{
    		// Validating for success cases.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
  6. internal/bucket/encryption/bucket-sse-config.go

    		config.XMLNS = xmlNS
    	}
    	return &config, nil
    }
    
    // ApplyOptions ask for specific features to be enabled,
    // when bucketSSEConfig is empty.
    type ApplyOptions struct {
    	AutoEncrypt bool
    }
    
    // Apply applies the SSE bucket configuration on the given HTTP headers and
    // sets the specified SSE headers.
    //
    // Apply does not overwrite any existing SSE headers. Further, it will
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 4.9K bytes
    - Click Count (0)
  7. internal/disk/stat_linux.go

    	"strings"
    	"syscall"
    
    	"github.com/prometheus/procfs/blockdevice"
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, firstTime bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  8. docs/uk/docs/python-types.md

    Python підтримує додаткові "підказки типу" ("type hints") (також звані "анотаціями типу" ("type annotations")).
    
    Ці **"type hints"** є спеціальним синтаксисом, що дозволяє оголошувати <abbr title="наприклад: str, int, float, bool">тип</abbr> змінної.
    
    За допомогою оголошення типів для ваших змінних, редактори та інструменти можуть надати вам кращу підтримку.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Nov 18 02:25:44 GMT 2024
    - 19.4K bytes
    - Click Count (0)
  9. docs/zh/docs/python-types.md

    # Python 类型提示简介
    
    **Python 3.6+ 版本**加入了对"类型提示"的支持。
    
    这些**"类型提示"**是一种新的语法(在 Python 3.6 版本加入)用来声明一个变量的<abbr title="例如:str、int、float、bool">类型</abbr>。
    
    通过声明变量的类型,编辑器和一些工具能给你提供更好的支持。
    
    这只是一个关于 Python 类型提示的**快速入门 / 复习**。它仅涵盖与 **FastAPI** 一起使用所需的最少部分...实际上只有很少一点。
    
    整个 **FastAPI** 都基于这些类型提示构建,它们带来了许多优点和好处。
    
    但即使你不会用到 **FastAPI**,了解一下类型提示也会让你从中受益。
    
    /// note
    
    如果你已经精通 Python,并且了解关于类型提示的一切知识,直接跳到下一章节吧。
    
    ///
    
    ## 动机
    
    让我们从一个简单的例子开始:
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Aug 18 06:34:40 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  10. src/archive/tar/reader.go

    			// the parser is more liberal than what USTAR actually permits.
    			notASCII := func(r rune) bool { return r >= 0x80 }
    			if bytes.IndexFunc(tr.blk[:], notASCII) >= 0 {
    				hdr.Format = FormatUnknown // Non-ASCII characters in block.
    			}
    			nul := func(b []byte) bool { return int(b[len(b)-1]) == 0 }
    			if !(nul(v7.size()) && nul(v7.mode()) && nul(v7.uid()) && nul(v7.gid()) &&
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 26.9K bytes
    - Click Count (0)
Back to Top