Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for reducer (0.44 sec)

  1. docs/erasure/storage-class/README.md

    ### Allowed values for REDUCED_REDUNDANCY storage class
    
    `REDUCED_REDUNDANCY` implies lesser parity than `STANDARD` class. So,`REDUCED_REDUNDANCY` parity drives should be
    
    - Less than N/2, if `STANDARD` parity is not set.
    - Less than `STANDARD` Parity, if it is set.
    
    Default value for `REDUCED_REDUNDANCY` storage class is `1`.
    
    ## Get started with Storage Class
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 5.8K bytes
    - Viewed (1)
  2. internal/logger/target/kafka/kafka.go

    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    	sconfig.Producer.Timeout = (10 * time.Second)
    	sconfig.Net.ReadTimeout = (10 * time.Second)
    	sconfig.Net.DialTimeout = (10 * time.Second)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  3. cmd/iam-store.go

    			if err := store.loadUsers(ctx, regUser, newCache.iamUsersMap); err != nil {
    				return err
    			}
    			bootstrapTraceMsg("loading regular groups")
    			if err := store.loadGroups(ctx, newCache.iamGroupsMap); err != nil {
    				return err
    			}
    		}
    
    		bootstrapTraceMsg("loading user policy mapping")
    		// load polices mapped to users
    		if err := store.loadMappedPolicies(ctx, regUser, false, newCache.iamUserPolicyMap); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  4. internal/disk/fdatasync_linux.go

    // read to be handled correctly. On the other hand, a change to the file size
    // (st_size, as made by say ftruncate(2)), would require a metadata flush.
    //
    // The aim of fdatasync() is to reduce disk activity for applications that
    // do not require all metadata to be synchronized with the disk.
    func Fdatasync(f *os.File) error {
    	return syscall.Fdatasync(int(f.Fd()))
    }
    
    // FadviseDontNeed invalidates page-cache
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 29 23:40:28 GMT 2021
    - 1.8K bytes
    - Viewed (0)
  5. cmd/encryption-v1.go

    	if r.ContentLength > encryptBufferThreshold {
    		// The encryption reads in blocks of 64KB.
    		// We add a buffer on bigger files to reduce the number of syscalls upstream.
    		content = bufio.NewReaderSize(content, encryptBufferSize)
    	}
    
    	var (
    		key   []byte
    		keyID string
    		ctx   kms.Context
    		err   error
    	)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    					}
    				}
    			}
    		}
    	}
    
    	// Set skipParent to skip mkdirAll() calls for deeply nested objects
    	// - if its an overwrite
    	// - if its a versioned object
    	//
    	// This can potentiall reduce syscalls by strings.Split(path, "/")
    	// times relative to the object name.
    	skipParent := dstVolumeDir
    	if len(dstBuf) > 0 {
    		skipParent = pathutil.Dir(dstFilePath)
    	}
    
    	var reqVID string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    	config.Producer.Retry.Max = 2
    	config.Producer.Retry.Backoff = (1 * time.Second)
    	config.Producer.Return.Successes = true
    	config.Producer.Return.Errors = true
    	config.Producer.RequiredAcks = 1
    	config.Producer.Timeout = (5 * time.Second)
    	// Set Producer Compression
    	cc, ok := codecs[strings.ToLower(args.Producer.Compression)]
    	if ok {
    		config.Producer.Compression = cc
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  8. internal/bucket/replication/destination.go

    	// EncryptionConfiguration TODO: not needed for MinIO
    }
    
    func (d Destination) isValidStorageClass() bool {
    	if d.StorageClass == "" {
    		return true
    	}
    	return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY"
    }
    
    // IsValid - checks whether Destination is valid or not.
    func (d Destination) IsValid() bool {
    	return d.Bucket != "" || !d.isValidStorageClass()
    }
    
    func (d Destination) String() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4K bytes
    - Viewed (2)
  9. docs/config/README.md

    export MINIO_SITE_REGION="us-west-0"
    export MINIO_SITE_NAME="sfo-rack-1"
    minio server /data
    ```
    
    ### Storage Class
    
    By default, parity for objects with standard storage class is set to `N/2`, and parity for objects with reduced redundancy storage class objects is set to `2`. Read more about storage class support in MinIO server [here](https://github.com/minio/minio/blob/master/docs/erasure/storage-class/README.md).
    
    ```
    KEY:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  10. docs/throttle/README.md

    This value works in conjunction with max connection setting, setting this value allows for long waiting requests to quickly time out when there is no slot available to perform the request.
    
    This will reduce the pileup of waiting requests when clients are not configured with timeouts. Default wait time is *10 seconds* if *MINIO_API_REQUESTS_MAX* is enabled. This may need to be tuned to your application needs.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
Back to top