- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 916 for leader (0.18 sec)
-
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) -
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) -
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) -
CHANGELOG/CHANGELOG-1.34.md
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Dec 10 01:13:50 UTC 2025 - 333.3K bytes - Viewed (1) -
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) -
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) -
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) -
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) -
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) -
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)