Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for ekvs (0.28 sec)

  1. cmd/common-main_test.go

    			tmpfile.Close()
    
    			ekvs, err := minioEnvironFromFile(tmpfile.Name())
    			if err != nil && !testCase.expectedErr {
    				t.Error(err)
    			}
    			if err == nil && testCase.expectedErr {
    				t.Error(errors.New("expected error, found success"))
    			}
    
    			if len(ekvs) != len(testCase.expectedEkvs) {
    				t.Errorf("expected %v keys, got %v keys", len(testCase.expectedEkvs), len(ekvs))
    			}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  2. cmd/common-main.go

    	}
    	defer f.Close()
    	var ekvs []envKV
    	scanner := bufio.NewScanner(f)
    	for scanner.Scan() {
    		ekv, err := parsEnvEntry(scanner.Text())
    		if err != nil {
    			return nil, err
    		}
    		if ekv.Skip {
    			// Skips empty lines
    			continue
    		}
    		ekvs = append(ekvs, ekv)
    	}
    	if err = scanner.Err(); err != nil {
    		return nil, err
    	}
    	return ekvs, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (0)
  3. cmd/config-current.go

    		config.BrowserSubSys:        browser.DefaultKVS,
    	}
    	maps.Copy(kvs, notify.DefaultNotificationKVS)
    	maps.Copy(kvs, lambda.DefaultLambdaKVS)
    	if globalIsErasure {
    		kvs[config.StorageClassSubSys] = storageclass.DefaultKVS
    		kvs[config.HealSubSys] = heal.DefaultKVS
    	}
    	config.RegisterDefaultKVS(kvs)
    
    	// Captures help for each sub-system
    	helpSubSys := config.HelpKVS{
    		config.HelpKV{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  4. cmd/config.go

    	}
    
    	srvCfg, err := readConfigWithoutMigrate(GlobalContext, objAPI)
    	if err != nil {
    		return err
    	}
    
    	bootstrapTraceMsg("lookup the configuration")
    
    	// Override any values from ENVs.
    	lookupConfigs(srvCfg, objAPI)
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  5. cmd/iam-etcd-store.go

    	err = p.parseJSON(data)
    	if err != nil {
    		return err
    	}
    
    	m[policy] = p
    	return nil
    }
    
    func (ies *IAMEtcdStore) getPolicyDocKV(ctx context.Context, kvs *mvccpb.KeyValue, m map[string]PolicyDoc) error {
    	data, err := decryptData(kvs.Value, string(kvs.Key))
    	if err != nil {
    		if err == errConfigNotFound {
    			return errNoSuchPolicy
    		}
    		return err
    	}
    
    	var p PolicyDoc
    	err = p.parseJSON(data)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    	"MINIO_OPERATOR_VERSION":       {},
    	"MINIO_VSPHERE_PLUGIN_VERSION": {},
    	"MINIO_CI_CD":                  {},
    }
    
    func getServerSystemCfg() *ServerSystemConfig {
    	envs := env.List("MINIO_")
    	envValues := make(map[string]string, len(envs))
    	for _, envK := range envs {
    		// skip certain environment variables as part
    		// of the whitelist and could be configured
    		// differently on each nodes, update skipEnvs()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. cmd/postpolicyform.go

    			// This is a JSON object type (that preserves key order)
    			kvs, ok := mv.Value.(jstream.KVS)
    			if ok {
    				for _, kv := range kvs {
    					if sset.Contains(kv.Key) {
    						// Reject duplicate conditions or expiration.
    						return nil, fmt.Errorf("input policy has multiple %s, please fix your client code", kv.Key)
    					}
    					sset.Add(kv.Key)
    				}
    			}
    			e.Encode(kvs)
    		}
    	}
    	return &buf, d.Err()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  8. cmd/object-lambda-handlers_test.go

    			cfg := config.New()
    			cfg[config.LambdaWebhookSubSys] = map[string]config.KVS{
    				functionID: {
    					{Key: "endpoint", Value: lambdaServer.URL},
    					{Key: "enable", Value: config.EnableOn},
    				},
    			}
    			cfg[config.APISubSys] = map[string]config.KVS{
    				"api": {
    					{Key: "gzip", Value: config.EnableOff},
    				},
    			}
    
    			var err error
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 18 21:56:31 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  9. docs/sts/etcd.md

    ```
    export MINIO_ETCD_ENDPOINTS=http://localhost:2379
    minio server /data
    ```
    
    NOTE: If `etcd` is configured with `Client-to-server authentication with HTTPS client certificates` then you need to use additional envs such as `MINIO_ETCD_CLIENT_CERT` pointing to path to `etcd-client.crt` and `MINIO_ETCD_CLIENT_CERT_KEY` path to `etcd-client.key` .
    
    ### 4. Test with MinIO STS API
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  10. cmd/etcd.go

    	if err != nil {
    		etcdLogOnceIf(ctx, err, "etcd-retrieve-keys")
    		return nil, etcdErrToErr(err, client.Endpoints())
    	}
    	if resp.Count == 0 {
    		return nil, errConfigNotFound
    	}
    	for _, ev := range resp.Kvs {
    		if string(ev.Key) == key {
    			return ev.Value, nil
    		}
    	}
    	return nil, errConfigNotFound
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top