Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 301 for Kappen (0.07 sec)

  1. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. internal/store/queuestore.go

    	entries := make([]string, 0, len(store.entries))
    	for entry := range store.entries {
    		entries = append(entries, entry)
    	}
    
    	// Sort entries...
    	sort.Slice(entries, func(i, j int) bool {
    		return store.entries[entries[i]] < store.entries[entries[j]]
    	})
    
    	for i := range entries {
    		keys = append(keys, parseKey(entries[i]))
    	}
    
    	return keys
    }
    
    // list will read all entries from disk.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. internal/s3select/simdj/record.go

    	}
    	for _, elem := range elems.Elements {
    		v, err := sql.IterToValue(elem.Iter)
    		if err != nil {
    			v, err = elem.Iter.Interface()
    			if err != nil {
    				panic(err)
    			}
    		}
    		dst.KVS = append(dst.KVS, jstream.KV{
    			Key:   elem.Name,
    			Value: v,
    		})
    	}
    	return dst, nil
    }
    
    // Set - sets the value for a column name.
    func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. cmd/postpolicyform.go

    				}
    				// {"acl": "public-read" } is an alternate way to indicate - [ "eq", "$acl", "public-read" ]
    				// In this case we will just collapse this into "eq" for all use cases.
    				parsedPolicy.Conditions.Policies = append(parsedPolicy.Conditions.Policies, struct {
    					Operator string
    					Key      string
    					Value    string
    				}{
    					policyCondEqual, "$" + strings.ToLower(k), toString(v),
    				})
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. internal/logger/config.go

    		for _, k := range envs {
    			target := strings.TrimPrefix(k, legacyEnvLoggerHTTPEndpoint+config.Default)
    			if target == legacyEnvLoggerHTTPEndpoint {
    				target = config.Default
    			}
    			loggerTargets = append(loggerTargets, target)
    		}
    
    		// Load HTTP logger from the environment if found
    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  7. internal/grid/grid.go

    // as an error to be reported.
    func readAllInto(b []byte, r *wsutil.Reader, want int64) ([]byte, error) {
    	read := int64(0)
    	for {
    		if len(b) == cap(b) {
    			// Add more capacity (let append pick how much).
    			b = append(b, 0)[:len(b)]
    		}
    		n, err := r.Read(b[len(b):cap(b)])
    		b = b[:len(b)+n]
    		if err != nil {
    			if errors.Is(err, io.EOF) {
    				if want >= 0 && read+int64(n) != want {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. cmd/metacache-stream.go

    		return metaCacheEntriesSorted{}, io.EOF
    	}
    
    	if r.current.name != "" {
    		if (inclDeleted || !r.current.isLatestDeletemarker()) && r.current.hasPrefix(prefix) && (inclDirs || r.current.isObject()) {
    			res = append(res, r.current)
    		}
    		r.current.name = ""
    		r.current.metadata = nil
    	}
    
    	for n < 0 || len(res) < n {
    		if more, err := r.mr.ReadBool(); !more {
    			switch err {
    			case nil:
    				r.err = io.EOF
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  9. internal/s3select/csv/recordtransform.go

    		}
    		return n, nil
    	}
    
    	// 2 characters...
    	for idx := 0; idx < len(p); {
    		i := bytes.Index(p[idx:], rr.recordDelimiter)
    		if i < 0 {
    			break
    		}
    		idx += i
    
    		p[idx] = '\n'
    		p = append(p[:idx+1], p[idx+2:]...)
    		n--
    	}
    
    	if p[n-1] != rr.recordDelimiter[0] {
    		return n, nil
    	}
    
    	if _, err = rr.reader.Read(rr.oneByte); err != nil {
    		return n, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  10. cmd/bucket-handlers_test.go

    		for _, objectName := range objectNames {
    			objectList = append(objectList, ObjectToDelete{
    				ObjectV: ObjectV{
    					ObjectName: objectName,
    				},
    			})
    		}
    
    		return objectList
    	}
    
    	getDeleteErrorList := func(objects []ObjectToDelete) (deleteErrorList []DeleteError) {
    		for _, obj := range objects {
    			deleteErrorList = append(deleteErrorList, DeleteError{
    				Code:    errorCodes[ErrAccessDenied].Code,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
Back to top