Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for initialize (0.07 sec)

  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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    }
    
    // srStateData represents the format of the current `srStateFile`.
    type srStateData struct {
    	Version int `json:"version"`
    
    	SRState srStateV1 `json:"srState"`
    }
    
    // Init - initialize the site replication manager.
    func (c *SiteReplicationSys) Init(ctx context.Context, objAPI ObjectLayer) error {
    	go c.startHealRoutine(ctx, objAPI)
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  6. doc/go1.17_spec.html

    Multiple variables on the left-hand side of a variable declaration initialized
    by single (multi-valued) expression on the right-hand side are initialized
    together: If any of the variables on the left-hand side is initialized, all
    those variables are initialized in the same step.
    </p>
    
    <pre>
    var x = a
    var a, b = f() // a and b are initialized together, before x is initialized
    </pre>
    
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.32.md

    - Fixes a bug in the `k8s.io/cloud-provider/service`  controller, it may panic when a service is updated because the event recorder was used before it was initialized. All cloud providers should using the `v1.31.0` cloud provider service controller must ensure that the controllers is initialized before the informer start to process events or update it to the version 1.32.0. ([#128179](https://github.com/kubernetes/kubernetes/pull/128179), [@carlory](https://github.com/carlory))...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Maps.java

       * href="https://docs.oracle.com/javase/tutorial/java/generics/genTypeInference.html#type-inference-instantiation">"diamond"
       * syntax</a>.
       *
       * @param map the map from which to initialize this {@code EnumMap}
       * @return a new {@code EnumMap} initialized with the mappings from {@code map}
       * @throws IllegalArgumentException if {@code m} is not an {@code EnumMap} instance and contains
       *     no mappings
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 161.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/Maps.java

       * href="https://docs.oracle.com/javase/tutorial/java/generics/genTypeInference.html#type-inference-instantiation">"diamond"
       * syntax</a>.
       *
       * @param map the map from which to initialize this {@code EnumMap}
       * @return a new {@code EnumMap} initialized with the mappings from {@code map}
       * @throws IllegalArgumentException if {@code m} is not an {@code EnumMap} instance and contains
       *     no mappings
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 167.4K bytes
    - Viewed (0)
  10. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top