Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for successors (0.27 sec)

  1. internal/event/target/kafka.go

    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	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)]
    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/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/erasure-metadata.go

    			maxHash = hash
    		}
    	}
    
    	if maxCount < quorum {
    		return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInconsistentMeta}
    	}
    
    	// Find the successor mod time in quorum, otherwise leave the
    	// candidate's successor modTime as found
    	succModTimeMap := make(map[time.Time]int)
    	var candidate FileInfo
    	var found bool
    	for i, hash := range metaHashes {
    		if hash == maxHash {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  4. cmd/object-api-datatypes.go

    	replicationDecision string // internal representation of replication decision for use by DeleteObject handler
    	// The total count of all versions of this object
    	NumVersions int
    	//  The modtime of the successor object version if any
    	SuccessorModTime time.Time
    
    	// Checksums added on upload.
    	// Encoded, maybe encrypted.
    	Checksum []byte
    
    	// Inlined
    	Inlined bool
    
    	DataBlocks   int
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  5. docs/metrics/v3.md

    | `minio_cluster_iam_sync_failures`                               | `counter` | Number of failed IAM data syncs since server start                                                                       |        |
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 28.5K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/list.md

    | `minio_node_iam_sync_failures`             | Number of failed IAM data syncs since server start.         |
    | `minio_node_iam_sync_successes`            | Number of successful IAM data syncs since server start.     |
    
    ## Information Lifecycle Management (ILM) Metrics
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 43.4K bytes
    - Viewed (2)
Back to top