Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for Kass (0.13 sec)

  1. cmd/metrics.go

    			prometheus.GaugeValue,
    			float64(v), string(k),
    		)
    	}
    	for k, v := range bgSeq.getHealFailedItemsMap() {
    		// healFailedItemsMap stores the endpoint and volume state separated by comma,
    		// split the fields and pass to channel at correct index
    		s := strings.Split(k, ",")
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(healMetricsNamespace, "objects", "heal_failed"),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  2. cmd/sts-handlers_test.go

    				suite.SetUpSuite(c)
    				defer suite.TearDownSuite(c)
    
    				err := suite.SetUpOpenIDs(c, testApps, rolePolicies)
    				if err != nil {
    					c.Fatalf("config with 1 claim based and 1 role based provider should pass but got: %v", err)
    				}
    			},
    		)
    	}
    }
    
    func TestIAMWithOpenIDMultipleConfigsValidation2(t *testing.T) {
    	openIDServer := os.Getenv(EnvTestOpenIDServer)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    	objectEncryption = objectEncryption || crypto.IsSourceEncrypted(srcInfo.UserDefined)
    
    	var compressMetadata map[string]string
    	// No need to compress for remote etcd calls
    	// Pass the decompressed stream to such calls.
    	isDstCompressed := isCompressible(r.Header, dstObject) &&
    		length > minCompressibleSize &&
    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)
  4. cmd/sftp-server.go

    		Config: ssh.Config{
    			KeyExchanges: allowKexAlgos,
    			Ciphers:      allowCiphers,
    			MACs:         allowMACs,
    		},
    		PublicKeyAuthAlgorithms: allowPubKeys,
    		PasswordCallback: func(c ssh.ConnMetadata, pass []byte) (*ssh.Permissions, error) {
    			if globalIAMSys.LDAPConfig.Enabled() {
    				sa, _, err := globalIAMSys.getServiceAccount(context.Background(), c.User())
    				if err != nil && !errors.Is(err, errNoSuchServiceAccount) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    	// from latestFileInfo to get the quorum
    	return dataBlocks, writeQuorum, nil
    }
    
    const (
    	tierFVID     = "tier-free-versionID"
    	tierFVMarker = "tier-free-marker"
    	tierSkipFVID = "tier-skip-fvid"
    )
    
    // SetTierFreeVersionID sets free-version's versionID. This method is used by
    // object layer to pass down a versionID to set for a free-version that may be
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  6. cmd/api-router.go

    // gzip the response and throttle the handler via `maxClients`. Each of these
    // can be disabled via the corresponding `s3HFlag`.
    //
    // CAUTION: for requests involving large req/resp bodies ensure to pass the
    // `traceHdrsS3HFlag`, otherwise both headers and body will be traced, causing
    // high memory usage!
    func s3APIMiddleware(f http.HandlerFunc, flags ...s3HFlag) http.HandlerFunc {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  7. cmd/admin-router.go

    type hFlag uint8
    
    const (
    	// this flag disables gzip compression of responses
    	noGZFlag = 1 << iota
    
    	// this flag enables tracing body and headers instead of just headers
    	traceAllFlag
    
    	// pass this flag to skip checking if object layer is available
    	noObjLayerFlag
    )
    
    // Has checks if the given flag is enabled in `h`.
    func (h hFlag) Has(flag hFlag) bool {
    	// Use bitwise-AND and check if the result is non-zero.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    //
    //	User-Agent:
    //
    //	    This is ignored from signing because signing this causes problems with generating pre-signed URLs
    //	    (that are executed by other agents) or when customers pass requests through proxies, which may
    //	    modify the user-agent.
    //
    //	Authorization:
    //
    //	    Is skipped for obvious reasons
    var ignoredHeaders = map[string]bool{
    	"Authorization": true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    		maxKeys    int
    		versioned  bool
    		// Expected output of ListObjects.
    		resultL ListObjectsInfo
    		resultV ListObjectVersionsInfo
    		err     error
    		// Flag indicating whether the test is expected to pass or not.
    		shouldPass bool
    	}{
    		{testBuckets[0], "unique/", "", "/", 1000, false, resultCases[0], ListObjectVersionsInfo{}, nil, true},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/common-main.go

    		os.Setenv("CONSOLE_LOG_QUERY_URL", value)
    		if value := env.Get(config.EnvMinIOLogQueryAuthToken, ""); value != "" {
    			os.Setenv("CONSOLE_LOG_QUERY_AUTH_TOKEN", value)
    		}
    	}
    	// pass the console subpath configuration
    	if globalBrowserRedirectURL != nil {
    		subPath := path.Clean(pathJoin(strings.TrimSpace(globalBrowserRedirectURL.Path), SlashSeparator))
    		if subPath != SlashSeparator {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
Back to top