Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 684 for sonst (0.02 sec)

  1. internal/s3select/csv/reader.go

    	dst = append(dst, in...)
    	return dst, err
    }
    
    // csvSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    	QueueDir          string   `json:"queueDir"`
    	QueueLimit        uint64   `json:"queueLimit"`
    }
    
    //lint:file-ignore ST1003 We cannot change these exported names.
    
    // AMQP input constants.
    const (
    	AmqpQueueDir   = "queue_dir"
    	AmqpQueueLimit = "queue_limit"
    
    	AmqpURL               = "url"
    	AmqpExchange          = "exchange"
    	AmqpRoutingKey        = "routing_key"
    	AmqpExchangeType      = "exchange_type"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. internal/event/targetlist.go

    package event
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync"
    	"sync/atomic"
    
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/store"
    	"github.com/minio/pkg/v3/workers"
    )
    
    const (
    	logSubsys = "notify"
    
    	// The maximum allowed number of concurrent Send() calls to all configured notifications targets
    	maxConcurrentAsyncSend = 50000
    )
    
    // Target - event target interface
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. cmd/handler-api.go

    	enableODirect               bool
    	gzipObjects                 bool
    	rootAccess                  bool
    	syncEvents                  bool
    	objectMaxVersions           int64
    }
    
    const (
    	cgroupV1MemLimitFile = "/sys/fs/cgroup/memory/memory.limit_in_bytes"
    	cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max"
    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. docs/fr/docs/tutorial/query-params-str-validations.md

    ```Python
    q: Union[str, None] = Query(default=None, max_length=50)
    ```
    
    Cela va valider les données, montrer une erreur claire si ces dernières ne sont pas valides, et documenter le paramètre dans le schéma `OpenAPI` de cette *path operation*.
    
    ## Rajouter plus de validation
    
    Vous pouvez aussi rajouter un second paramètre `min_length` :
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 17:14:38 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. cmd/encryption-v1.go

    	errInvalidEncryptionParameters     = errors.New("The encryption parameters are not applicable to this object")
    	errInvalidEncryptionParametersSSEC = errors.New("SSE-C encryption parameters are not supported on this bucket")
    )
    
    const (
    	// SSECustomerKeySize is the size of valid client provided encryption keys in bytes.
    	// Currently AWS supports only AES256. So the SSE-C key size is fixed to 32 bytes.
    	SSECustomerKeySize = 32
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    // than small data threshold and checks reading them again
    func TestPutObjectSmallInlineData(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	const numberOfDisks = 4
    
    	// Create an instance of xl backend.
    	obj, fsDirs, err := prepareErasure(ctx, numberOfDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Cleanup backend directories.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    			if !errors.Is(err, context.Canceled) {
    				storageLogIf(ctx, fmt.Errorf("saving pool.bin for pool index %d failed with: %v", i, err))
    			}
    			return err
    		}
    	}
    	return nil
    }
    
    const (
    	poolMetaName      = "pool.bin"
    	poolMetaFormat    = 1
    	poolMetaVersionV1 = 1
    	poolMetaVersion   = poolMetaVersionV1
    )
    
    // Init() initializes pools and saves additional information about them
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    		globalBucketTargetSys.set(buckets[i], meta) // set remote replication targets
    	}
    }
    
    func (sys *BucketMetadataSys) refreshBucketsMetadataLoop(ctx context.Context) {
    	const bucketMetadataRefresh = 15 * time.Minute
    
    	sleeper := newDynamicSleeper(2, 150*time.Millisecond, false)
    
    	t := time.NewTimer(bucketMetadataRefresh)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  10. cmd/bucket-targets.go

    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/kms"
    )
    
    const (
    	defaultHealthCheckDuration = 5 * time.Second
    	// default interval for reload of all remote target endpoints
    	defaultHealthCheckReloadDuration = 30 * time.Minute
    )
    
    type arnTarget struct {
    	Client      *TargetClient
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top