- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 428 for initializers (0.31 seconds)
-
internal/cachevalue/cache.go
// NewFromFunc allocates a new cached value instance and initializes it with an // update function, making it ready for use. func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update, opts: opts, } } // InitOnce initializes the cache with a TTL and an update function. It is // guaranteed to be called only once.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 12:50:46 GMT 2024 - 4.4K bytes - Click Count (0) -
cmd/erasure-sets_test.go
nDisks := 16 // Maximum disks. var erasureDisks []string for range nDisks { // Do not attempt to create this path, the test validates // so that newErasureSets initializes non existing paths // and successfully returns initialized object layer. disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix()) erasureDisks = append(erasureDisks, disk) defer os.RemoveAll(disk) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.8K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.12.md
- The alpha `Initializers` admission plugin is no longer enabled by default. This matches the off-by-default behavior of the alpha API which drives initializer behavior. ([#66039](https://github.com/kubernetes/kubernetes/pull/66039), [@liggitt](https://github.com/liggitt))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Thu Feb 06 06:04:15 GMT 2020 - 293.8K bytes - Click Count (0) -
cmd/iam.go
logger.Info("Waiting for OpenID to be initialized.. (retrying in %s)", retryInterval) } if !ldapInit { logger.Info("Waiting for LDAP to be initialized.. (retrying in %s)", retryInterval) } if !authNInit { logger.Info("Waiting for AuthN to be initialized.. (retrying in %s)", retryInterval) } if !authZInit { logger.Info("Waiting for AuthZ to be initialized.. (retrying in %s)", retryInterval) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
cmd/typed-errors.go
var errInvalidRangeSource = errors.New("Range specified exceeds source object size") // error returned by disks which are to be initialized are waiting for the // first server to initialize them in distributed set to initialize them. var errNotFirstDisk = errors.New("Not first drive") // error returned by first disk waiting to initialize other servers. var errFirstDiskWait = errors.New("Waiting on other drives") // error returned for a negative actual size.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 16 07:34:24 GMT 2025 - 5.9K bytes - Click Count (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) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
this.journalFileBackup = directory / JOURNAL_FILE_BACKUP } @Synchronized @Throws(IOException::class) fun initialize() { assertLockHeld() if (initialized) { return // Already initialized. } // If a bkp file exists, use it instead. if (fileSystem.exists(journalFileBackup)) { // If journal file also exists just delete backup file.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 34.7K bytes - Click Count (0) -
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) -
okhttp/src/androidMain/kotlin/okhttp3/OkHttp.android.kt
/** * Configure the ApplicationContext. Not needed unless the AndroidX Startup [Initializer] is disabled, or running * a robolectric test. * * The functionality that will fail without a valid Context is primarily Cookies and URL Domain handling, but * may expand in the future. */ fun initialize(applicationContext: Context) { if (PlatformRegistry.applicationContext == null) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 1.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/reflect/ReflectionTest.java
} public void testInitialize() { assertEquals("This test can't be included twice in the same suite.", 0, classesInitialized); Reflection.initialize(A.class); assertEquals(1, classesInitialized); Reflection.initialize( A.class, // Already initialized (above) B.class, C.class); assertEquals(3, classesInitialized); } public void testNullPointers() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 2.7K bytes - Click Count (0)