Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 149 for store (0.16 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  2. cmd/iam-object-store.go

    		if listKey == iamFormatFile {
    			continue
    		}
    
    		res[listKey] = append(res[listKey], trimmedItem)
    	}
    	// Store the listing for later re-use.
    	iamOS.cachedIAMListing.Store(res)
    	return res, nil
    }
    
    // PurgeExpiredSTS - purge expired STS credentials from object store.
    func (iamOS *IAMObjectStore) PurgeExpiredSTS(ctx context.Context) error {
    	if iamOS.objAPI == nil {
    		return errServerNotInitialized
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  3. cmd/iam-etcd-store.go

    	var p MappedPolicy
    	err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup))
    	if err != nil {
    		if err == errConfigNotFound {
    			return errNoSuchPolicy
    		}
    		return err
    	}
    	m.Store(name, p)
    	return nil
    }
    
    func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error {
    	var p MappedPolicy
    	err := getIAMConfig(&p, kv.Value, string(kv.Key))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  6. internal/event/targetlist.go

    // Target - event target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Save(Event) error
    	SendFromStore(store.Key) error
    	Close() error
    	Store() TargetStore
    }
    
    // TargetStore is a shallow version of a target.Store
    type TargetStore interface {
    	Len() int
    }
    
    // Stats is a collection of stats for multiple targets.
    type Stats struct {
    	TotalEvents        int64 // Deprecated
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  7. 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 Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  8. src/archive/zip/writer.go

    	}
    
    	if strings.HasSuffix(fh.Name, "/") {
    		// Set the compression method to Store to ensure data length is truly zero,
    		// which the writeHeader method always encodes for the size fields.
    		// This is necessary as most compression formats have non-zero lengths
    		// even when compressing an empty string.
    		fh.Method = Store
    		fh.Flags &^= 0x8 // we will not write a data descriptor
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Thu Apr 04 14:28:57 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  9. 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 23 11:13:09 GMT 2024
    - Last Modified: Sun Apr 07 03:32:27 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  10. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top