Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 1,950 for func (0.12 sec)

  1. 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)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 6K bytes
    - Viewed (0)
  3. cmd/streaming-v4-unsigned.go

    	reader   *bufio.Reader
    	trailers http.Header
    
    	buffer []byte
    	offset int
    	err    error
    	debug  bool
    }
    
    func (cr *s3UnsignedChunkedReader) Close() (err error) {
    	return cr.err
    }
    
    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    	// First, if there is any unread data, copy it to the client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 08 05:06:44 UTC 2022
    - 8.8K bytes
    - Viewed (0)
  5. internal/http/request-recorder.go

    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    		r.buf.Write(p[:n])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  6. internal/event/arn.go

    type ARN struct {
    	TargetID
    	region string
    }
    
    // String - returns string representation.
    func (arn ARN) String() string {
    	if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:sqs:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // MarshalXML - encodes to XML data.
    func (arn ARN) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  7. internal/bucket/replication/sourceselectioncriteria.go

    }
    
    // IsValid - checks whether SourceSelectionCriteria is valid or not.
    func (s SourceSelectionCriteria) IsValid() bool {
    	return s.ReplicaModifications.Status == Enabled || s.ReplicaModifications.Status == Disabled
    }
    
    // Validate source selection criteria
    func (s SourceSelectionCriteria) Validate() error {
    	if (s == SourceSelectionCriteria{}) {
    		return nil
    	}
    	if !s.IsValid() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  8. tests/table_test.go

    	gorm.Model
    	Name string
    }
    
    func (UserWithTableNamer) TableName(namer schema.Namer) string {
    	return namer.TableName("user")
    }
    
    func TestTableWithNamer(t *testing.T) {
    	db, _ := gorm.Open(tests.DummyDialector{}, &gorm.Config{
    		NamingStrategy: schema.NamingStrategy{
    			TablePrefix: "t_",
    		},
    	})
    
    	sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Mar 09 09:31:28 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/operand_test.go

    //
    // For unexpected panics, calls t.Fatal.
    func tryParse(t *testing.T, parse func()) (err error) {
    	panicOnError = true
    	defer func() {
    		panicOnError = false
    
    		e := recover()
    		var ok bool
    		if err, ok = e.(error); e != nil && !ok {
    			t.Fatal(e)
    		}
    	}()
    
    	parse()
    
    	return nil
    }
    
    func testBadOperandParser(t *testing.T, parser *Parser, tests []badOperandTest) {
    	for _, test := range tests {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 23.9K bytes
    - Viewed (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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top