Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Meyers (0.2 sec)

  1. cmd/object-handlers.go

    		return defaultMeta, nil
    	}
    
    	// Copy is default behavior if not x-amz-metadata-directive is set.
    	return defaultMeta, nil
    }
    
    // getRemoteInstanceTransport contains a roundtripper for external (not peers) servers
    var remoteInstanceTransport atomic.Value
    
    func setRemoteInstanceTransport(tr http.RoundTripper) {
    	remoteInstanceTransport.Store(tr)
    }
    
    func getRemoteInstanceTransport() http.RoundTripper {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    	// expected in case of read timeout
    	w.Header().Set("Connection", "close")
    
    	setEventStreamHeaders(w)
    
    	logCh := make(chan log.Info, 1000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    	encodedCh := make(chan []byte, 1000+len(peers)*1000)
    	err = globalConsoleSys.Subscribe(logCh, ctx.Done(), node, limitLines, logKind, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  3. cmd/site-replication.go

    		})
    	}
    	if err != nil {
    		return errSRServiceAccount(fmt.Errorf("unable to create service account on %s: %v", ourName, err))
    	}
    
    	peers := make(map[string]madmin.PeerInfo, len(arg.Peers))
    	for dID, pi := range arg.Peers {
    		if c.state.Peers != nil {
    			if existingPeer, ok := c.state.Peers[dID]; ok {
    				// retain existing ReplicateILMExpiry of peer if its already set
    				// and incoming arg has it false. it could be default false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
Back to top