Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1001 - 1010 of 1,427 for appends (0.19 sec)

  1. cmd/peer-rest-server.go

    	for _, ev := range values[peerRESTListenEvents] {
    		eventName, err := event.ParseName(ev)
    		if err != nil {
    			return grid.NewRemoteErr(err)
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  2. internal/kms/config.go

    			continue
    		}
    		if !ellipses.HasEllipses(endpoint) {
    			endpoints = append(endpoints, endpoint)
    			continue
    		}
    
    		pattern, err := ellipses.FindEllipsesPatterns(endpoint)
    		if err != nil {
    			return nil, fmt.Errorf("kms: invalid endpoint '%s': %v", endpoint, err)
    		}
    		for _, p := range pattern.Expand() {
    			endpoints = append(endpoints, strings.Join(p, ""))
    		}
    	}
    	return endpoints, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    			innerResults := make(chan metaCacheEntry, 100)
    			inputs = append(inputs, innerResults)
    			go func(i int, set *erasureObjects) {
    				defer wg.Done()
    				err := set.listPath(listCtx, o, innerResults)
    				mu.Lock()
    				defer mu.Unlock()
    				if err == nil {
    					allAtEOF = false
    				}
    				errs[i] = err
    			}(len(errs), set)
    			errs = append(errs, nil)
    		}
    	}
    	mu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. docs/minio-limits.md

    > **This list is non exhaustive, it depends on the operating system and filesystem under use - please consult your operating system vendor for a more comprehensive list of special characters**.
    
    MinIO recommends using Linux operating system for production workloads.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. common/config/license-lint.yml

    - github.com/xeipuuv/gojsonreference
    # Apache 2.0: https://github.com/xeipuuv/gojsonschema/blob/master/LICENSE-APACHE-2.0.txt
    - github.com/xeipuuv/gojsonschema
    
    # Apache 2.0 (but missing appendix): https://github.com/garyburd/redigo/blob/master/LICENSE
    - github.com/garyburd/redigo
    - github.com/gomodule/redigo
    
    # Apache 2.0
    #   github.com/ghodss/yaml: MIT / BSD-3
    #   github.com/gogo/protobuf: BSD-3
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 25 19:26:20 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. internal/s3select/jstream/decoder.go

    	if c = d.skipSpaces(); c == ']' {
    		goto out
    	}
    
    scan:
    	if v, err = d.emitAny(); err != nil {
    		goto out
    	}
    
    	if d.depth > d.emitDepth { // skip alloc for array if it won't be emitted
    		array = append(array, v)
    	}
    
    	// next token must be ',' or ']'
    	switch c = d.skipSpaces(); c {
    	case ',':
    		d.skipSpaces()
    		goto scan
    	case ']':
    		goto out
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. cmd/endpoint_test.go

    	}
    	getExpectedEndpoints := func(args []string, prefix string) ([]*url.URL, []bool) {
    		var URLs []*url.URL
    		var localFlags []bool
    		for _, arg := range args {
    			u, _ := url.Parse(arg)
    			URLs = append(URLs, u)
    			localFlags = append(localFlags, strings.HasPrefix(arg, prefix))
    		}
    
    		return URLs, localFlags
    	}
    
    	case1Endpoint1 := "http://" + nonLoopBackIP + "/d1"
    	case1Endpoint2 := "http://" + nonLoopBackIP + "/d2"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jan 13 07:53:03 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  8. docs/bigdata/README.md

    fs.s3a.block.size=512M
    fs.s3a.buffer.dir=${hadoop.tmp.dir}/s3a
    fs.s3a.committer.magic.enabled=false
    fs.s3a.committer.name=directory
    fs.s3a.committer.staging.abort.pending.uploads=true
    fs.s3a.committer.staging.conflict-mode=append
    fs.s3a.committer.staging.tmp.path=/tmp/staging
    fs.s3a.committer.staging.unique-filenames=true
    fs.s3a.connection.establish.timeout=5000
    fs.s3a.connection.ssl.enabled=false
    fs.s3a.connection.timeout=200000
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4_test.go

    		{"10000000000000000", 0, "http chunk length too large"},
    		{"00000000000000001", 0, "http chunk length too large"}, // could accept if we wanted
    	}
    	for i := uint64(0); i <= 1234; i++ {
    		tests = append(tests, testCase{in: fmt.Sprintf("%x", i), want: i})
    	}
    	for _, tt := range tests {
    		got, err := parseHexUint([]byte(tt.in))
    		if tt.wantErr != "" {
    			if err != nil && !strings.Contains(err.Error(), tt.wantErr) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  10. internal/crypto/sse-s3.go

    	}
    	keys := make([]ObjectKey, 0, len(metadata))
    	for i := range metadata {
    		key, err := s3.UnsealObjectKey(k, metadata[i], buckets[i], objects[i])
    		if err != nil {
    			return nil, err
    		}
    		keys = append(keys, key)
    	}
    	return keys, nil
    }
    
    // CreateMetadata encodes the sealed object key into the metadata and returns
    // the modified metadata. If the keyID and the kmsKey is not empty it encodes
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top