Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for follower (0.18 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. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	"crypto/sha512"
    	"strings"
    
    	"github.com/IBM/sarama"
    	"github.com/xdg/scram"
    
    	"github.com/minio/minio/internal/hash/sha256"
    )
    
    func initScramClient(cfg Config, config *sarama.Config) {
    	switch strings.ToLower(cfg.SASL.Mechanism) {
    	case "sha512":
    		config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  6. 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)
  7. 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)
  8. internal/event/target/webhook.go

    	target.addr = args.Endpoint.Host
    	if _, _, err := net.SplitHostPort(args.Endpoint.Host); err != nil && strings.Contains(err.Error(), "missing port in address") {
    		switch strings.ToLower(args.Endpoint.Scheme) {
    		case "http":
    			target.addr += ":80"
    		case "https":
    			target.addr += ":443"
    		default:
    			return nil, errors.New("unsupported scheme")
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top