Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 185 for initializers (0.07 seconds)

  1. cmd/server-main.go

    		warnings = append(warnings, color.YellowBold(msg))
    	}
    
    	// Initialize users credentials and policies in background right after config has initialized.
    	go func() {
    		bootstrapTrace("globalIAMSys.Init", func() {
    			globalIAMSys.Init(GlobalContext, newObject, globalEtcdClient, globalRefreshIAMInterval)
    		})
    
    		// Initialize Console UI
    		if globalBrowserEnabled {
    			bootstrapTrace("initConsoleServer", func() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  2. cmd/auth-handler_test.go

    	req := mustNewRequest(method, urlStr, contentLength, body, t)
    	cred := globalActiveCred
    	if err := signRequestV4(req, cred.AccessKey, cred.SecretKey); err != nil {
    		t.Fatalf("Unable to initialized new signed http request %s", err)
    	}
    	return req
    }
    
    // This is similar to mustNewRequest but additionally the request
    // is signed with AWS Signature V2, fails if not able to do so.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  3. gorm.go

    		config.ClauseBuilders = map[string]clause.ClauseBuilder{}
    	}
    
    	if config.Dialector != nil {
    		err = config.Dialector.Initialize(db)
    		if err != nil {
    			if db, _ := db.DB(); db != nil {
    				_ = db.Close()
    			}
    
    			// DB is not initialized, so we skip AfterInitialize
    			skipAfterInitialize = true
    			return
    		}
    
    		if config.TranslateError {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Aug 26 06:24:29 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  4. internal/logger/target/kafka/kafka.go

    	}
    
    	sconfig.Net.KeepAlive = 60 * time.Second
    	sconfig.Net.SASL.User = h.kconfig.SASL.User
    	sconfig.Net.SASL.Password = h.kconfig.SASL.Password
    	initScramClient(h.kconfig, sconfig) // initializes configured scram client.
    	sconfig.Net.SASL.Enable = h.kconfig.SASL.Enable
    
    	tlsConfig, err := saramatls.NewConfig(h.kconfig.TLS.ClientTLSCert, h.kconfig.TLS.ClientTLSKey)
    	if err != nil {
    		return err
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  5. cmd/tier.go

    	defer config.RUnlock()
    	data := make([]byte, 4, config.Msgsize()+4)
    
    	// Initialize the header.
    	binary.LittleEndian.PutUint16(data[0:2], tierConfigFormat)
    	binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion)
    
    	// Marshal the tier config
    	return config.MarshalMsg(data)
    }
    
    // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  6. internal/lru/lru.go

    	len  int         // current list Length excluding (this) sentinel element
    }
    
    // Init initializes or clears list l.
    func (l *LruList[K, V]) Init() *LruList[K, V] {
    	l.root.next = &l.root
    	l.root.prev = &l.root
    	l.len = 0
    	return l
    }
    
    // NewList returns an initialized list.
    func NewList[K comparable, V any]() *LruList[K, V] { return new(LruList[K, V]).Init() }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  7. finisher_api.go

    			if where, ok := c.Expression.(clause.Where); ok {
    				tx.assignInterfacesToValue(where.Exprs)
    			}
    		}
    
    		// initialize with attrs, conds
    		if len(tx.Statement.attrs) > 0 {
    			tx.assignInterfacesToValue(tx.Statement.attrs...)
    		}
    	}
    
    	// initialize with attrs, conds
    	if len(tx.Statement.assigns) > 0 {
    		tx.assignInterfacesToValue(tx.Statement.assigns...)
    	}
    	return
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  8. cmd/bucket-metadata-sys.go

    				wait() // wait to proceed to next entry.
    			}
    		}
    		t.Reset(bucketMetadataRefresh)
    	}
    }
    
    // Initialized indicates if bucket metadata sys is initialized atleast once.
    func (sys *BucketMetadataSys) Initialized() bool {
    	sys.RLock()
    	defer sys.RUnlock()
    
    	return sys.initialized
    }
    
    // Loads bucket metadata for all buckets into BucketMetadataSys.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  9. src/bytes/buffer.go

    // sufficient to initialize a [Buffer].
    func NewBuffer(buf []byte) *Buffer { return &Buffer{buf: buf} }
    
    // NewBufferString creates and initializes a new [Buffer] using string s as its
    // initial contents. It is intended to prepare a buffer to read an existing
    // string.
    //
    // In most cases, new([Buffer]) (or just declaring a [Buffer] variable) is
    // sufficient to initialize a [Buffer].
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  10. cmd/prepare-storage.go

    		return nil, err
    	}
    
    	// All disks report unformatted we should initialized everyone.
    	if shouldInitErasureDisks(sErrs) && firstDisk {
    		logger.Info("Formatting %s pool, %v set(s), %v drives per set.",
    			humanize.Ordinal(poolCount), setCount, setDriveCount)
    
    		// Initialize erasure code format on disks
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
Back to Top