Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 421 - 430 of 1,760 for func (0.01 seconds)

  1. internal/bucket/versioning/versioning_test.go

    		t.Fatalf("XML shouldn't contain ExcludedPrefixes tag - %s", str)
    	}
    }
    
    func TestVersioningZero(t *testing.T) {
    	var v Versioning
    	if v.Enabled() {
    		t.Fatalf("Expected to be disabled but got enabled")
    	}
    	if v.Suspended() {
    		t.Fatalf("Expected to be disabled but got suspended")
    	}
    }
    
    func TestExcludeFolders(t *testing.T) {
    	v := Versioning{
    		Status:         Enabled,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun May 08 05:06:44 GMT 2022
    - 8.8K bytes
    - Click Count (0)
  2. cmd/bucket-quota.go

    type BucketQuotaSys struct{}
    
    // Get - Get quota configuration.
    func (sys *BucketQuotaSys) Get(ctx context.Context, bucketName string) (*madmin.BucketQuota, error) {
    	cfg, _, err := globalBucketMetadataSys.GetQuotaConfig(ctx, bucketName)
    	return cfg, err
    }
    
    // NewBucketQuotaSys returns initialized BucketQuotaSys
    func NewBucketQuotaSys() *BucketQuotaSys {
    	return &BucketQuotaSys{}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  3. cmd/dynamic-timeouts.go

    }
    
    // Timeout returns the current timeout value
    func (dt *dynamicTimeout) Timeout() time.Duration {
    	return time.Duration(atomic.LoadInt64(&dt.timeout))
    }
    
    func (dt *dynamicTimeout) RetryInterval() time.Duration {
    	return dt.retryInterval
    }
    
    // LogSuccess logs the duration of a successful action that
    // did not hit the timeout
    func (dt *dynamicTimeout) LogSuccess(duration time.Duration) {
    	dt.logEntry(duration)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. internal/jwt/parser_test.go

    )
    
    var (
    	defaultKeyFunc = func(claim *MapClaims) ([]byte, error) { return []byte("HelloSecret"), nil }
    	emptyKeyFunc   = func(claim *MapClaims) ([]byte, error) { return nil, nil }
    	errorKeyFunc   = func(claim *MapClaims) ([]byte, error) { return nil, fmt.Errorf("error loading key") }
    )
    
    var jwtTestData = []struct {
    	name        string
    	tokenString string
    	keyfunc     func(*MapClaims) ([]byte, error)
    	claims      jwt.Claims
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  5. internal/bucket/versioning/versioning.go

    	default:
    		return Errorf("unsupported Versioning status %s", v.Status)
    	}
    	return nil
    }
    
    // Enabled - returns true if versioning is enabled
    func (v Versioning) Enabled() bool {
    	return v.Status == Enabled
    }
    
    // Versioned returns if 'prefix' has versioning enabled or suspended.
    func (v Versioning) Versioned(prefix string) bool {
    	return v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  6. schema/utils.go

    			settings[k] = val
    		} else if k != "" {
    			settings[k] = k
    		}
    	}
    
    	return settings
    }
    
    func toColumns(val string) (results []string) {
    	if val != "" {
    		for _, v := range strings.Split(val, ",") {
    			results = append(results, strings.TrimSpace(v))
    		}
    	}
    	return
    }
    
    func removeSettingFromTag(tag reflect.StructTag, names ...string) reflect.StructTag {
    	for _, name := range names {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Oct 30 11:15:36 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  7. internal/http/listener_test.go

    	"testing"
    	"time"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    )
    
    var serverPort uint32 = 60000
    
    var getCert = func(*tls.ClientHelloInfo) (*tls.Certificate, error) {
    	certificate, err := getTLSCert()
    	if err != nil {
    		return nil, err
    	}
    	return &certificate, nil
    }
    
    func getTLSCert() (tls.Certificate, error) {
    	keyPEMBlock := []byte(`-----BEGIN RSA PRIVATE KEY-----
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. schema/schema_helper_test.go

    				}
    			}
    
    			if !found {
    				t.Errorf("schema %v failed to found primary key: %v", s, field)
    			}
    		}
    	})
    }
    
    func checkSchemaField(t *testing.T, s *schema.Schema, f *schema.Field, fc func(*schema.Field)) {
    	t.Run("CheckField/"+f.Name, func(t *testing.T) {
    		if fc != nil {
    			fc(f)
    		}
    
    		if f.TagSettings == nil {
    			if f.Tag != "" {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Aug 28 02:57:17 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  9. cmd/site-replication-metrics.go

    	// Error counts
    	ErrCounts map[string]int `json:"errCounts"` // Count of credential errors
    }
    
    func (rt *RTimedMetrics) String() string {
    	s := rt.toMetric()
    	return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count)
    }
    
    func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats {
    	if rt == nil {
    		return madmin.TimedErrStats{}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. cmd/admin-handlers-idp-config.go

    //
    // POST <admin-prefix>/idp-cfg/openid/_ -> update (default) named config `_`
    func (a adminAPIHandlers) UpdateIdentityProviderCfg(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	addOrUpdateIDPHandler(ctx, w, r, true)
    }
    
    // ListIdentityProviderCfg:
    //
    // GET <admin-prefix>/idp-cfg/openid -> lists openid provider configs.
    func (a adminAPIHandlers) ListIdentityProviderCfg(w http.ResponseWriter, r *http.Request) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 12.7K bytes
    - Click Count (0)
Back to Top