- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Store (0.62 sec)
-
cmd/config-current.go
errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err)) } else { // update dynamic scanner values. scannerIdleMode.Store(scannerCfg.IdleMode) scannerCycle.Store(scannerCfg.Cycle) scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions) scannerExcessFolders.Store(scannerCfg.ExcessFolders) configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait)) } case config.LoggerWebhookSubSys:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
return nil, fmt.Errorf("error starting cni server: %w", err) } s.cniServerStopFunc = cniServer.Stop return s, nil } func (s *Server) Ready() { s.isReady.Store(true) } func (s *Server) NotReady() { s.isReady.Store(false) } // buildKubeClient creates the kube client func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/build-constants.go
MinioReleaseBaseURL = "https://dl.min.io/server/minio/release/" // MinioReleaseURL - release URL. MinioReleaseURL = MinioReleaseBaseURL + minioOSARCH + SlashSeparator // MinioStoreName - MinIO store name. MinioStoreName = "MinIO" // MinioUAName - MinIO user agent name. MinioUAName = "MinIO" // MinioBannerName - MinIO banner name for startup message. MinioBannerName = "MinIO Object Storage Server"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/site-replication.go
if mp, ok := globalIAMSys.store.GetMappedPolicy(opts.EntityValue, false); ok { userPolicyMap.Store(opts.EntityValue, mp) } } else { stsErr := globalIAMSys.store.loadMappedPolicies(ctx, stsUser, false, stsPolicyMap) if stsErr != nil { return info, errSRBackendIssue(stsErr) } usrErr := globalIAMSys.store.loadMappedPolicies(ctx, regUser, false, userPolicyMap)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/data-scanner_test.go
globalBucketObjectLockSys = &BucketObjectLockSys{} globalBucketVersioningSys = &BucketVersioningSys{} es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done() workers := globalExpiryState.workers.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cni/pkg/cmd/root.go
ambientAgent.Start() defer ambientAgent.Stop() log.Info("Ambient node agent started, starting installer...") } else { // Ambient not enabled, so this readiness flag is no-op'd watchServerReady.Store(true) } installer := install.NewInstaller(&cfg.InstallConfig, installDaemonReady) repair.StartRepair(ctx, cfg.RepairConfig) log.Info("Installer created, watching node CNI dir")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/admin-handlers-users.go
writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL) return } case allUsersFile: userIdentities := make(map[string]UserIdentity) err := globalIAMSys.store.loadUsers(ctx, regUser, userIdentities) if err != nil { writeErrorResponse(ctx, w, exportError(ctx, err, iamFile, ""), r.URL) return } userAccounts := make(map[string]madmin.AddOrUpdateUserReq)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 77.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
* returned by {@code factory}. Those objects should not be manually updated and they should not * use soft, weak, or phantom references. * * @param map place to store the mapping from each key to its corresponding values * @param factory supplier of new, empty collections that will each hold all values for a given * key * @throws IllegalArgumentException if {@code map} is not empty
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 86.4K bytes - Viewed (0) -
cmd/utils.go
type profilerWrapper struct { // Profile recorded at start of benchmark. records map[string][]byte stopFn func() ([]byte, error) ext string } // record will record the profile and store it as the base. func (p *profilerWrapper) record(profileType string, debug int, recordName string) { var buf bytes.Buffer if p.records == nil { p.records = make(map[string][]byte) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
checkNotNull(iterable); return new Iterator<T>() { Iterator<T> iterator = emptyModifiableIterator(); @Override public boolean hasNext() { /* * Don't store a new Iterator until we know the user can't remove() the last returned * element anymore. Otherwise, when we remove from the old iterator, we may be invalidating
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Apr 30 18:43:01 GMT 2024 - 51.1K bytes - Viewed (0)