Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for Flush (0.14 sec)

  1. istioctl/pkg/writer/compare/sds/writer.go

    		if includeConfigType {
    			s.Name = fmt.Sprintf("secret/%s", s.Name)
    		}
    		fmt.Fprintf(tw, "%s\t%s\t%s\t%t\t%s\t%s\t%s\n",
    			s.Name, s.Type, s.State, s.Valid, s.SerialNumber, s.NotAfter, s.NotBefore)
    	}
    	return tw.Flush()
    }
    
    // printSecretItemsJSON prints secret in JSON format, and dumps the raw certificate data with the output
    func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 21 14:17:23 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    //
    // We will unconditionally flush our set before use here, so it shouldn't matter.
    func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) {
    	linDeps := ipset.RealNlDeps()
    	probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
    	if err != nil {
    		return probeSet, err
    	}
    	probeSet.Flush()
    	return probeSet, nil
    }
    
    func (s *Server) Start() {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_linux.go

    	if err != nil {
    		return fmt.Errorf("failed to delete IP %s with and proto %d from ipset %s: %w", ip, ipProto, name, err)
    	}
    	return nil
    }
    
    func (m *realDeps) flush(name string) error {
    	err := netlink.IpsetFlush(name)
    	if err != nil {
    		return fmt.Errorf("failed to flush ipset %s: %w", name, err)
    	}
    	return nil
    }
    
    // Alpine and some distros struggles with this - ipset CLI utilities support this, but
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. cni/pkg/ipset/nldeps_unspecified.go

    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) flush(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) clearEntriesWithComment(name, comment string) error {
    	return errors.New("not implemented on this platform")
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  5. bin/retry.sh

      while true; do
        unset SHELL # Don't let environment control which shell to use
        if isatty; then
          if [ "$(uname)" == "Darwin" ]; then
            script -q -r "${tmpFile}" "${*}"
          else
            script --flush --quiet --return "${tmpFile}" --command "${*}"
          fi
        else
          # if we aren't a TTY, run directly as script will always run with a tty, which may output content that
          # we cannot display
    Shell Script
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jun 11 16:08:08 GMT 2021
    - 2K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/ecds.go

    	if err != nil {
    		return err
    	}
    	for _, ecds := range dump {
    		fmt.Fprintf(w, "%v\t%v\n",
    			ecds.Name,
    			strings.TrimPrefix(ecds.GetTypedConfig().GetTypeUrl(), typeURLPrefix),
    		)
    	}
    
    	return w.Flush()
    }
    
    func (c *ConfigWriter) retrieveSortedEcds() ([]*core.TypedExtensionConfig, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Jan 14 02:41:27 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    				fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%x\t%v\t%v\n",
    					secret.Identity, t, secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom))
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func valueOrNA(value string) string {
    	if value == "" {
    		return "NA"
    	}
    	return value
    }
    
    func certNotExpired(cert *Cert) bool {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/ztunnel/configdump/services.go

    			_, ip, _ = strings.Cut(svc.Addresses[0], "/")
    		}
    		waypoint := serviceWaypointName(svc, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    			svc.Namespace, svc.Name, ip, waypoint)
    	}
    	return w.Flush()
    }
    
    // PrintServiceDump prints the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceDump(filter ServiceFilter, outputFormat string) error {
    	zDump := c.ztunnelDump
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/ztunnel/configdump/workload.go

    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\n",
    				wl.Namespace, wl.Name, ip, wl.Node, waypoint, wl.Protocol)
    		} else {
    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node)
    		}
    	}
    	return w.Flush()
    }
    
    // PrintWorkloadDump prints the relevant workloads in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintWorkloadDump(filter WorkloadFilter, outputFormat string) error {
    	zDump := c.ztunnelDump
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/table/writer.go

    		cells = append(cells, NewCell(name))
    	}
    	c.header = Row{Cells: cells}
    }
    
    func (c *ColoredTableWriter) AddRow(obj interface{}) {
    	c.rows = append(c.rows, c.addRowFunc(obj))
    }
    
    func (c *ColoredTableWriter) Flush() {
    	output := c.getTableOutput(c.rows)
    	if len(output) == 0 {
    		return
    	}
    	sep := getMaxWidths(output)
    	for _, row := range output {
    		for i, col := range row {
    			_, _ = fmt.Fprint(c.writer, col.String())
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Oct 08 04:41:42 GMT 2022
    - 2.8K bytes
    - Viewed (0)
Back to top