Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for ERROR (0.13 sec)

  1. cni/pkg/ipset/nldeps_unspecified.go

    	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")
    }
    
    func (m *realDeps) clearEntriesWithIP(name string, ip netip.Addr) error {
    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)
  2. cni/pkg/iptables/iptables_linux.go

    		}
    	}
    
    	return nil
    }
    
    func AddLoopbackRoutes(cfg *Config) error {
    	return forEachLoopbackRoute(cfg, netlink.RouteReplace)
    }
    
    func DelLoopbackRoutes(cfg *Config) error {
    	return forEachLoopbackRoute(cfg, netlink.RouteDel)
    }
    
    func forEachLoopbackRoute(cfg *Config, f func(*netlink.Route) error) error {
    	loopbackLink, err := netlink.LinkByName("lo")
    	if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  3. istioctl/pkg/waypoint/waypoint.go

    		Args: func(cmd *cobra.Command, args []string) error {
    			if deleteAll && len(args) > 0 {
    				return fmt.Errorf("cannot specify waypoint names when deleting all waypoints")
    			}
    			if !deleteAll && len(args) == 0 {
    				return fmt.Errorf("must either specify a waypoint name or delete all using --all")
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClient()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server.go

    	ConstructInitialSnapshot(ambientPods []*corev1.Pod) error
    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error
    	DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error
    
    	Stop()
    }
    
    type Server struct {
    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)
  5. cni/pkg/nodeagent/net.go

    	currentPodSnapshot   *podNetnsCache
    	iptablesConfigurator *iptables.IptablesConfigurator
    	podNs                PodNetnsFinder
    	// allow overriding for tests
    	netnsRunner        func(fdable NetnsFd, toRun func() error) error
    	hostsideProbeIPSet ipset.IPSet
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  6. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    	out := c.FullDump
    	if outputFormat == "yaml" {
    		var err error
    		out, err = yaml.JSONToYAML(out)
    		if err != nil {
    			return err
    		}
    	}
    	fmt.Fprintln(c.Stdout, string(out))
    	return nil
    }
    
    // PrintVersionSummary prints version information for Istio and Ztunnel from the config dump
    func (c *ConfigWriter) PrintVersionSummary() error {
    	// TODO
    	return nil
    }
    
    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)
  7. istioctl/pkg/writer/ztunnel/configdump/services.go

    		}
    	}
    
    	return true
    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	svcs := slices.Filter(maps.Values(zDump.Services), filter.Verify)
    	slices.SortFunc(svcs, func(a, b *ZtunnelService) int {
    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)
  8. istioctl/pkg/writer/compare/comparator.go

    	w             io.Writer
    	context       int
    	location      string
    }
    
    // NewComparator is a comparator constructor
    func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) {
    	c := &Comparator{}
    	for _, resp := range istiodResponses {
    		istiodDump := &configdump.Wrapper{}
    		err := json.Unmarshal(resp, istiodDump)
    		if err != nil {
    			continue
    		}
    		c.istiod = istiodDump
    		break
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 3.7K bytes
    - Viewed (1)
  9. istioctl/pkg/util/configdump/wrapper.go

    	*protoregistry.Types
    }
    
    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) {
    	typ, err := r.Types.FindMessageByURL(url)
    	if err != nil {
    		// Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change
    		msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  10. cni/pkg/ipset/nldeps_linux.go

    		return nil
    	}
    
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	err := netlink.IpsetAdd(name, &netlink.IPSetEntry{
    		Comment:  comment,
    		IP:       net.IP(ip.AsSlice()),
    		Protocol: &ipProto,
    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)
Back to top