Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 531 - 540 of 690 for appendTo (0.04 seconds)

  1. cmd/data-scanner.go

    				delete(abandonedChildren, h.Key()) // h.Key() already accounted for.
    				if exists {
    					existingFolders = append(existingFolders, this)
    					f.updateCache.copyWithChildren(&f.oldCache, h, &thisHash)
    				} else {
    					newFolders = append(newFolders, this)
    				}
    				return nil
    			}
    
    			wait := noWait
    			if f.weSleep() {
    				// Dynamic time delay.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  2. cmd/consolelogger.go

    func (sys *HTTPConsoleLoggerSys) Content() (logs []log.Entry) {
    	sys.RLock()
    	sys.logBuf.Do(func(p any) {
    		if p != nil {
    			lg, ok := p.(log.Info)
    			if ok {
    				if (lg.Entry != log.Entry{}) {
    					logs = append(logs, lg.Entry)
    				}
    			}
    		}
    	})
    	sys.RUnlock()
    
    	return logs
    }
    
    // Cancel - cancels the target
    func (sys *HTTPConsoleLoggerSys) Cancel() {
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  3. internal/config/lambda/parse.go

    		for id, args := range webhookTargets {
    			if !args.Enable {
    				continue
    			}
    			t, err := target.NewWebhookTarget(ctx, id, args, logOnceIf, transport)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    		}
    	}
    	return targets, nil
    }
    
    // FetchEnabledTargets - Returns a set of configured TargetList
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. schema/naming.go

    )
    
    func init() {
    	commonInitialismsForReplacer := make([]string, 0, len(commonInitialisms))
    	for _, initialism := range commonInitialisms {
    		commonInitialismsForReplacer = append(commonInitialismsForReplacer, initialism, cases.Title(language.Und).String(initialism))
    	}
    	commonInitialismsReplacer = strings.NewReplacer(commonInitialismsForReplacer...)
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Jun 12 03:46:59 GMT 2024
    - 5.3K bytes
    - Click Count (0)
  5. cmd/os_windows.go

    				// directory symlinks are ignored.
    				continue
    			}
    		case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0:
    			name += SlashSeparator
    		}
    
    		count--
    		entries = append(entries, name)
    	}
    
    	return entries, nil
    }
    
    func globalSync() {
    	// no-op on windows
    }
    
    func syscallErrToFileErr(dirPath string, err error) error {
    	switch err {
    	case nil:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5K bytes
    - Click Count (0)
  6. internal/disk/stat_linux.go

    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    	for _, token := range strings.Fields(statLine) {
    		ui64, err := strconv.ParseUint(token, 10, 64)
    		if err != nil {
    			return nil, err
    		}
    		stats = append(stats, ui64)
    	}
    
    	return stats, nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  7. cmd/config.go

    				}
    
    				data, err = decryptData(data, obj.Name)
    				if err != nil {
    					// ignore history file that cannot be loaded.
    					continue
    				}
    
    				cfgEntry.Data = string(data)
    			}
    			configHistory = append(configHistory, cfgEntry)
    			count--
    			if count == 0 {
    				break
    			}
    		}
    		if !res.IsTruncated {
    			// We are done here
    			break
    		}
    		marker = res.NextMarker
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  8. 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()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  9. src/archive/tar/reader.go

    			if (len(sparseMap)%2 == 0 && key != paxGNUSparseOffset) ||
    				(len(sparseMap)%2 == 1 && key != paxGNUSparseNumBytes) ||
    				strings.Contains(value, ",") {
    				return nil, ErrHeader
    			}
    			sparseMap = append(sparseMap, value)
    		default:
    			paxHdrs[key] = value
    		}
    	}
    	if len(sparseMap) > 0 {
    		paxHdrs[paxGNUSparseMap] = strings.Join(sparseMap, ",")
    	}
    	return paxHdrs, nil
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 26.9K bytes
    - Click Count (0)
  10. cmd/bucket-notification-handlers.go

    				// notification targets without removing ARN in notification
    				// configuration we won't see this problem anymore.
    				if reflect.DeepEqual(queue.ARN, arnErr.ARN) && i < len(config.QueueList) {
    					config.QueueList = append(config.QueueList[:i],
    						config.QueueList[i+1:]...)
    				}
    				// This is a one time activity we shall do this
    				// here and allow stale ARN to be removed. We shall
    				// never reach a stage where we will have stale
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
Back to Top