Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for ToSlice (0.3 sec)

  1. cmd/iam-store.go

    func (mp MappedPolicy) toSlice() []string {
    	var policies []string
    	for _, policy := range strings.Split(mp.Policies, ",") {
    		if strings.TrimSpace(policy) == "" {
    			continue
    		}
    		policies = append(policies, policy)
    	}
    	return policies
    }
    
    func (mp MappedPolicy) policySet() set.StringSet {
    	return set.CreateStringSet(mp.toSlice()...)
    }
    
    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/net.go

    	if globalBrowserRedirectURL != nil {
    		return []string{globalBrowserRedirectURL.String()}
    	}
    	var ipList []string
    	if globalMinioConsoleHost == "" {
    		ipList = sortIPs(mustGetLocalIP4().ToSlice())
    		ipList = append(ipList, mustGetLocalIP6().ToSlice()...)
    	} else {
    		ipList = []string{globalMinioConsoleHost}
    	}
    
    	for _, ip := range ipList {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. cmd/iam.go

    				// Print a warning that some policies mapped to a role are not defined.
    				errMsg := fmt.Errorf(
    					"The policies \"%s\" mapped to role ARN %s are not defined - this role may not work as expected.",
    					unknownPoliciesSet.ToSlice(), arn.String())
    				authZLogIf(ctx, errMsg, logger.WarningKind)
    			}
    		}
    		sys.rolesMap[arn] = rolePolicies
    	}
    }
    
    // Prints IAM role ARNs.
    func (sys *IAMSys) printIAMRoles() {
    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)
  4. cmd/iam-etcd-store.go

    	if err != nil {
    		return err
    	}
    
    	groups := etcdKvsToSet(iamConfigGroupsPrefix, r.Kvs)
    
    	// Reload config for all groups.
    	for _, group := range groups.ToSlice() {
    		if err = ies.loadGroup(ctx, group, m); err != nil && err != errNoSuchGroup {
    			return err
    		}
    	}
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    		derrs[i] = checkDelObjArgs(ctx, bucket, objects[i].ObjectName)
    		objSets.Add(objects[i].ObjectName)
    	}
    
    	// Acquire a bulk write lock across 'objects'
    	multiDeleteLock := z.NewNSLock(bucket, objSets.ToSlice()...)
    	lkctx, err := multiDeleteLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		for i := range derrs {
    			derrs[i] = err
    		}
    		return dobjects, derrs
    	}
    	ctx = lkctx.Context()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. cmd/config-current.go

    	defer env.SetEnvOn()
    	if subSys != "" {
    		return validateSubSysConfig(ctx, s, subSys, objAPI)
    	}
    
    	// No sub-system passed. Validate all of them.
    	for _, ss := range config.SubSystems.ToSlice() {
    		if err := validateSubSysConfig(ctx, s, ss, objAPI); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    func lookupConfigs(s config.Config, objAPI ObjectLayer) {
    	ctx := GlobalContext
    
    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)
  7. cmd/endpoint.go

    				u := &url.URL{
    					Scheme: endpoint.Scheme,
    					Host:   endpoint.Host,
    				}
    				return u.String()
    			}
    		}
    	}
    	host := globalMinioHost
    	if host == "" {
    		host = sortIPs(localIP4.ToSlice())[0]
    	}
    	return fmt.Sprintf("%s://%s", getURLScheme(globalIsTLS), net.JoinHostPort(host, globalMinioPort))
    }
    
    // LocalDisksPaths returns the disk paths of the local disks
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  8. internal/config/config.go

    	if isSingleTarget && len(candidates) > 0 {
    		return Errorf("The following environment variables are unknown: %s",
    			strings.Join(candidates.ToSlice(), ", "))
    	}
    
    	if !isSingleTarget {
    		// Validate other env vars for all targets.
    		envVars := candidates.ToSlice()
    		for _, envVar := range envVars {
    			for _, param := range validKeys {
    				pEnvName := getEnvVarName(subSys, Default, param) + Default
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  9. internal/config/lambda/parse.go

    func FetchEnabledTargets(ctx context.Context, cfg config.Config, transport *http.Transport) (*event.TargetList, error) {
    	targetList := event.NewTargetList()
    	for _, subSys := range config.LambdaSubSystems.ToSlice() {
    		targets, err := fetchSubSysTargets(ctx, cfg, subSys, transport)
    		if err != nil {
    			return nil, err
    		}
    		for _, t := range targets {
    			if err = targetList.Add(t); err != nil {
    				return nil, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  10. internal/http/listener_test.go

    		return !strings.HasPrefix(ip, "127.")
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    		t.Fatalf("No non-loop back IP address found for this host")
    	}
    	nonLoopBackIP := nonLoopBackIPs.ToSlice()[0]
    	return nonLoopBackIP
    }
    
    func TestNewHTTPListener(t *testing.T) {
    	testCases := []struct {
    		serverAddrs         []string
    		tcpKeepAliveTimeout time.Duration
    		readTimeout         time.Duration
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
Back to top