Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for flush (0.14 sec)

  1. 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 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. 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 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  3. 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 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  4. 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 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  5. 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 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  6. cni/pkg/ipset/nldeps_mock.go

    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	args := m.Called(name, ip, ipProto)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) flush(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) clearEntriesWithComment(name, comment string) error {
    	args := m.Called(name, comment)
    	return args.Error(0)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  7. 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 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			for _, c := range wl.Connections.Outbound {
    				fmt.Fprintf(w, "%v\tOutbound\t%v\t%v\t%v\n", name, lookupIP(c.Src), lookupIP(c.ActualDst), lookupIP(c.OriginalDst))
    			}
    		}
    	}
    	return w.Flush()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  9. cni/pkg/ipset/ipset.go

    	if ipToDel.Is6() {
    		return m.Deps.deleteIP(m.V6Name, ipToDel, ipProto)
    	}
    	return m.Deps.deleteIP(m.V4Name, ipToDel, ipProto)
    }
    
    func (m *IPSet) Flush() error {
    	var err error
    	err = m.Deps.flush(m.V4Name)
    
    	if m.V6Name != "" {
    		v6err := m.Deps.flush(m.V6Name)
    		err = errors.Join(err, v6err)
    	}
    	return err
    }
    
    func (m *IPSet) ClearEntriesWithComment(comment string) error {
    	var err error
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/ztunnel/configdump/policies.go

    	})
    	fmt.Fprintln(w, "NAMESPACE\tPOLICY NAME\tACTION\tSCOPE")
    
    	for _, pol := range pols {
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    			pol.Namespace, pol.Name, pol.Action, pol.Scope)
    	}
    	return w.Flush()
    }
    
    // PrintPolicyDump prints the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPolicyDump(filter PolicyFilter, outputFormat string) error {
    	zDump := c.ztunnelDump
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.5K bytes
    - Viewed (0)
Back to top