Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for delete (0.15 sec)

  1. cni/pkg/nodeagent/net.go

    	}
    
    	log.Debug("in pod mode - removing pod from ztunnel")
    	if err := s.ztunnelServer.PodDeleted(ctx, string(pod.UID)); err != nil {
    		log.Errorf("failed to delete pod from ztunnel: %v", err)
    	}
    	return nil
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    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)
  2. cni/pkg/nodeagent/server.go

    	}
    	return err
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *meshDataplane) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	err := s.netServer.DelPodFromMesh(ctx, pod)
    	if err != nil {
    		log.Errorf("failed to delete pod from mesh: %v", err)
    		return err
    	}
    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)
  3. cni/pkg/iptables/iptables.go

    	}
    	return nil
    }
    
    func (cfg *IptablesConfigurator) DeleteHostRules() {
    	log.Debug("Attempting to delete hostside iptables rules (if they exist)")
    
    	cfg.executeHostDeleteCommands()
    }
    
    func (cfg *IptablesConfigurator) executeHostDeleteCommands() {
    	optionalDeleteCmds := [][]string{
    		// delete our main jump in the host ruleset. If it's not there, NBD.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	fixture.podNsMap.UpsertPodCacheWithNetns(string(pod.UID), workload)
    	err := netServer.DelPodFromMesh(ctx, pod)
    	assert.NoError(t, err)
    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	// with delete iptables is not called, as there is no need to delete the iptables rules
    	// from a pod that's gone from the cluster.
    	assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 0)
    	assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 0)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_linux.go

    	}
    	return nil
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	err := netlink.IpsetDel(name, &netlink.IPSetEntry{
    		IP:       net.IP(ip.AsSlice()),
    		Protocol: &ipProto,
    	})
    	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
    }
    
    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)
  6. istioctl/pkg/waypoint/waypoint.go

    	waypointDeleteCmd := &cobra.Command{
    		Use:   "delete",
    		Short: "Delete a waypoint configuration",
    		Long:  "Delete a waypoint configuration from the cluster",
    		Example: `  # Delete a waypoint from the default namespace
      istioctl x waypoint delete
    
      # Delete a waypoint by name, which can obtain from istioctl x waypoint list
      istioctl x waypoint delete waypoint-name --namespace default
    
    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)
  7. cni/pkg/ipset/nldeps_mock.go

    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	args := m.Called(name, ip, ipProto, comment, replace)
    	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)
    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)
  8. operator/cmd/mesh/install.go

    		return fmt.Errorf("errors occurred during operation")
    	}
    
    	// Previously we may install IOP file from the old version of istioctl. Now since we won't install IOP file
    	// anymore, and it didn't provide much value, we can delete it if it exists.
    	reconciler.DeleteIOPInClusterIfExists(iop)
    
    	opts.ProgressLog.SetState(progress.StateComplete)
    
    	return nil
    }
    
    func savedIOPName(iop *v1alpha12.IstioOperator) string {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 14:30:43 GMT 2024
    - 15.5K bytes
    - Viewed (1)
  9. cni/pkg/config/config.go

    	NodeName string
    
    	// Key and value for broken pod label
    	LabelKey   string
    	LabelValue string
    
    	// Whether to fix race condition by repairing them
    	RepairPods bool
    
    	// Whether to fix race condition by delete broken pods
    	DeletePods bool
    
    	// Whether to label broken pods
    	LabelPods bool
    
    	// Filters for race repair, including name of sidecar annotation, name of init container,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  10. cni/pkg/constants/constants.go

    	AmbientEnabled       = "ambient-enabled"
    	AmbientDNSCapture    = "ambient-dns-capture"
    	AmbientIPv6          = "ambient-ipv6"
    
    	// Repair
    	RepairEnabled            = "repair-enabled"
    	RepairDeletePods         = "repair-delete-pods"
    	RepairRepairPods         = "repair-repair-pods"
    	RepairLabelPods          = "repair-label-pods"
    	RepairLabelKey           = "repair-broken-pod-label-key"
    	RepairLabelValue         = "repair-broken-pod-label-value"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 2.7K bytes
    - Viewed (0)
Back to top