Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 59 of 59 for Messages (0.15 sec)

  1. cmd/endpoint.go

    					resolvedList[i] = true
    					endpoints[i].IsLocal = true
    					epsResolved++
    					if !foundLocal {
    						foundLocal = true
    					}
    					continue
    				}
    
    				// Log the message to console about the host resolving
    				reqInfo := (&logger.ReqInfo{}).AppendTags(
    					"host",
    					endpoints[i].Hostname(),
    				)
    
    				if orchestrated && hostResolveToLocalhost(endpoints[i]) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  2. cmd/utils.go

    	ioutilx "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/logger/message/audit"
    	"github.com/minio/minio/internal/rest"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v2/certs"
    	"github.com/minio/pkg/v2/env"
    	xaudit "github.com/minio/pkg/v2/logger/message/audit"
    	xnet "github.com/minio/pkg/v2/net"
    	"golang.org/x/oauth2"
    )
    
    const (
    	slashSeparator = "/"
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance_gen.go

    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = rebalSaveOpts(zb0001)
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z rebalSaveOpts) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *rebalStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  4. cmd/bucket-replication-metrics_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z ActiveWorkerStat) Msgsize() (s int) {
    	s = 1 + 5 + msgp.IntSize + 4 + msgp.Float32Size + 4 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1_gen.go

    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = BitrotAlgorithm(zb0001)
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BitrotAlgorithm) Msgsize() (s int) {
    	s = msgp.UintSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ChecksumInfo) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 40.2K bytes
    - Viewed (0)
  6. cmd/prepare-storage.go

    	go renameAllBucketMetacache(diskPath)
    }
    
    // Following error message is added to fix a regression in release
    // RELEASE.2018-03-16T22-52-12Z after migrating v1 to v2 to v3. This
    // migration failed to capture '.This' field properly which indicates
    // the disk UUID association. Below error message is returned when
    // we see this situation in format.json, for more info refer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  7. cmd/handler-api.go

    		select {
    		case pool <- struct{}{}:
    			defer func() { <-pool }()
    			globalHTTPStats.addRequestsInQueue(-1)
    			f.ServeHTTP(w, r)
    		case <-deadlineTimer.C:
    			// Send a http timeout message
    			writeErrorResponse(r.Context(), w,
    				errorCodes.ToAPIErr(ErrTooManyRequests),
    				r.URL)
    			globalHTTPStats.addRequestsInQueue(-1)
    			return
    		case <-r.Context().Done():
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 10K bytes
    - Viewed (0)
  8. cmd/local-locker.go

    			continue
    		}
    		if ok {
    			reply = l.removeEntry(resource, args, &lri) || reply
    		}
    	}
    	return
    }
    
    // removeEntry based on the uid of the lock message, removes a single entry from the
    // lockRequesterInfo array or the whole array from the map (in case of a write lock
    // or last read lock)
    // UID and optionally owner must match for entries to be deleted.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. cmd/bucket-metadata_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *BucketMetadata) Msgsize() (s int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 25 05:52:39 GMT 2023
    - 22.1K bytes
    - Viewed (0)
Back to top