Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for Produced (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. internal/config/api/help.go

    			Optional:    true,
    			Type:        "duration",
    		},
    		config.HelpKV{
    			Key:         apiListQuorum,
    			Description: `set the acceptable quorum expected for list operations e.g. "optimal", "reduced", "disk", "strict", "auto"` + defaultHelpPostfix(apiListQuorum),
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         apiReplicationPriority,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 15 01:07:19 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_linux.go

    		// if paths didn't match then we do have cross-device mount.
    		return fmt.Errorf(msg, path, crossMounts)
    	}
    	return nil
    }
    
    // readProcMounts reads the given mountFilePath (normally /proc/mounts) and produces a hash
    // of the contents.  If the out argument is not nil, this fills it with MountPoint structs.
    func readProcMounts(mountFilePath string) (mountInfos, error) {
    	file, err := os.Open(mountFilePath)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  6. internal/crypto/error.go

    	errInvalidInternalSealAlgorithm = Errorf("The internal seal algorithm is invalid and not supported")
    )
    
    // errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able
    // to produce enough random data. This is fatal error and should cause a panic.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    // which decides which condition it is useful to check if an object is dangling
    //
    //	  errs: errors from reading xl.meta in all disks
    //	   err: reduced errs
    //	bucket: the object name in question
    func shouldCheckForDangling(err error, errs []error, bucket string) bool {
    	// Avoid data in .minio.sys for now
    	if bucket == minioMetaBucket {
    		return false
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  8. internal/s3select/sql/value.go

    	errCmpMismatchedTypes     = errors.New("cannot compare values of different types")
    	errCmpInvalidBoolOperator = errors.New("invalid comparison operator for boolean arguments")
    )
    
    // Value represents a value of restricted type reduced from an
    // expression represented by an ASTNode. Only one of the fields is
    // non-nil.
    //
    // In cases where we are fetching data from a data source (like csv),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    	var localDrives []StorageAPI
    	local := endpointServerPools.FirstLocal()
    	for i, ep := range endpointServerPools {
    		// If storage class is not set during startup, default values are used
    		// -- Default for Reduced Redundancy Storage class is, parity = 2
    		// -- Default for Standard Storage class is, parity = 2 - disks 4, 5
    		// -- Default for Standard Storage class is, parity = 3 - disks 6, 7
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    	}
    }
    
    func getNodeRRSParityMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: storageClassSubsystem,
    		Name:      "rrs_parity",
    		Help:      "reduced redundancy storage class parity",
    		Type:      gaugeMetric,
    	}
    }
    
    func getNodeDrivesFreeInodesMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top