Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 236 for Leader (0.2 sec)

  1. cmd/globals.go

    	// Allocated DNS config wrapper over etcd client.
    	globalDNSConfig dns.Store
    
    	// GlobalKMS initialized KMS configuration
    	GlobalKMS kms.KMS
    
    	// Common lock for various subsystems performing the leader tasks
    	globalLeaderLock *sharedLock
    
    	// Auto-Encryption, if enabled, turns any non-SSE-C request
    	// into an SSE-S3 request. If enabled a valid, non-empty KMS
    	// configuration must be present.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		return err
    	}
    
    	if len(data) == 0 {
    		return nil
    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("rebalanceMeta: no data")
    	}
    
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case rebalMetaFmt:
    	default:
    		return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2]))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.30.md

    - Client-go: Optimized leaders renewing leases by updating leader lock optimistically without getting the record from the API server first. Also, a new metric `leader_election_slowpath_total` was added to allow users to monitor how many leader elections are updated non-optimistically.
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Wed Apr 17 17:56:15 GMT 2024
    - 227.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    		globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock")
    	})
    
    	// Enable background operations on
    	//
    	// - Disk auto healing
    	// - MRF (most recently failed) healing
    	// - Background expiration routine for lifecycle policies
    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)
  5. CHANGELOG/CHANGELOG-1.28.md

    - The deprecated flag `--lock-object-namespace` and `--lock-object-name` have been removed from kube-scheduler. Please use `--leader-elect-resource-namespace` and `--leader-elect-resource-name` or ComponentConfig instead to configure those parameters. ([#119130](https://github.com/kubernetes/kubernetes/pull/119130), [@SataQiu](https://github.com/SataQiu)) [SIG Scheduling]
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Tue Apr 16 20:44:48 GMT 2024
    - 385.1K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    - Adds feature gate `NodeLogQuery` which provides cluster administrators with a streaming view of logs using kubectl without them having to implement a client side reader or logging into the node. ([#96120](https://github.com/kubernetes/kubernetes/pull/96120), [@LorbusChris](https://github.com/LorbusChris))
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Tue Apr 16 15:20:21 GMT 2024
    - 434.3K bytes
    - Viewed (3)
  7. fastapi/security/http.py

        The HTTP authorization header value is split by the first space.
    
        The first part is the `scheme`, the second part is the `credentials`.
    
        For example, in an HTTP Bearer token scheme, the client will send a header
        like:
    
        ```
        Authorization: Bearer deadbeef12346
        ```
    
        In this case:
    
        * `scheme` will have the value `"Bearer"`
    Python
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Fri Apr 19 15:29:38 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

          check(type == -1)
          this.type = Http2.TYPE_SETTINGS
          this.ack = true
        }
    
        override fun headers(
          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
          headerBlock: List<Header>,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_HEADERS
          this.inFinished = inFinished
          this.streamId = streamId
          this.associatedStreamId = associatedStreamId
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  9. internal/rest/client.go

    	if err != nil {
    		return
    	}
    
    	// Filter out Signature field from Authorization header.
    	origAuth := req.Header.Get("Authorization")
    	if origAuth != "" {
    		req.Header.Set("Authorization", "**REDACTED**")
    	}
    
    	// Only display request header.
    	reqTrace, err := httputil.DumpRequestOut(req, false)
    	if err != nil {
    		return
    	}
    
    	// Write request to trace output.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        internal val reader: Http2Reader,
      ) : Http2Reader.Handler, () -> Unit {
        override fun invoke() {
          var connectionErrorCode = ErrorCode.INTERNAL_ERROR
          var streamErrorCode = ErrorCode.INTERNAL_ERROR
          var errorException: IOException? = null
          try {
            reader.readConnectionPreface(this)
            while (reader.nextFrame(false, this)) {
            }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
Back to top