Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 79 for Store (0.17 sec)

  1. cmd/iam-store.go

    // operation, we fetch this info from storage, and refresh the cache as well.
    func (store *IAMStoreSys) ListGroups(ctx context.Context) (res []string, err error) {
    	cache := store.lock()
    	defer store.unlock()
    
    	if store.getUsersSysType() == MinIOUsersSysType {
    		m := map[string]GroupInfo{}
    		err = store.loadGroups(ctx, m)
    		if err != nil {
    			return
    		}
    		cache.iamGroupsMap = m
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  2. cmd/iam.go

    	}
    
    	loadUserCalled := false
    	select {
    	case <-sys.configLoaded:
    	default:
    		sys.store.LoadUser(ctx, name)
    		loadUserCalled = true
    	}
    
    	userInfo, err := sys.store.GetUserInfo(name)
    	if err == errNoSuchUser && !loadUserCalled {
    		sys.store.LoadUser(ctx, name)
    		userInfo, err = sys.store.GetUserInfo(name)
    	}
    	return userInfo, err
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. internal/event/target/postgresql.go

    }
    
    // Name - returns the Name of the target.
    func (target *PostgreSQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *PostgreSQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *PostgreSQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/healthServer.go

    	}()
    
    	return
    }
    
    func initRouter(router *http.ServeMux) (installReady *atomic.Value, watchReady *atomic.Value) {
    	installReady = &atomic.Value{}
    	watchReady = &atomic.Value{}
    	installReady.Store(false)
    	watchReady.Store(false)
    
    	router.HandleFunc(constants.LivenessEndpoint, healthz)
    	router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady))
    
    	return
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    			break
    		}
    	}
    }
    
    func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error {
    	return r.loadWithOpts(ctx, store, ObjectOptions{})
    }
    
    func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error {
    	data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts)
    	if err != nil {
    		return err
    	}
    
    	if len(data) == 0 {
    		return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/testdata/riscv64error.s

    	MOVW	$1, X5				// ERROR "unsupported constant load"
    	MOVF	$1, X5				// ERROR "unsupported constant load"
    	MOVBU	X5, (X6)			// ERROR "unsupported unsigned store"
    	MOVHU	X5, (X6)			// ERROR "unsupported unsigned store"
    	MOVWU	X5, (X6)			// ERROR "unsupported unsigned store"
    	MOVF	F0, F1, F2			// ERROR "illegal MOV instruction"
    	MOVD	F0, F1, F2			// ERROR "illegal MOV instruction"
    	MOV	X10, X11, X12			// ERROR "illegal MOV instruction"
    Others
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Sun Apr 07 03:32:27 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    		healthCheck:  healthCheck && globalDriveMonitoring,
    		metricsCache: cachevalue.New[DiskMetrics](),
    	}
    	xl.SetDiskID(emptyDiskID)
    
    	xl.totalWrites.Store(xl.storage.getWriteAttribute())
    	xl.totalDeletes.Store(xl.storage.getDeleteAttribute())
    	xl.diskCtx, xl.diskCancel = context.WithCancel(context.TODO())
    	for i := range xl.apiLatencies[:] {
    		xl.apiLatencies[i] = &lockedLastMinuteLatency{}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  8. 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)
  9. okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt

    internal fun CacheControl.commonToString(): String {
      var result = headerValue
      if (result == null) {
        result =
          buildString {
            if (noCache) append("no-cache, ")
            if (noStore) append("no-store, ")
            if (maxAgeSeconds != -1) append("max-age=").append(maxAgeSeconds).append(", ")
            if (sMaxAgeSeconds != -1) append("s-maxage=").append(sMaxAgeSeconds).append(", ")
            if (isPrivate) append("private, ")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:41:01 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  10. .github/workflows/test.yml

            run: bash scripts/test.sh
            env:
              COVERAGE_FILE: coverage/.coverage.${{ runner.os }}-py${{ matrix.python-version }}
              CONTEXT: ${{ runner.os }}-py${{ matrix.python-version }}
          - name: Store coverage files
            uses: actions/upload-artifact@v3
            with:
              name: coverage
              path: coverage
    
      coverage-combine:
        needs: [test]
        runs-on: ubuntu-latest
        steps:
    Others
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:40:57 GMT 2024
    - 4.4K bytes
    - Viewed (1)
Back to top