Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 916 for leader (0.04 sec)

  1. cmd/callhome.go

    	var b bytes.Buffer
    	gzWriter := gzip.NewWriter(&b)
    
    	header := struct {
    		Version string `json:"version"`
    	}{Version: healthInfo.Version}
    
    	enc := json.NewEncoder(gzWriter)
    	if e := enc.Encode(header); e != nil {
    		internalLogIf(ctx, fmt.Errorf("Could not encode health info header: %w", e))
    		return nil
    	}
    
    	if e := enc.Encode(healthInfo); e != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. cmd/admin-handlers-pools.go

    		return
    	}
    
    	writeSuccessResponseJSON(w, b)
    	// Notify peers to load rebalance.bin and start rebalance routine if they happen to be
    	// participating pool's leader node
    	globalNotificationSys.LoadRebalanceMeta(ctx, true)
    }
    
    func (a adminAPIHandlers) RebalanceStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    	}
    	z.rebalMu.RUnlock()
    
    	for poolIdx, doRebalance := range participants {
    		if !doRebalance {
    			continue
    		}
    		// nothing to do if this node is not pool's first node (i.e pool's rebalance 'leader').
    		if !globalEndpoints[poolIdx].Endpoints[0].IsLocal {
    			continue
    		}
    
    		go func(idx int) {
    			stopfn := globalRebalanceMetrics.log(rebalanceMetricRebalanceBuckets, idx)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 28.7K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.34.md

    - Removed "endpoint-controller" and "workload-leader-election" FlowSchemas from the default APF configuration.
      
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Dec 10 01:13:50 UTC 2025
    - 333.3K bytes
    - Viewed (1)
  5. internal/bucket/bandwidth/reader.go

    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    	if hdr > 0 { // available tokens go towards header first
    		if hdr < b { // all of header can be accommodated
    			r.opts.HeaderSize = 0
    			need = int(math.Min(float64(b-hdr), float64(need))) // use remaining tokens towards payload
    			tokens = need + hdr
    		} else { // part of header can be accommodated
    			r.opts.HeaderSize -= b - 1
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.32.md

    - kube-apiserver: a new `--requestheader-uid-headers` flag allows configuring request header authentication to obtain the authenticating user's UID from the specified headers. The suggested value for the new option is `X-Remote-Uid`. When specified, the `kube-system/extension-apiserver-authentication` configmap will include the value in its `.data[requestheader-uid-headers]` field. ([#115834](https://github.com/kubernetes/kubernetes/pull/115834), [@stlaz](...
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Tue Dec 16 18:27:41 UTC 2025
    - 448.1K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    	// Initialize the pool meta, but set it to not save.
    	// When z.Init below has loaded the poolmeta will be initialized,
    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    		globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock")
    	})
    
    	// Start self healing after the object initialization
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  8. docs/de/docs/tutorial/header-param-models.md

    Sie können die erforderlichen Header in der Dokumentationsoberfläche unter `/docs` sehen:
    
    <div class="screenshot">
    <img src="/img/tutorial/header-param-models/image01.png">
    </div>
    
    ## Zusätzliche Header verbieten { #forbid-extra-headers }
    
    In einigen speziellen Anwendungsfällen (wahrscheinlich nicht sehr häufig) möchten Sie möglicherweise die **Header einschränken**, die Sie erhalten möchten.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Sep 20 15:10:09 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  9. internal/s3select/parquet/reader.go

    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Reader implements reading records from parquet input.
    type Reader struct {
    	io.Closer
    	r *parquetgo.FileReader
    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) {
    	fr, err := parquetgo.NewFileReader(rsc)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  10. docs/de/docs/tutorial/header-params.md

    # Header-Parameter { #header-parameters }
    
    Sie können Header-Parameter genauso definieren, wie Sie `Query`-, `Path`- und `Cookie`-Parameter definieren.
    
    ## `Header` importieren { #import-header }
    
    Importieren Sie zuerst `Header`:
    
    {* ../../docs_src/header_params/tutorial001_an_py310.py hl[3] *}
    
    ## `Header`-Parameter deklarieren { #declare-header-parameters }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Sep 20 15:10:09 UTC 2025
    - 3.5K bytes
    - Viewed (0)
Back to top