Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for yang (0.16 sec)

  1. internal/event/target/kafka.go

    	config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth
    	config.Net.TLS.Config.RootCAs = args.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// 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
    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

    	sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth
    	sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// 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
    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/storage-datatypes.go

    //   - on xl.meta (array of versions) on disk to check for version disparity
    //   - on rewrite dataDir on disk that must be additionally purged
    //     only after as a 2-phase call, allowing the older dataDir to
    //     hang-around in-case we need some form of recovery.
    type RenameDataResp struct {
    	Sign       []byte
    	OldDataDir string // contains '<uuid>', it is designed to be passed as value to Delete(bucket, pathJoin(object, dataDir))
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  4. docs/metrics/v3.md

    | `/system/network/internode` | Metrics about internode requests made by the node |
    | `/system/process`           | Standard process metrics                          |
    | `/system/go`                | Standard Go lang metrics                          |
    |                             |                                                   |
    
    ### Cluster metrics
    
    These present metrics about the whole MinIO cluster.
    
    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)
  5. cmd/bucket-replication.go

    					return putOpts, err
    				}
    			}
    			putOpts.Internal.TaggingTimestamp = tagTimestamp
    		}
    	}
    
    	lkMap := caseInsensitiveMap(objInfo.UserDefined)
    	if lang, ok := lkMap.Lookup(xhttp.ContentLanguage); ok {
    		putOpts.ContentLanguage = lang
    	}
    	if disp, ok := lkMap.Lookup(xhttp.ContentDisposition); ok {
    		putOpts.ContentDisposition = disp
    	}
    	if cc, ok := lkMap.Lookup(xhttp.CacheControl); ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  6. CREDITS

    github.com/zeebo/xxh3
    https://github.com/zeebo/xxh3
    ----------------------------------------------------------------
    xxHash Library
    Copyright (c) 2012-2014, Yann Collet
    Copyright (c) 2019, Jeff Wendling
    All rights reserved.
    
    Redistribution and use in source and binary forms, with or without modification,
    are permitted provided that the following conditions are met:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 1.6M bytes
    - Viewed (0)
Back to top