Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for Butcher (0.18 sec)

  1. istioctl/pkg/wait/wait.go

    		}
    
    		return nil
    	})
    	return g
    }
    
    type watcher struct {
    	resultsChan chan string
    	errorChan   chan error
    	ctx         context.Context
    }
    
    func withContext(ctx context.Context) *watcher {
    	return &watcher{
    		resultsChan: make(chan string, 1),
    		errorChan:   make(chan error, 1),
    		ctx:         ctx,
    	}
    }
    
    func (w *watcher) Go(f func(chan string) error) {
    	go func() {
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Sat Feb 17 12:24:17 GMT 2024
    - 10.1K bytes
    - Viewed (0)
  2. cni/pkg/install/install.go

    		}
    	}
    	targets := append(
    		binPaths,
    		in.cfg.MountedCNINetDir,
    		constants.ServiceAccountPath,
    	)
    	// Create file watcher before checking for installation
    	// so that no file modifications are missed while and after checking
    	// note: we create a file watcher for each invocation, otherwise when we write to the directories
    	// we would get infinite looping of events
    	//
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  3. cni/pkg/install/cniconfig.go

    		if len(filename) == 0 {
    			filename = "YYY-istio-cni.conf"
    		}
    		return filepath.Join(cfg.mountedCNINetDir, filename), nil
    	}
    
    	watcher, err := util.CreateFileWatcher(cfg.mountedCNINetDir)
    	if err != nil {
    		return "", err
    	}
    	defer watcher.Close()
    
    	for len(filename) == 0 {
    		filename, err = getDefaultCNINetwork(cfg.mountedCNINetDir)
    		if err == nil {
    			break
    		}
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/stringfuncs_test.go

    		{"abcd", "bc", false, "", false},
    		{"abcd", "bc", true, "d", true},
    	}
    
    	for i, tc := range matcherCases {
    		res, ok := matcher(tc.iText, tc.iPat, tc.iHasLeadingPercent)
    		if res != tc.resultExpected || ok != tc.matchExpected {
    			t.Errorf("Matcher Case %d failed", i)
    		}
    	}
    
    	evalCases := []struct {
    		iText, iPat   string
    		iEsc          rune
    		matchExpected bool
    		errExpected   error
    	}{
    Go
    - Registered: Sun Apr 07 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.1K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    }
    
    // IAMStoreSys contains IAMStorageAPI to add higher-level methods on the storage
    // layer.
    type IAMStoreSys struct {
    	IAMStorageAPI
    }
    
    // HasWatcher - returns if the storage system has a watcher.
    func (store *IAMStoreSys) HasWatcher() bool {
    	_, ok := store.IAMStorageAPI.(iamStorageWatcher)
    	return ok
    }
    
    // GetUser - fetches credential from memory.
    Go
    - Registered: Sun Apr 14 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 74.4K bytes
    - Viewed (2)
  6. src/cmd/cgo/doc.go

    # Using cgo with the go command
    
    To use cgo write normal Go code that imports a pseudo-package "C".
    The Go code can then refer to types such as C.size_t, variables such
    as C.stdout, or functions such as C.putchar.
    
    If the import of "C" is immediately preceded by a comment, that
    comment, called the preamble, is used as a header when compiling
    the C parts of the package. For example:
    
    	// #include <stdio.h>
    Go
    - Registered: Tue Apr 16 11:13:10 GMT 2024
    - Last Modified: Sun Mar 31 09:02:45 GMT 2024
    - 42.1K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/cni-watcher.go

    Chun Li <******@****.***> 1707418344 +0800
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  8. cni/pkg/util/pluginutil.go

    	for _, path := range paths {
    		if !file.Exists(path) {
    			log.Infof("file watcher skipping watch on non-existent path: %v", path)
    			continue
    		}
    		if err := watcher.Add(path); err != nil {
    			if closeErr := watcher.Close(); closeErr != nil {
    				err = fmt.Errorf("%s: %w", closeErr.Error(), err)
    			}
    			return nil, err
    		}
    	}
    
    	return &Watcher{
    		watcher: watcher,
    		Events:  fileModified,
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/cni-watcher_test.go

    Ben Leggett <******@****.***> 1706861920 -0500
    Go
    - Registered: Wed Apr 17 22:53:10 GMT 2024
    - Last Modified: Fri Feb 02 08:18:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  10. cni/pkg/util/util.go

    	for _, path := range paths {
    		if !file.Exists(path) {
    			log.Infof("file watcher skipping watch on non-existent path: %v", path)
    			continue
    		}
    		if err := watcher.Add(path); err != nil {
    			if closeErr := watcher.Close(); closeErr != nil {
    				err = fmt.Errorf("%s: %w", closeErr.Error(), err)
    			}
    			return nil, err
    		}
    	}
    
    	return &Watcher{
    		watcher: watcher,
    		Events:  fileModified,
    Go
    - Registered: Wed Jan 24 22:53:09 GMT 2024
    - Last Modified: Thu Jul 20 18:34:43 GMT 2023
    - 3.6K bytes
    - Viewed (0)
Back to top