Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 14 for Initialize (0.06 seconds)

  1. cmd/object-handlers_test.go

    			expectedRespStatus: http.StatusForbidden,
    		},
    	}
    
    	// Iterating over the cases, fetching the object validating the response.
    	for i, testCase := range testCases {
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    		// construct HTTP request for Get Object end point.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  2. cmd/object-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Err != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream chunked reader with optional trailers.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  3. cmd/bucket-replication.go

    }
    
    // save resync status to resync.bin
    func saveResyncStatus(ctx context.Context, bucket string, brs BucketReplicationResyncStatus, objectAPI ObjectLayer) error {
    	data := make([]byte, 4, brs.Msgsize()+4)
    
    	// Initialize the resync meta header.
    	binary.LittleEndian.PutUint16(data[0:2], resyncMetaFormat)
    	binary.LittleEndian.PutUint16(data[2:4], resyncMetaVersion)
    
    	buf, err := brs.MarshalMsg(data)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  4. cmd/site-replication.go

    		duration := max(time.Duration(r.Float64()*float64(time.Minute)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    	c.RLock()
    	defer c.RUnlock()
    	if c.enabled {
    		logger.Info("Cluster replication initialized")
    	}
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  5. cmd/admin-handlers.go

    			return
    		}
    		// Zero nonce, we only use each key once, and 32 bytes is plenty.
    		nonce := make([]byte, stream.NonceSize())
    		encw := stream.EncryptWriter(w, nonce, nil)
    		defer encw.Close()
    
    		// Initialize a zip writer which will provide a zipped content
    		// of profiling data of all nodes
    		inspectZipW = zip.NewWriter(encw)
    		defer inspectZipW.Close()
    
    		if b := getClusterMetaInfo(ctx); len(b) > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  6. cmd/metrics-v2.go

    }
    
    // MetricsGroupV2 are a group of metrics that are initialized together.
    type MetricsGroupV2 struct {
    	metricsCache     *cachevalue.Cache[[]MetricV2] `msg:"-"`
    	cacheInterval    time.Duration
    	metricsGroupOpts MetricsGroupOpts
    }
    
    // MetricsGroupOpts are a group of metrics opts to be used to initialize the metrics group.
    type MetricsGroupOpts struct {
    	dependGlobalObjectAPI           bool
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  7. src/main/webapp/js/bootstrap.min.js.map

    getComputedStyle(this._element).overflowY === 'visible' ? null : this._element\n    this._activeTarget = null\n    this._observer = null\n    this._previousScrollData = {\n      visibleEntryTop: 0,\n      parentScrollTop: 0\n    }\n    this.refresh() // initialize\n  }\n\n  // Getters\n  static get Default() {\n    return Default\n  }\n\n  static get DefaultType() {\n    return DefaultType\n  }\n\n  static get NAME() {\n    return NAME\n  }\n\n  // Public\n  refresh() {\n    this._initializeTargetsAndObservables()\n...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 12 06:14:02 GMT 2025
    - 211.9K bytes
    - Click Count (0)
  8. CHANGELOG/CHANGELOG-1.36.md

    - Fix a bug where the DRA manager did not initialize sharedID from cache when DRAConsumableCapacity is enabled. ([#136734](https://github.com/kubernetes/kubernetes/pull/136734), [@sunya-ch](https://github.com/sunya-ch)) [SIG Node and Scheduling]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 23:38:00 GMT 2026
    - 142.1K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.4.md

        * Any code that inspects this annotation should be changed to use the new key.
          State of Initialization will continue to be reported in both pods.alpha.kubernetes.io/initialized
          and in `podStatus.conditions.{status: "True", type: Initialized}`
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 133.5K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.5.md

    * Add a new option "--local" to the `kubectl label` ([#33990](https://github.com/kubernetes/kubernetes/pull/33990), [@asalkeld](https://github.com/asalkeld))
    * Initialize podsWithAffinity to avoid scheduler panic ([#33967](https://github.com/kubernetes/kubernetes/pull/33967), [@xiang90](https://github.com/xiang90))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 136.4K bytes
    - Click Count (0)
Back to Top