Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 1,179 for funcs (0.09 sec)

  1. internal/bucket/lifecycle/filter_test.go

    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var filter Filter
    			err := xml.Unmarshal([]byte(tc.inputXML), &filter)
    			if err != nil {
    				t.Fatalf("%d: Expected no error but got %v", i+1, err)
    			}
    			err = filter.Validate()
    			if err != tc.expectedErr {
    				t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err)
    			}
    		})
    	}
    }
    
    func TestObjectSizeFilters(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 27 00:01:20 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. cmd/server-startup-msg.go

    	"github.com/minio/minio/internal/logger"
    )
    
    // generates format string depending on the string length and padding.
    func getFormatStr(strLen int, padding int) string {
    	formatStr := fmt.Sprintf("%ds", strLen+padding)
    	return "%" + formatStr
    }
    
    // Prints the formatted startup message.
    func printStartupMessage(apiEndpoints []string, err error) {
    	banner := strings.Repeat("-", len(MinioBannerName))
    	if globalIsDistErasure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. internal/config/dns/operator_dns.go

    type OperatorOption func(*OperatorDNS)
    
    // Authentication - custom username and password for authenticating at the endpoint
    func Authentication(username, password string) OperatorOption {
    	return func(args *OperatorDNS) {
    		args.username = username
    		args.password = password
    	}
    }
    
    // RootCAs - add custom trust certs pool
    func RootCAs(certPool *x509.CertPool) OperatorOption {
    	return func(args *OperatorDNS) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  4. schema/index.go

    				sort.Slice(idx.Fields, func(i, j int) bool {
    					return idx.Fields[i].priority < idx.Fields[j].priority
    				})
    
    				indexes[index.Name] = idx
    			}
    		}
    	}
    	for _, index := range indexes {
    		if index.Class == "UNIQUE" && len(index.Fields) == 1 {
    			index.Fields[0].Field.UniqueIndex = index.Name
    		}
    	}
    	return indexes
    }
    
    func (schema *Schema) LookIndex(name string) *Index {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    			r = append(r, v)
    		}
    	}
    
    	sort.Slice(r, func(i, j int) bool {
    		return r[i].User < r[j].User
    	})
    
    	return r
    }
    
    // Assumes store is locked by caller. If groups is empty, returns all group mappings.
    func (store *IAMStoreSys) listGroupPolicyMappings(cache *iamCache, groupsSet set.StringSet,
    	groupPredicate func(string) bool, decodeFunc func(string) string,
    ) []madmin.GroupPolicyEntities {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    	}
    	scfg.CmdLines = cmdLines
    	return scfg
    }
    
    func (s *bootstrapRESTServer) VerifyHandler(params *grid.MSS) (*ServerSystemConfig, *grid.RemoteErr) {
    	return getServerSystemCfg(), nil
    }
    
    var serverVerifyHandler = grid.NewSingleHandler[*grid.MSS, *ServerSystemConfig](grid.HandlerServerVerify, grid.NewMSS, func() *ServerSystemConfig { return &ServerSystemConfig{} })
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users-race_test.go

    			c.Fatalf("Unable to attach policy: %v", err)
    		}
    
    		accessKeys[i] = accessKey
    		secretKeys[i] = secretKey
    	}
    
    	g := errgroup.Group{}
    	for i := 0; i < userCount; i++ {
    		g.Go(func(i int) func() error {
    			return func() error {
    				uClient := s.getUserClient(c, accessKeys[i], secretKeys[i], "")
    				err := s.adm.RemoveUser(ctx, accessKeys[i])
    				if err != nil {
    					return err
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/arch/loong64.go

    // constant) is one of the RDTIMELW/RDTIMEHW/RDTIMED instructions that
    // require special handling.
    func IsLoong64RDTIME(op obj.As) bool {
    	switch op {
    	case loong64.ARDTIMELW, loong64.ARDTIMEHW, loong64.ARDTIMED:
    		return true
    	}
    	return false
    }
    
    func IsLoong64AMO(op obj.As) bool {
    	return loong64.IsAtomicInst(op)
    }
    
    func loong64RegisterNumber(name string, n int16) (int16, bool) {
    	switch name {
    	case "F":
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jul 29 02:47:00 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. src/cmd/api/testdata/src/pkg/p2/p2.go

    // license that can be found in the LICENSE file.
    
    package p2
    
    type Twoer interface {
    	// Deprecated: No good.
    	PackageTwoMeth()
    }
    
    // Deprecated: No good.
    func F() string {}
    
    func G() Twoer {}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 337 bytes
    - Viewed (0)
  10. internal/dsync/utils.go

    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(r *rand.Rand, attempt uint) time.Duration {
    		sleep := min
    		sleep += unit * time.Duration(attempt)
    		if sleep > cap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 13 15:42:21 UTC 2023
    - 1.2K bytes
    - Viewed (0)
Back to top