- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 180 for error (0.24 sec)
-
cni/pkg/nodeagent/error.go
package nodeagent import ( "errors" "fmt" ) var ErrPartialAdd = errors.New("partial add error") type PartialAddError struct { inner error } func (e *PartialAddError) Error() string { return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner) } func (e *PartialAddError) Unwrap() []error { return []error{ErrPartialAdd, e.inner} }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
loopbackLink, err := netlink.LinkByName("lo") if err != nil { return fmt.Errorf("failed to find 'lo' link: %v", err) } // Set up netlink routes for localhost cidrs := []string{"0.0.0.0/0"} if cfg.EnableIPv6 { cidrs = append(cidrs, "0::0/0") } for _, fullCIDR := range cidrs { _, localhostDst, err := net.ParseCIDR(fullCIDR) if err != nil { return fmt.Errorf("parse CIDR: %v", err) }
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) -
cni/pkg/ipset/nldeps_unspecified.go
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) -
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) -
istioctl/pkg/tag/tag.go
Args: func(cmd *cobra.Command, args []string) error { if len(args) == 0 { return fmt.Errorf("must provide a tag for removal") } if len(args) > 1 { return fmt.Errorf("must provide a single tag for removal") } return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return fmt.Errorf("failed to create Kubernetes client: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
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) -
cni/pkg/nodeagent/net.go
if err := s.netnsRunner(openNetns, func() error { return s.iptablesConfigurator.DeleteInpodRules() }); err != nil { log.Errorf("failed to delete inpod rules %v", err) return fmt.Errorf("failed to delete inpod rules %w", err) } if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil { log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err) return err }
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) -
istioctl/pkg/tag/util.go
func GetWebhookRevision(wh admitv1.MutatingWebhookConfiguration) (string, error) { if tagName, ok := wh.ObjectMeta.Labels[label.IoIstioRev.Name]; ok { return tagName, nil } return "", fmt.Errorf("could not extract tag revision from webhook") } // DeleteTagWebhooks deletes the given webhooks. func DeleteTagWebhooks(ctx context.Context, client kubernetes.Interface, tag string) error { webhooks, err := GetWebhooksWithTag(ctx, client, tag)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1) -
cni/pkg/iptables/nldeps.go
type NetlinkDependencies interface { AddInpodMarkIPRule(cfg *Config) error DelInpodMarkIPRule(cfg *Config) error AddLoopbackRoutes(cfg *Config) error DelLoopbackRoutes(cfg *Config) error } func RealNlDeps() NetlinkDependencies { return &realDeps{} } type realDeps struct{} func (r *realDeps) AddInpodMarkIPRule(cfg *Config) error { return AddInpodMarkIPRule(cfg) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
netns, err := runInHost(func() (string, error) { return getPodNetNs(pod) }) if err != nil { m.With(resultLabel.Value(resultFail)).Increment() return fmt.Errorf("get netns: %v", err) } log = log.WithLabels("netns", netns) if err := redirectRunningPod(pod, netns); err != nil { log.Errorf("failed to setup redirection: %v", err) m.With(resultLabel.Value(resultFail)).Increment()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)