Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 1,405 for rfunc (0.06 sec)

  1. 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)
  2. 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)
  3. cmd/sts-handlers_test.go

    			etcdStr = " (with etcd backend)"
    		}
    		t.Run(
    			fmt.Sprintf("Test: %d, ServerType: %s%s", i+1, testCase.serverType, etcdStr),
    			func(t *testing.T) {
    				runAllIAMSTSTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/cmd/asm/internal/asm/parse.go

    	return tok
    }
    
    func (p *Parser) back() {
    	if p.inputPos == 0 {
    		p.errorf("internal error: backing up before BOL")
    	} else {
    		p.inputPos--
    	}
    }
    
    func (p *Parser) peek() lex.ScanToken {
    	if p.more() {
    		return p.input[p.inputPos].ScanToken
    	}
    	return scanner.EOF
    }
    
    func (p *Parser) more() bool {
    	return p.inputPos < len(p.input)
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  9. src/cmd/cgo/ast_go1.go

    package main
    
    import (
    	"go/ast"
    	"go/token"
    )
    
    func (f *File) walkUnexpected(x interface{}, context astContext, visit func(*File, interface{}, astContext)) {
    	error_(token.NoPos, "unexpected type %T in walk", x)
    	panic("unexpected type")
    }
    
    func funcTypeTypeParams(n *ast.FuncType) *ast.FieldList {
    	return nil
    }
    
    func typeSpecTypeParams(n *ast.TypeSpec) *ast.FieldList {
    	return nil
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Nov 30 21:45:10 UTC 2022
    - 578 bytes
    - Viewed (0)
  10. 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)
Back to top