Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 294 for Kappen (0.18 sec)

  1. cmd/bootstrap-peer-server.go

    	var mismatching []string
    	for k, v := range s1.MinioEnv {
    		ev, ok := s2.MinioEnv[k]
    		if !ok {
    			missing = append(missing, k)
    		} else if v != ev {
    			mismatching = append(mismatching, k)
    		}
    	}
    	var extra []string
    	for k := range s2.MinioEnv {
    		_, ok := s1.MinioEnv[k]
    		if !ok {
    			extra = append(extra, k)
    		}
    	}
    	msg := "Expected same MINIO_ environment variables and values across all servers: "
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/data-usage-cache_gen.go

    	o = msgp.AppendUint64(o, z.Objects)
    	// string "vs"
    	o = append(o, 0xa2, 0x76, 0x73)
    	o = msgp.AppendUint64(o, z.Versions)
    	// string "dms"
    	o = append(o, 0xa3, 0x64, 0x6d, 0x73)
    	o = msgp.AppendUint64(o, z.DeleteMarkers)
    	// string "szs"
    	o = append(o, 0xa3, 0x73, 0x7a, 0x73)
    	o = msgp.AppendArrayHeader(o, uint32(dataUsageBucketLen))
    	for za0001 := range z.ObjSizes {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  3. cmd/erasure-common.go

    				//   unformatted or simply not accessible for some reason.
    				//
    				// - Do not consume disks which are being healed
    				//
    				// - Future: skip busy disks
    				return
    			}
    
    			mu.Lock()
    			newDisks = append(newDisks, disks[i])
    			mu.Unlock()
    		}()
    	}
    	wg.Wait()
    	return newDisks
    }
    
    func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) {
    	disks := er.getOnlineDisks()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/event/target/nats.go

    	if n.Username != "" && n.Password != "" {
    		connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password))
    	}
    	if n.UserCredentials != "" {
    		connOpts = append(connOpts, nats.UserCredentials(n.UserCredentials))
    	}
    	if n.Token != "" {
    		connOpts = append(connOpts, nats.Token(n.Token))
    	}
    	if n.Secure || n.TLS && n.TLSSkipVerify {
    		connOpts = append(connOpts, nats.Secure(nil))
    	} else if n.TLS {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 27 18:11:55 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  5. docs/debugging/xattr/main.go

    			}
    			names = append(names, attrs...)
    		} else {
    			names = append(names, name)
    		}
    		var data [][]string
    		for _, attr := range names {
    			value, err := getxattr(path, attr)
    			if err != nil {
    				data = append(data, []string{attr, errors.Unwrap(err).Error()})
    			} else {
    				data = append(data, []string{attr, fmt.Sprintf("%d", value)})
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  6. 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)
  7. internal/grid/types.go

    // Value returns the underlying value.
    // Regular append mechanics should be observed.
    // If no value has been set yet, a new array is created.
    func (j *Array[T]) Value() []T {
    	if j.val == nil {
    		j.val = j.p.newA(10)
    	}
    	return j.val
    }
    
    // Append a value to the underlying array.
    // The returned Array is always the same as the one called.
    func (j *Array[T]) Append(v ...T) *Array[T] {
    	if j.val == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  8. internal/hash/checksum.go

    	var tmp [binary.MaxVarintLen32]byte
    	n := binary.PutUvarint(tmp[:], uint64(c.Type))
    	crc := c.Raw
    	if len(crc) != c.Type.RawByteLen() {
    		return b
    	}
    	b = append(b, tmp[:n]...)
    	b = append(b, crc...)
    	if c.Type.Is(ChecksumMultipart) {
    		var checksums int
    		// Ensure we don't divide by 0:
    		if c.Type.RawByteLen() == 0 || len(parts)%c.Type.RawByteLen() != 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top