Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewReader (0.22 sec)

  1. cni/pkg/iptables/iptables.go

    	}
    
    	log.Infof("Running %s with the following input:\n%v", iptVer.CmdToString(cmd), strings.TrimSpace(data))
    	// --noflush to prevent flushing/deleting previous contents from table
    	return cfg.ext.Run(cmd, iptVer, strings.NewReader(data), "--noflush", "-v")
    }
    
    func (cfg *IptablesConfigurator) addLoopbackRoute() error {
    	return cfg.nlDeps.AddLoopbackRoutes(cfg.cfg)
    }
    
    func (cfg *IptablesConfigurator) delLoopbackRoute() error {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  2. istioctl/pkg/tag/tag.go

    	sa := local.NewSourceAnalyzer(analysis.Combine("webhook", &webhook.Analyzer{}), "", resource.Namespace(istioNamespace), nil)
    	if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil {
    		return err
    	}
    	k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
    	if err != nil {
    		return err
    	}
    	sa.AddRunningKubeSourceWithRevision(k, revision, false)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 16.3K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/podcgroupns.go

    //   - http://man7.org/linux/man-pages/man7/cgroups.7.html
    //   - https://www.kernel.org/doc/Documentation/cgroup-v2.txt
    func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) {
    	reader := bytes.NewReader(procCgroupData.Bytes())
    	var cgroups []Cgroup
    	scanner := bufio.NewScanner(reader)
    
    	for scanner.Scan() {
    		token := scanner.Text()
    		substrings := strings.SplitN(token, ":", 3)
    		if len(substrings) < 3 {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  4. operator/cmd/mesh/manifest-generate_test.go

    		return nil, nil
    	}
    }
    
    func extract(gzipStream io.Reader, destination string) error {
    	uncompressedStream, err := gzip.NewReader(gzipStream)
    	if err != nil {
    		return fmt.Errorf("create gzip reader: %v", err)
    	}
    
    	tarReader := tar.NewReader(uncompressedStream)
    
    	for {
    		header, err := tarReader.Next()
    		if err == io.EOF {
    			break
    		}
    		if err != nil {
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Thu Feb 22 08:32:23 GMT 2024
    - 42K bytes
    - Viewed (0)
Back to top