Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for 9800000 (0.18 sec)

  1. docs/bucket/notifications/README.md

    delivery_mode  (number)    set to '1' for non-persistent or '2' for persistent queue
    queue_dir      (path)      staging dir for undelivered messages e.g. '/home/events'
    queue_limit    (number)    maximum limit for undelivered messages, defaults to '100000'
    comment        (sentence)  optionally add a comment to this setting
    ```
    
    Or environment variables
    
    ```
    KEY:
    notify_amqp[:name]  publish bucket notifications to AMQP endpoints
    
    ARGS:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  2. cmd/generic-handlers.go

    	maxHeaderSize = 8 * 1024
    
    	// Maximum size for user-defined metadata - See: https://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html
    	maxUserDataSize = 2 * 1024
    
    	// maxBuckets upto 500000 for any MinIO deployment.
    	maxBuckets = 500 * 1000
    )
    
    // ReservedMetadataPrefix is the prefix of a metadata key which
    // is reserved and for internal use only.
    const (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    	// Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers.
    	// Keep 100k buffered channel.
    	// If receiver cannot keep up with that we drop events.
    	traceCh := make(chan []byte, 100000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), traceCh, ctx.Done(), func(entry madmin.TraceInfo) bool {
    		return shouldTrace(entry, traceOpts)
    	}, nil)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  4. internal/config/notify/help.go

    	queueDirComment   = `staging dir for undelivered messages e.g. '/home/events'`
    	queueLimitComment = `maximum limit for undelivered messages, defaults to '100000'`
    )
    
    // Help template inputs for all notification targets
    var (
    	HelpWebhook = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.WebhookEndpoint,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  5. cmd/object-api-utils_test.go

    		data    []byte
    		wantIdx bool
    	}{
    		{name: "empty", data: nil},
    		{name: "small", data: []byte("hello, world!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!")},
    		{name: "large", data: bytes.Repeat([]byte("hello, world"), 1000000), wantIdx: true},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			buf := make([]byte, 100) // make small buffer to ensure multiple reads are required for large case
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    	if r.ContentLength <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingContentLength), r.URL)
    		return
    	}
    
    	// The max. XML contains 100000 object names (each at most 1024 bytes long) + XML overhead
    	const maxBodySize = 2 * 100000 * 1024
    
    	if r.ContentLength > maxBodySize {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEntityTooLarge), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  7. cmd/erasure-encode_test.go

    func BenchmarkErasureEncode_12_30MB(b *testing.B) {
    	const size = 30 * 1024 * 1024
    	b.Run(" 000000|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 0, size, b) })
    	b.Run(" 000000|X00000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 1, size, b) })
    	b.Run(" X00000|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 1, 0, size, b) })
    	b.Run(" 000000|XXXXX0 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 5, size, b) })
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.9K bytes
    - Viewed (0)
Back to top