Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for follower (0.15 sec)

  1. docs/metrics/prometheus/README.md

    The command will generate the `scrape_configs` section of the prometheus.yml as follows:
    
    ##### Cluster
    
    ```yaml
    scrape_configs:
    - job_name: minio-job
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  2. internal/logger/targets.go

    	cnt := make(map[string]int, len(sys)+len(audit))
    
    	// Add system and audit.
    	for _, t := range sys {
    		key := strings.ToLower(t.Type().String())
    		n := cnt[key]
    		cnt[key]++
    		key = fmt.Sprintf("sys_%s_%d", key, n)
    		res[key] = t.Stats()
    	}
    
    	for _, t := range audit {
    		key := strings.ToLower(t.Type().String())
    		n := cnt[key]
    		cnt[key]++
    		key = fmt.Sprintf("audit_%s_%d", key, n)
    		res[key] = t.Stats()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    			}
    			if objRetention.Mode.Valid() {
    				oi.UserDefined[strings.ToLower(xhttp.AmzObjectLockMode)] = string(objRetention.Mode)
    				oi.UserDefined[strings.ToLower(xhttp.AmzObjectLockRetainUntilDate)] = amztime.ISO8601Format(objRetention.RetainUntilDate.UTC())
    			} else {
    				oi.UserDefined[strings.ToLower(xhttp.AmzObjectLockMode)] = ""
    				oi.UserDefined[strings.ToLower(xhttp.AmzObjectLockRetainUntilDate)] = ""
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  4. docs/hotfixes.md

    Once the **patch** is successfully applied, developer must run tests to validate the fix that was backported by running following tests, locally.
    
    Unit tests
    
    ```
    λ make test
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/api-utils.go

    			j++
    		}
    	}
    	return string(t)
    }
    
    // s3EncodeName encodes string in response when encodingType is specified in AWS S3 requests.
    func s3EncodeName(name, encodingType string) string {
    	if strings.ToLower(encodingType) == "url" {
    		return s3URLEncode(name)
    	}
    	return name
    }
    
    // getHandlerName returns the name of the handler function. It takes the type
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    	if s3Err == ErrNone && retentionMode.Valid() {
    		metadata[strings.ToLower(xhttp.AmzObjectLockMode)] = string(retentionMode)
    		metadata[strings.ToLower(xhttp.AmzObjectLockRetainUntilDate)] = amztime.ISO8601Format(retentionDate.UTC())
    	}
    	if s3Err == ErrNone && legalHold.Status.Valid() {
    		metadata[strings.ToLower(xhttp.AmzObjectLockLegalHold)] = string(legalHold.Status)
    	}
    	if s3Err != ErrNone {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  7. docs/kms/README.md

    ### 1. Fetch the root identity
    
    As the initial step, fetch the private key and certificate of the root identity:
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  8. internal/event/target/kafka.go

    	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
    		config.Producer.CompressionLevel = args.Producer.CompressionLevel
    	}
    
    	config.Net.ReadTimeout = (5 * time.Second)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    			Object: object,
    		}
    	}
    
    	if opts.DeletePrefix {
    		if opts.Expiration.Expire {
    			// Expire all versions expiration must still verify the state() on disk
    			// via a getObjectInfo() call as follows, any read quorum issues we
    			// must not proceed further for safety reasons. attempt a MRF heal
    			// while we see such quorum errors.
    			goi, _, gerr := er.getObjectInfoAndQuorum(ctx, bucket, object, opts)
    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)
  10. cmd/erasure-server-pool.go

    		// as a List() call is an important performance improvement.
    		//
    		// Spark based s3a committers are a  big enough use-case to have this optimization.
    		//
    		// A sample code to see the improvements is as follows, this sample code is
    		// simply a read on JSON from MinIO and write it back as "parquet".
    		//
    		// import org.apache.spark.sql.SparkSession
    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)
Back to top