Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 961 for Func (0.11 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/dynamic-timeouts_test.go

    		t.Errorf("Failure to decrease timeout appropriately")
    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for range 100 {
    				for range 100 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  2. 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) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 6.6K bytes
    - Click Count (0)
  3. cmd/metacache-entries.go

    // isDir returns if the entry is representing a prefix directory.
    func (e metaCacheEntry) isDir() bool {
    	return len(e.metadata) == 0 && strings.HasSuffix(e.name, slashSeparator)
    }
    
    // isObject returns if the entry is representing an object.
    func (e metaCacheEntry) isObject() bool {
    	return len(e.metadata) > 0
    }
    
    // isObjectDir returns if the entry is representing an object/
    func (e metaCacheEntry) isObjectDir() bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  4. internal/rest/rpc-stats.go

    // Return a function which update the global stats related to tcp connections
    func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) {
    	var dialStart, dialEnd int64
    	start := time.Now()
    	trace := &httptrace.ClientTrace{
    		GotFirstResponseByte: func() {
    			atomic.AddUint64(&globalStats.tcpTimeForFirstByteTotalDur, uint64(time.Since(start)))
    		},
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 13 18:21:34 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  5. schema/constraint.go

    	Constraint string // length(phone) >= 10
    	*Field
    }
    
    func (chk *CheckConstraint) GetName() string { return chk.Name }
    
    func (chk *CheckConstraint) Build() (sql string, vars []interface{}) {
    	return "CONSTRAINT ? CHECK (?)", []interface{}{clause.Column{Name: chk.Name}, clause.Expr{SQL: chk.Constraint}}
    }
    
    // ParseCheckConstraints parse schema check constraints
    func (schema *Schema) ParseCheckConstraints() map[string]CheckConstraint {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Mar 18 07:33:54 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  6. internal/http/dial_others.go

    //
    //nolint:unused
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    	return func(network, address string, c syscall.RawConn) error {
    		return nil
    	}
    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  7. cmd/metrics-v3-handler.go

    	globalMetricsV3Once           sync.Once
    )
    
    func newMetricsV3Server(auth func(h http.Handler) http.Handler) *metricsV3Server {
    	registry := prometheus.NewRegistry()
    	metricGroups := newMetricGroups(registry)
    	globalMetricsV3Once.Do(func() {
    		globalMetricsV3CollectorPaths = metricGroups.collectorPaths
    	})
    	return &metricsV3Server{
    		registry: registry,
    		opts: promhttp.HandlerOpts{
    			ErrorLog:            promLogger{},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  8. internal/s3select/select.go

    )
    
    var parquetSupport bool
    
    func init() {
    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = bpool.Pool[*bytes.Buffer]{
    	New: func() *bytes.Buffer {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  9. internal/http/listener.go

    	ctxCanceler context.CancelFunc
    }
    
    // start - starts separate goroutine for each TCP listener.  A valid new connection is passed to httpListener.acceptCh.
    func (listener *httpListener) start() {
    	// Closure to handle listener until httpListener.ctxDoneCh channel is closed.
    	handleListener := func(idx int, ln net.Listener) {
    		for {
    			conn, err := ln.Accept()
    			select {
    			case listener.acceptCh <- acceptResult{conn, err, idx}:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  10. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
Back to Top