Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 320 for append (0.14 sec)

  1. docs/debugging/s3-check-md5/main.go

    	if debug {
    		s3Client.TraceOn(os.Stderr)
    	}
    
    	var buckets []string
    	if bucket != "" {
    		buckets = append(buckets, bucket)
    	} else {
    		bucketsInfo, err := s3Client.ListBuckets(context.Background())
    		if err != nil {
    			log.Fatalln(err)
    		}
    		for _, b := range bucketsInfo {
    			buckets = append(buckets, b.Name)
    		}
    	}
    
    	for _, bucket := range buckets {
    		opts := minio.ListObjectsOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 17 01:15:57 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  2. docs/debugging/xl-meta/main.go

    		var files []string
    
    		for _, pattern := range args {
    			if pattern == "-" {
    				files = append(files, pattern)
    				continue
    			}
    			found, err := filepathx.Glob(pattern)
    			if err != nil {
    				return err
    			}
    			if len(found) == 0 {
    				return fmt.Errorf("unable to find file %v", pattern)
    			}
    			files = append(files, found...)
    		}
    		if len(files) == 0 {
    			return fmt.Errorf("no files found")
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  3. internal/config/identity/openid/openid.go

    			} else {
    				kvsrc.Value = "off"
    			}
    		}
    		res = append(res, madmin.IDPCfgInfo{
    			Key:   kvsrc.Key,
    			Value: kvsrc.Value,
    			IsCfg: true,
    			IsEnv: kvsrc.Src == config.ValueSourceEnv,
    		})
    	}
    
    	if provCfg, exists := r.ProviderCfgs[cfgName]; exists && provCfg.RolePolicy != "" {
    		// Append roleARN
    		res = append(res, madmin.IDPCfgInfo{
    			Key:   "roleARN",
    			Value: provCfg.roleArn.String(),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    	// Data blocks can vary per pool, but parity is same.
    	for i, setDriveCount := range z.SetDriveCounts() {
    		b.StandardSCData = append(b.StandardSCData, setDriveCount-scParity)
    		b.RRSCData = append(b.RRSCData, setDriveCount-rrSCParity)
    		b.DrivesPerSet = append(b.DrivesPerSet, setDriveCount)
    		b.TotalSets = append(b.TotalSets, z.serverPools[i].setCount)
    	}
    
    	b.StandardSCParity = scParity
    	b.RRSCParity = rrSCParity
    	return
    }
    
    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)
  5. internal/s3select/sql/jsonpath.go

    			if err != nil {
    				return nil, false, err
    			}
    
    			if flatten {
    				// Flatten if array.
    				if arr, ok := rval.([]interface{}); ok {
    					result = append(result, arr...)
    					continue
    				}
    			}
    			result = append(result, rval)
    		}
    		return result, true, nil
    	}
    	panic("cannot reach here")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  6. internal/config/lambda/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  7. internal/s3select/sql/stringfuncs.go

    	s := []rune{}
    	prev := runeZero
    	hasLeadingPercent := false
    	patLen := len([]rune(pattern))
    	for i, r := range pattern {
    		if i > 0 && prev == escape {
    			switch r {
    			case percent, escape, underscore:
    				s = append(s, r)
    				prev = r
    				if r == escape {
    					prev = runeZero
    				}
    			default:
    				return false, errMalformedEscapeSequence
    			}
    			continue
    		}
    
    		prev = r
    
    		var ok bool
    		switch r {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 4.2K bytes
    - Viewed (0)
  8. internal/mountinfo/mountinfo_linux.go

    		if strings.HasPrefix(mpath, ppath) {
    			// At this point if the mount point has a common prefix two conditions can happen.
    			// - mount.Path matches exact with `path` means we can proceed no error here.
    			// - mount.Path doesn't match (means cross-device mount), should error out.
    			if mount.Path != path {
    				crossMounts = append(crossMounts, mount)
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  9. cmd/bucket-targets.go

    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  10. cmd/listen-notification-handlers.go

    		eventName, err := event.ParseName(s)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
Back to top